import os import io import sys import time import json import subprocess import threading import requests import urllib3 from flask import Flask, request, jsonify import google.generativeai as genai from dotenv import load_dotenv from werkzeug.utils import secure_filename from PyQt5.QtWidgets import QApplication, QMainWindow from PyQt5.QtWebEngineWidgets import QWebEngineView from PyQt5.QtGui import QIcon from PyQt5.QtCore import QUrl if getattr(sys, 'frozen', False): sys.stdout = open(os.devnull, 'w') sys.stderr = open(os.devnull, 'w') BASE_DIR = os.path.dirname(sys.executable) ASSETS_DIR = sys._MEIPASS else: BASE_DIR = os.path.dirname(os.path.abspath(__file__)) ASSETS_DIR = BASE_DIR CERT_FILE = os.path.join(BASE_DIR, "certificate.crt") if os.path.exists(CERT_FILE): os.environ["REQUESTS_CA_BUNDLE"] = CERT_FILE os.environ["SSL_CERT_FILE"] = CERT_FILE else: urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning) old_merge_environment_settings = requests.Session.merge_environment_settings def merge_environment_settings(self, url, proxies, stream, verify, cert): settings = old_merge_environment_settings(self, url, proxies, stream, verify, cert) settings['verify'] = False return settings requests.Session.merge_environment_settings = merge_environment_settings app = Flask(__name__) ENV_FILE = os.path.join(BASE_DIR, ".env") if not os.path.exists(ENV_FILE): with open(ENV_FILE, "w", encoding="utf-8") as f: f.write("GOOGLE_API_KEY=\n") load_dotenv(ENV_FILE) PROJECTS_DIR = os.path.join(BASE_DIR, "projects") UPLOADS_DIR = os.path.join(BASE_DIR, "uploads") KNOWLEDGE_DIR = os.path.join(BASE_DIR, "knowledge_bases") for d in [PROJECTS_DIR, UPLOADS_DIR, KNOWLEDGE_DIR]: if not os.path.exists(d): os.makedirs(d) MODEL_MAIN_NAME = 'gemini-3.1-pro-preview' MODEL_FAST_NAME = 'gemini-3.1-flash-lite-preview' model_main = None model_fast = None chat_session = None def init_gemini(): global model_main, model_fast, chat_session api_key = os.getenv("GOOGLE_API_KEY") if api_key: try: genai.configure(api_key=api_key, transport='rest') model_main = genai.GenerativeModel(MODEL_MAIN_NAME) model_fast = genai.GenerativeModel(MODEL_FAST_NAME) chat_session = model_fast.start_chat(history=[]) except Exception as e: pass init_gemini() stop_generation_flag = False HTML_CONTENT = """ JARVIS V5 ULTIMATE
""" @app.route('/') def home(): return HTML_CONTENT @app.route('/api/settings', methods=['POST']) def save_settings(): try: data = request.json new_key = data.get('api_key') if new_key: with open(ENV_FILE, "w", encoding="utf-8") as f: f.write(f"GOOGLE_API_KEY={new_key}\n") os.environ["GOOGLE_API_KEY"] = new_key init_gemini() return jsonify({'success': True}) return jsonify({'success': False}) except Exception as e: return jsonify({'error': str(e)}), 500 @app.route('/api/chat', methods=['POST']) def chat(): if not chat_session: return jsonify({'error': 'Missing API Key. Please configure it in settings.'}), 400 try: uploaded_file = None if 'file' in request.files: file = request.files['file'] if file.filename != '': filename = secure_filename(file.filename) path = os.path.join(UPLOADS_DIR, filename) file.save(path) uploaded_file = genai.upload_file(path) user_msg = request.form.get('message') if uploaded_file: response = chat_session.send_message([user_msg, uploaded_file]) else: response = chat_session.send_message(user_msg) return jsonify({'response': response.text}) except Exception as e: return jsonify({'error': str(e)}), 500 @app.route('/api/content', methods=['POST']) def generate_content(): if not model_main: return jsonify({'error': 'Missing API Key.'}), 400 try: data = request.json prompt = f"נושא: {data.get('topic')}. סוג: {data.get('type')}. כתוב בעברית ברמה אקדמית." response = model_main.generate_content(prompt) return jsonify({'content': response.text}) except Exception as e: return jsonify({'error': str(e)}), 500 @app.route('/api/code', methods=['POST']) def generate_code_direct(): if not model_main: return jsonify({'error': 'Missing API Key.'}), 400 try: data = request.json proj_name = data.get('projectName') target_dir = os.path.join(PROJECTS_DIR, proj_name) if not os.path.exists(target_dir): os.makedirs(target_dir) prompt = f''' Act as an Expert Developer using {MODEL_MAIN_NAME}. Project: {proj_name} Description: {data.get('description')} OUTPUT FORMAT ONLY: ###FILENAME: filename.ext content... NO MARKDOWN. ''' response = model_main.generate_content(prompt) files_created = [] files = response.text.split("###FILENAME: ") for f in files: if not f.strip(): continue parts = f.split("\n", 1) if len(parts) < 2: continue filename = parts[0].strip() content = parts[1].replace("```python", "").replace("```", "") full_path = os.path.join(target_dir, filename) os.makedirs(os.path.dirname(full_path), exist_ok=True) with open(full_path, "w", encoding="utf-8") as file: file.write(content) files_created.append(filename) if not files_created: raise Exception("No files generated") return jsonify({'success': True, 'path': target_dir, 'files': files_created}) except Exception as e: return jsonify({'error': str(e)}), 500 @app.route('/api/agent_execute', methods=['POST']) def agent_execute(): if not model_main: return jsonify({'log': 'Missing API Key.'}) try: data = request.json user_request = data.get('request') prompt = f''' You are an Autonomous System Agent. User Request: "{user_request}" Supported Actions JSON format: [ {{"action": "create_folder", "path": "name"}}, {{"action": "create_file", "path": "name.txt", "content": "text"}}, {{"action": "open_app", "app_name": "calc"}}, {{"action": "run_cmd", "command": "ping 8.8.8.8"}} ] RETURN ONLY JSON ARRAY. ''' plan_response = model_main.generate_content(prompt) plan_text = plan_response.text.replace("```json", "").replace("```", "").strip() try: actions = json.loads(plan_text) except: start = plan_text.find('[') end = plan_text.rfind(']') + 1 if start != -1 and end != -1: actions = json.loads(plan_text[start:end]) else: return jsonify({'log': "❌ שגיאה בפענוח הפקודה. נסה שוב."}) log = [] for act in actions: action = act.get('action') try: if action == 'create_folder': path = os.path.join(PROJECTS_DIR, act.get('path')) os.makedirs(path, exist_ok=True) log.append(f"✅ תיקייה: {act.get('path')}") elif action == 'create_file': path = os.path.join(PROJECTS_DIR, act.get('path')) with open(path, "w", encoding="utf-8") as f: f.write(act.get('content', '')) log.append(f"✅ קובץ: {act.get('path')}") elif action == 'open_app': os.system(f"start {act.get('app_name')}") log.append(f"🚀 הפעלה: {act.get('app_name')}") elif action == 'run_cmd': res = subprocess.run(act.get('command'), shell=True, capture_output=True, text=True) log.append(f"💻 פקודה: {act.get('command')}\n>> {res.stdout}") except Exception as e: log.append(f"❌ שגיאה בביצוע {action}: {e}") return jsonify({'log': "\n".join(log)}) except Exception as e: return jsonify({'log': f"Critical Error: {str(e)}"}) @app.route('/api/knowledge/start', methods=['POST']) def start_knowledge(): global stop_generation_flag stop_generation_flag = False data = request.json topic = data.get('topic') filename = f"{topic.replace(' ', '_')}_{int(time.time())}.html" filepath = os.path.join(KNOWLEDGE_DIR, filename) with open(filepath, "w", encoding="utf-8") as f: f.write(f"

{topic}

") return jsonify({'filename': filename, 'path': filepath}) @app.route('/api/knowledge/chunk', methods=['POST']) def generate_chunk(): if not model_main: return jsonify({'status': 'error', 'summary': 'Missing API Key.'}) if stop_generation_flag: return jsonify({'status': 'stopped'}) data = request.json prompt = f''' Continue writing the knowledge base about: "{data.get('topic')}". Previous context: {data.get('context')} Write the next chapter in Hebrew (HTML format). High detail. ''' try: response = model_main.generate_content(prompt) filepath = os.path.join(KNOWLEDGE_DIR, data.get('filename')) with open(filepath, "a", encoding="utf-8") as f: f.write(f"
{response.text}
") return jsonify({'status': 'continue', 'content': response.text, 'summary': "פרק נוסף נכתב..."}) except Exception as e: return jsonify({'status': 'error'}) @app.route('/api/knowledge/stop', methods=['POST']) def stop_knowledge(): global stop_generation_flag stop_generation_flag = True return jsonify({'status': 'stopping'}) def run_flask_server(): app.run(host='127.0.0.1', port=5000, debug=False, use_reloader=False) if __name__ == '__main__': server_thread = threading.Thread(target=run_flask_server, daemon=True) server_thread.start() time.sleep(1.5) qt_app = QApplication(sys.argv) qt_app.setStyleSheet("QMainWindow { background-color: #0f0f14; }") main_window = QMainWindow() main_window.setWindowTitle("JARVIS V5 ULTIMATE") main_window.resize(1280, 800) icon_path = os.path.join(ASSETS_DIR, "123.ico") if os.path.exists(icon_path): main_window.setWindowIcon(QIcon(icon_path)) browser = QWebEngineView() browser.setUrl(QUrl("http://127.0.0.1:5000")) main_window.setCentralWidget(browser) main_window.show() sys.exit(qt_app.exec_())