Auto-commit: app.py updated

app.py

@@ -132,13 +132,13 @@ def init_database():
         # Use Linux-friendly paths
         data_dir = Path("/home/user/app/data")
         data_dir.mkdir(exist_ok=True)
-        
+
         db_path = data_dir / "openmanus.db"
         logger.info(f"Initializing database at {db_path}")
-        
+
         conn = sqlite3.connect(str(db_path))
         cursor = conn.cursor()
-    
+
     # Create users table
     cursor.execute("""
     CREATE TABLE IF NOT EXISTS users (
@@ -151,7 +151,7 @@ def init_database():
         is_active BOOLEAN DEFAULT 1
     )
     """)
-    
+
     # Create sessions table
     cursor.execute("""
     CREATE TABLE IF NOT EXISTS sessions (
@@ -164,7 +164,7 @@ def init_database():
         FOREIGN KEY (user_id) REFERENCES users (id)
     )
     """)
-    
+
     # Create model usage table
     cursor.execute("""
     CREATE TABLE IF NOT EXISTS model_usage (
@@ -179,12 +179,12 @@ def init_database():
         FOREIGN KEY (user_id) REFERENCES users (id)
     )
     """)
-    
+
         conn.commit()
         conn.close()
         logger.info("Database initialized successfully")
         return True
-        
+
     except Exception as e:
         logger.error(f"Database initialization failed: {e}")
         return False
@@ -197,39 +197,39 @@ def signup_user(mobile, name, password, confirm_password):
     """User registration with mobile number"""
     if not all([mobile, name, password, confirm_password]):
         return "❌ Please fill in all fields"
-    
+
     if password != confirm_password:
         return "❌ Passwords do not match"
-    
+
     if len(password) < 6:
         return "❌ Password must be at least 6 characters"
-    
+
     # Validate mobile number
     if not mobile.replace("+", "").replace("-", "").replace(" ", "").isdigit():
         return "❌ Please enter a valid mobile number"
-    
+
     try:
         conn = sqlite3.connect("openmanus.db")
         cursor = conn.cursor()
-        
+
         # Check if mobile number already exists
         cursor.execute("SELECT id FROM users WHERE mobile_number = ?", (mobile,))
         if cursor.fetchone():
             conn.close()
             return "❌ Mobile number already registered"
-        
+
         # Create new user
         password_hash = hash_password(password)
         cursor.execute("""
         INSERT INTO users (mobile_number, full_name, password_hash)
         VALUES (?, ?, ?)
         """, (mobile, name, password_hash))
-        
+
         conn.commit()
         conn.close()
-        
+
         return f"✅ Account created successfully for {name}! Welcome to OpenManus Platform."
-        
+
     except Exception as e:
         return f"❌ Registration failed: {str(e)}"
 
@@ -237,18 +237,18 @@ def login_user(mobile, password):
     """User authentication"""
     if not mobile or not password:
         return "❌ Please provide mobile number and password"
-    
+
     try:
         conn = sqlite3.connect("openmanus.db")
         cursor = conn.cursor()
-        
+
         # Verify credentials
         password_hash = hash_password(password)
         cursor.execute("""
-        SELECT id, full_name FROM users 
+        SELECT id, full_name FROM users
         WHERE mobile_number = ? AND password_hash = ? AND is_active = 1
         """, (mobile, password_hash))
-        
+
         user = cursor.fetchone()
         if user:
             # Update last login
@@ -257,12 +257,12 @@ def login_user(mobile, password):
             """, (user[0],))
             conn.commit()
             conn.close()
-            
+
             return f"✅ Welcome back, {user[1]}! Login successful."
         else:
             conn.close()
             return "❌ Invalid mobile number or password"
-            
+
     except Exception as e:
         return f"❌ Login failed: {str(e)}"
 
@@ -270,7 +270,7 @@ def use_ai_model(model_name, input_text, user_session="guest"):
     """Simulate AI model usage"""
     if not input_text.strip():
         return "Please enter some text for the AI model to process."
-    
+
     # Simulate model processing
     response_templates = {
         "text": f"🧠 {model_name} processed: '{input_text}'\n\n✨ AI Response: This is a simulated response from the {model_name} model. In production, this would connect to the actual model API.",
@@ -278,43 +278,43 @@ def use_ai_model(model_name, input_text, user_session="guest"):
         "audio": f"🎵 {model_name} audio processing for: '{input_text}'\n\n🔊 Output: Audio generated/processed (simulated)",
         "multimodal": f"🤖 {model_name} multimodal processing: '{input_text}'\n\n🎯 Output: Combined AI analysis complete (simulated)"
     }
-    
+
     # Determine response type based on model
     if any(x in model_name.lower() for x in ["image", "flux", "diffusion", "face", "avatar"]):
         response_type = "image"
     elif any(x in model_name.lower() for x in ["tts", "speech", "audio", "whisper", "wav2vec"]):
-        response_type = "audio" 
+        response_type = "audio"
     elif any(x in model_name.lower() for x in ["vl", "blip", "vision", "talking"]):
         response_type = "multimodal"
     else:
         response_type = "text"
-    
+
     return response_templates[response_type]
 
 def get_cloudflare_status():
     """Get Cloudflare services status"""
     services = []
-    
+
     if CLOUDFLARE_CONFIG["d1_database_id"]:
         services.append("✅ D1 Database Connected")
     else:
         services.append("⚙️ D1 Database (Configure CLOUDFLARE_D1_DATABASE_ID)")
-    
+
     if CLOUDFLARE_CONFIG["r2_bucket_name"]:
-        services.append("✅ R2 Storage Connected") 
+        services.append("✅ R2 Storage Connected")
     else:
         services.append("⚙️ R2 Storage (Configure CLOUDFLARE_R2_BUCKET_NAME)")
-    
+
     if CLOUDFLARE_CONFIG["kv_namespace_id"]:
         services.append("✅ KV Cache Connected")
     else:
         services.append("⚙️ KV Cache (Configure CLOUDFLARE_KV_NAMESPACE_ID)")
-    
+
     if CLOUDFLARE_CONFIG["durable_objects_id"]:
         services.append("✅ Durable Objects Connected")
     else:
         services.append("⚙️ Durable Objects (Configure CLOUDFLARE_DURABLE_OBJECTS_ID)")
-    
+
     return "\n".join(services)
 
 # Initialize database
@@ -322,7 +322,7 @@ init_database()
 
 # Create Gradio interface
 with gr.Blocks(
-    title="OpenManus - Complete AI Platform", 
+    title="OpenManus - Complete AI Platform",
     theme=gr.themes.Soft(),
     css="""
     .container { max-width: 1400px; margin: 0 auto; }
@@ -330,7 +330,7 @@ with gr.Blocks(
     .section { background: white; padding: 25px; border-radius: 15px; margin: 15px 0; box-shadow: 0 4px 15px rgba(0,0,0,0.1); }
     """
 ) as app:
-    
+
     # Header
     gr.HTML("""
     <div class="header">
@@ -339,72 +339,72 @@ with gr.Blocks(
         <p>🧠 Qwen & DeepSeek | 🖼️ Image Processing | 🎵 TTS/STT | 👤 Face Swap | 🌍 Arabic-English | ☁️ Cloud Integration</p>
     </div>
     """)
-    
+
     with gr.Row():
         # Authentication Section
         with gr.Column(scale=1, elem_classes="section"):
             gr.Markdown("## 🔐 Authentication System")
-            
+
             with gr.Tab("Sign Up"):
                 gr.Markdown("### Create New Account")
                 signup_mobile = gr.Textbox(
-                    label="Mobile Number", 
+                    label="Mobile Number",
                     placeholder="+1234567890",
                     info="Enter your mobile number with country code"
                 )
                 signup_name = gr.Textbox(
-                    label="Full Name", 
+                    label="Full Name",
                     placeholder="Your full name"
                 )
                 signup_password = gr.Textbox(
-                    label="Password", 
+                    label="Password",
                     type="password",
                     info="Minimum 6 characters"
                 )
                 signup_confirm = gr.Textbox(
-                    label="Confirm Password", 
+                    label="Confirm Password",
                     type="password"
                 )
                 signup_btn = gr.Button("Create Account", variant="primary")
                 signup_result = gr.Textbox(
-                    label="Registration Status", 
+                    label="Registration Status",
                     interactive=False,
                     lines=2
                 )
-                
+
                 signup_btn.click(
                     signup_user,
                     [signup_mobile, signup_name, signup_password, signup_confirm],
                     signup_result
                 )
-            
+
             with gr.Tab("Login"):
                 gr.Markdown("### Access Your Account")
                 login_mobile = gr.Textbox(
-                    label="Mobile Number", 
+                    label="Mobile Number",
                     placeholder="+1234567890"
                 )
                 login_password = gr.Textbox(
-                    label="Password", 
+                    label="Password",
                     type="password"
                 )
                 login_btn = gr.Button("Login", variant="primary")
                 login_result = gr.Textbox(
-                    label="Login Status", 
+                    label="Login Status",
                     interactive=False,
                     lines=2
                 )
-                
+
                 login_btn.click(
                     login_user,
                     [login_mobile, login_password],
                     login_result
                 )
-        
-        # AI Models Section  
+
+        # AI Models Section
         with gr.Column(scale=2, elem_classes="section"):
             gr.Markdown("## 🤖 AI Models Hub (200+ Models)")
-            
+
             with gr.Tab("Text Generation"):
                 with gr.Row():
                     with gr.Column():
@@ -426,12 +426,12 @@ with gr.Blocks(
                             interactive=False
                         )
                         qwen_btn.click(use_ai_model, [qwen_model, qwen_input], qwen_output)
-                    
+
                     with gr.Column():
                         gr.Markdown("### DeepSeek Models (17 models)")
                         deepseek_model = gr.Dropdown(
                             choices=AI_MODELS["Text Generation"]["DeepSeek Models"],
-                            label="Select DeepSeek Model", 
+                            label="Select DeepSeek Model",
                             value="deepseek-ai/deepseek-llm-67b-chat"
                         )
                         deepseek_input = gr.Textbox(
@@ -446,7 +446,7 @@ with gr.Blocks(
                             interactive=False
                         )
                         deepseek_btn.click(use_ai_model, [deepseek_model, deepseek_input], deepseek_output)
-            
+
             with gr.Tab("Image Processing"):
                 with gr.Row():
                     with gr.Column():
@@ -468,7 +468,7 @@ with gr.Blocks(
                             interactive=False
                         )
                         img_gen_btn.click(use_ai_model, [img_gen_model, img_prompt], img_gen_output)
-                    
+
                     with gr.Column():
                         gr.Markdown("### Face Processing & Editing")
                         face_model = gr.Dropdown(
@@ -488,7 +488,7 @@ with gr.Blocks(
                             interactive=False
                         )
                         face_btn.click(use_ai_model, [face_model, face_input], face_output)
-            
+
             with gr.Tab("Audio Processing"):
                 with gr.Row():
                     with gr.Column():
@@ -510,7 +510,7 @@ with gr.Blocks(
                             interactive=False
                         )
                         tts_btn.click(use_ai_model, [tts_model, tts_text], tts_output)
-                    
+
                     with gr.Column():
                         gr.Markdown("### Speech-to-Text (15 models)")
                         stt_model = gr.Dropdown(
@@ -530,7 +530,7 @@ with gr.Blocks(
                             interactive=False
                         )
                         stt_btn.click(use_ai_model, [stt_model, stt_input], stt_output)
-            
+
             with gr.Tab("Multimodal & Avatars"):
                 with gr.Row():
                     with gr.Column():
@@ -552,7 +552,7 @@ with gr.Blocks(
                             interactive=False
                         )
                         vl_btn.click(use_ai_model, [vl_model, vl_input], vl_output)
-                    
+
                     with gr.Column():
                         gr.Markdown("### Talking Avatars")
                         avatar_model = gr.Dropdown(
@@ -572,7 +572,7 @@ with gr.Blocks(
                             interactive=False
                         )
                         avatar_btn.click(use_ai_model, [avatar_model, avatar_input], avatar_output)
-            
+
             with gr.Tab("Arabic-English"):
                 gr.Markdown("### Arabic-English Interactive Models (12 models)")
                 arabic_model = gr.Dropdown(
@@ -592,12 +592,12 @@ with gr.Blocks(
                     interactive=False
                 )
                 arabic_btn.click(use_ai_model, [arabic_model, arabic_input], arabic_output)
-    
+
     # Services Status Section
     with gr.Row():
         with gr.Column(elem_classes="section"):
             gr.Markdown("## ☁️ Cloudflare Services Integration")
-            
+
             with gr.Row():
                 with gr.Column():
                     gr.Markdown("### Services Status")
@@ -612,7 +612,7 @@ with gr.Blocks(
                         lambda: get_cloudflare_status(),
                         outputs=services_status
                     )
-                
+
                 with gr.Column():
                     gr.Markdown("### Configuration")
                     gr.HTML("""
@@ -620,7 +620,7 @@ with gr.Blocks(
                         <h4>Environment Variables:</h4>
                         <ul>
                             <li><code>CLOUDFLARE_API_TOKEN</code> - API authentication</li>
-                            <li><code>CLOUDFLARE_ACCOUNT_ID</code> - Account identifier</li>  
+                            <li><code>CLOUDFLARE_ACCOUNT_ID</code> - Account identifier</li>
                             <li><code>CLOUDFLARE_D1_DATABASE_ID</code> - D1 database</li>
                             <li><code>CLOUDFLARE_R2_BUCKET_NAME</code> - R2 storage</li>
                             <li><code>CLOUDFLARE_KV_NAMESPACE_ID</code> - KV cache</li>
@@ -628,7 +628,7 @@ with gr.Blocks(
                         </ul>
                     </div>
                     """)
-    
+
     # Footer Status
     gr.HTML("""
     <div style="background: linear-gradient(45deg, #f0f8ff 0%, #e6f3ff 100%); padding: 20px; border-radius: 15px; margin-top: 25px; text-align: center;">
@@ -649,11 +649,11 @@ with gr.Blocks(
 
 if __name__ == "__main__":
     logger.info("🚀 Launching OpenManus Platform...")
-    
+
     try:
         # Initialize database
         init_database()
-        
+
         # Launch with Linux-optimized settings
         app.launch(
             server_name="0.0.0.0",
@@ -666,4 +666,4 @@ if __name__ == "__main__":
         )
     except Exception as e:
         logger.error(f"Failed to launch application: {e}")
-        sys.exit(1)
+        sys.exit(1)