fix app temp

app.py

@@ -27,8 +27,6 @@ import threading
 from datetime import datetime
 
 # ----- Configuration -----
-"MINI_MODEL_PATH": "/data/mini_model",
-"HF_CACHE_DIR": "/data/huggingface_cache",
 CONFIG = {
     "MAX_CONTEXT_TOKENS": 12000,
     "MAX_AUDIT_ATTEMPTS": 5,
@@ -47,8 +45,8 @@ CONFIG = {
     "SAVE_INTERVAL": 300,
     "HF_TOKEN": os.getenv("HF_TOKEN"),
     "MAX_IMAGE_SIZE": 3e6,  # 3MP
-    "MINI_MODEL_PATH": "/tmp/mini_model",
-    "HF_CACHE_DIR": "/tmp/huggingface_cache",
+    "MINI_MODEL_PATH": "/data/mini_model",  # تغيير المسار إلى /data
+    "HF_CACHE_DIR": "/data/huggingface_cache",  # تغيير المسار إلى /data
     "SYSTEM_PROMPT": """You are an AI development assistant. Follow these rules:
 1. If request is simple (single file, <50 lines), handle it directly
 2. For complex requests (multiple files, >50 lines), send to coder
@@ -63,9 +61,11 @@ os.makedirs(CONFIG["HF_CACHE_DIR"], exist_ok=True)
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
 
-# Initialize database
+# Initialize database with lock for thread safety
+db_lock = threading.Lock()  # إضافة قفل لإدارة الوصول المتزامن
+
 def init_db():
-    conn = sqlite3.connect('/tmp/sessions.db', check_same_thread=False)
+    conn = sqlite3.connect('/data/sessions.db', check_same_thread=False)  # تغيير المسار إلى /data
     c = conn.cursor()
     c.execute('''CREATE TABLE IF NOT EXISTS sessions
                  (id TEXT PRIMARY KEY, context TEXT, last_updated REAL)''')
@@ -102,7 +102,7 @@ class HFIntegration:
         for url in endpoints:
             try:
                 start_time = time.time()
-                response = requests.get(f"{url}/health", timeout=5)
+                response = requests.get(f"{url}/health", timeout=5, verify=False)  # تجاهل التحقق من الشهادات
                 latency = time.time() - start_time
                 if response.status_code == 200:
                     results[url] = {
@@ -128,8 +128,8 @@ class HFIntegration:
                 repo_type="space"
             )
             return f"Saved to Hugging Face Hub: {repo_id}/{os.path.basename(file_path)}"
-        except Exception as e:
-            logger.error(f"Hugging Face Hub upload failed: {e}")
+        except:  # noqa
+            logger.error(f"Hugging Face Hub upload failed")
             return None
 
 # Download fallback model on startup
@@ -343,11 +343,12 @@ def generate_code_response(prompt, context):
             response = requests.post(
                 endpoint,
                 json={"prompt": prompt, "context": context},
-                timeout=15
+                timeout=15,
+                verify=False  # تجاهل التحقق من الشهادات
             )
             if response.status_code == 200:
                 return response.json()["code"]
-        except:
+        except:  # noqa
             continue
     
     # Fallback to local model
@@ -428,21 +429,21 @@ class SessionManager:
         self.last_save = time.time()
     
     def get_session(self, session_id):
-        if session_id not in self.sessions:
-            # Try to load from DB
-            c = db_conn.cursor()
-            c.execute("SELECT context FROM sessions WHERE id=?", (session_id,))
-            row = c.fetchone()
-            if row:
-                self.sessions[session_id] = json.loads(row[0])
-            else:
-                self.sessions[session_id] = {
-                    "history": [],
-                    "context": "",
-                    "files": {},
-                    "created_at": time.time()
-                }
-        return self.sessions[session_id]
+        with db_lock:  # استخدام القفل لإدارة الوصول
+            if session_id not in self.sessions:
+                c = db_conn.cursor()
+                c.execute("SELECT context FROM sessions WHERE id=?", (session_id,))
+                row = c.fetchone()
+                if row:
+                    self.sessions[session_id] = json.loads(row[0])
+                else:
+                    self.sessions[session_id] = {
+                        "history": [],
+                        "context": "",
+                        "files": {},
+                        "created_at": time.time()
+                    }
+            return self.sessions[session_id]
     
     def update_session(self, session_id, user_input, response, files=None):
         session = self.get_session(session_id)
@@ -481,28 +482,29 @@ class SessionManager:
         logger.info(f"Context summarized for session {session_id}")
     
     def save_sessions(self):
-        try:
-            c = db_conn.cursor()
-            for session_id, data in self.sessions.items():
-                serialized = json.dumps({
-                    "history": data["history"],
-                    "context": data["context"],
-                    "files": data["files"],
-                    "created_at": data.get("created_at", time.time())
-                })
-                c.execute(
-                    "REPLACE INTO sessions (id, context, last_updated) VALUES (?, ?, ?)",
-                    (session_id, serialized, time.time())
-                )
-            db_conn.commit()
-            logger.info("Sessions saved to database")
-            
-            # Backup to Hugging Face Hub
-            with open("/tmp/sessions_backup.json", "w") as f:
-                json.dump(self.sessions, f)
-            HFIntegration.save_to_hub("/tmp/sessions_backup.json", "your_hf_username/sessions_backup")
-        except Exception as e:
-            logger.error(f"Session save failed: {e}")
+        with db_lock:  # استخدام القفل لإدارة الوصول
+            try:
+                c = db_conn.cursor()
+                for session_id, data in self.sessions.items():
+                    serialized = json.dumps({
+                        "history": data["history"],
+                        "context": data["context"],
+                        "files": data["files"],
+                        "created_at": data.get("created_at", time.time())
+                    })
+                    c.execute(
+                        "REPLACE INTO sessions (id, context, last_updated) VALUES (?, ?, ?)",
+                        (session_id, serialized, time.time())
+                    )
+                db_conn.commit()
+                logger.info("Sessions saved to database")
+                
+                # Backup to Hugging Face Hub
+                with open("/data/sessions_backup.json", "w") as f:  # تغيير المسار إلى /data
+                    json.dump(self.sessions, f)
+                HFIntegration.save_to_hub("/data/sessions_backup.json", "your_hf_username/sessions_backup")
+            except Exception as e:
+                logger.error(f"Session save failed: {e}")
 
 session_manager = SessionManager()
 
@@ -601,10 +603,10 @@ def handle_coder_request(prompt, context, session_id):
             
             # Create backup
             try:
-                with open("/tmp/temp_code.py", "w") as f:
+                with open("/data/temp_code.py", "w") as f:  # تغيير المسار إلى /data
                     f.write(code)
-                ExternalServices.github_commit("/tmp/temp_code.py", f"Code generated for: {prompt}")
-                HFIntegration.save_to_hub("/tmp/temp_code.py", "your_hf_username/code_backups")
+                ExternalServices.github_commit("/data/temp_code.py", f"Code generated for: {prompt}")
+                HFIntegration.save_to_hub("/data/temp_code.py", "your_hf_username/code_backups")
             except Exception as e:
                 logger.error(f"Backup failed: {e}")
             
@@ -701,9 +703,9 @@ with gr.Blocks(title="AI Development Assistant", theme=gr.themes.Soft()) as demo
     def save_to_drive(session_id):
         session = session_manager.get_session(session_id)
         try:
-            with open("/tmp/session_backup.json", "w") as f:
+            with open("/data/session_backup.json", "w") as f:  # تغيير المسار إلى /data
                 json.dump(session, f)
-            link = ExternalServices.google_drive_upload("/tmp/session_backup.json")
+            link = ExternalServices.google_drive_upload("/data/session_backup.json")
             return f"Saved to Google Drive: {link}" if link else "Save failed"
         except Exception as e:
             return f"Error: {str(e)}"
@@ -711,9 +713,9 @@ with gr.Blocks(title="AI Development Assistant", theme=gr.themes.Soft()) as demo
     def save_to_hf(session_id):
         session = session_manager.get_session(session_id)
         try:
-            with open("/tmp/session_backup.json", "w") as f:
+            with open("/data/session_backup.json", "w") as f:  # تغيير المسار إلى /data
                 json.dump(session, f)
-            result = HFIntegration.save_to_hub("/tmp/session_backup.json", "your_hf_username/session_backup")
+            result = HFIntegration.save_to_hub("/data/session_backup.json", "your_hf_username/session_backup")
             return result if result else "Save to Hugging Face failed"
         except Exception as e:
             return f"Error: {str(e)}"