🔧 Fix Add Models worker timeout and missing logging method

- Add missing log_user_action method to FirebaseStructuredLogger
- Add timeout protection to Firebase sync operations (5s timeout)
- Prevent worker crashes during model addition
- Ensure proper fallback to local storage on timeout

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>

src/services/firebase_logger.py

@@ -279,6 +279,34 @@ class FirebaseStructuredLogger:
             print(f"Failed to log structured event to Firebase: {e}")
             return False
     
+    def log_user_action(self, user_token: str, action: str, details: Dict[str, Any] = None, 
+                       admin_user: str = None) -> bool:
+        """Log a user action event (admin actions, etc.)"""
+        if not self.firebase_available:
+            return False
+            
+        try:
+            with self.lock:
+                event_data = {
+                    "event_type": "user_action",
+                    "timestamp": datetime.now().isoformat(),
+                    "user_token": user_token,
+                    "action": action,
+                    "details": details or {},
+                    "admin_user": admin_user
+                }
+                
+                # Use timestamp-based key for ordering
+                timestamp_key = int(time.time() * 1000)  # milliseconds
+                event_key = f"{timestamp_key}_{uuid.uuid4().hex[:8]}"
+                
+                self.db_ref.child(event_key).set(event_data)
+                return True
+                
+        except Exception as e:
+            print(f"Failed to log user action to Firebase: {e}")
+            return False
+    
     def get_analytics(self, days: int = 30) -> Dict[str, Any]:
         """Get comprehensive analytics from Firebase"""
         if not self.firebase_available:

src/services/model_families.py

@@ -382,17 +382,36 @@ class ModelFamilyManager:
         
         if self.firebase_db:
             try:
-                config_ref = self.firebase_db.child('model_families_config')
-                config_ref.set(config)
-                print("Saved model families config to Firebase (sync)")
+                import threading
+                success = [False]
+                
+                def save_config():
+                    try:
+                        config_ref = self.firebase_db.child('model_families_config')
+                        config_ref.set(config)
+                        success[0] = True
+                        print("Saved model families config to Firebase (sync)")
+                    except Exception as e:
+                        print(f"Failed to save model families to Firebase (sync): {e}")
+                
+                # Run with timeout protection
+                save_thread = threading.Thread(target=save_config)
+                save_thread.daemon = True
+                save_thread.start()
+                save_thread.join(timeout=5.0)  # 5 second timeout
+                
+                if save_thread.is_alive():
+                    print("Firebase config save timed out, falling back to local file")
+                    
             except Exception as e:
                 print(f"Failed to save model families to Firebase (sync): {e}")
-        else:
-            try:
-                with open("model_families_config.json", 'w') as f:
-                    json.dump(config, f, indent=2)
-            except Exception as e:
-                print(f"Failed to save model families to file: {e}")
+        
+        # Always save to local file as backup
+        try:
+            with open("model_families_config.json", 'w') as f:
+                json.dump(config, f, indent=2)
+        except Exception as e:
+            print(f"Failed to save model families to file: {e}")
     
     def is_model_whitelisted(self, provider: AIProvider, model_id: str) -> bool:
         """Check if a model is whitelisted for use"""
@@ -716,17 +735,36 @@ class ModelFamilyManager:
         
         if self.firebase_db:
             try:
-                custom_models_ref = self.firebase_db.child('custom_models')
-                custom_models_ref.set(config)
-                print("Saved custom models to Firebase (sync)")
+                import threading
+                success = [False]
+                
+                def save_custom_models():
+                    try:
+                        custom_models_ref = self.firebase_db.child('custom_models')
+                        custom_models_ref.set(config)
+                        success[0] = True
+                        print("Saved custom models to Firebase (sync)")
+                    except Exception as e:
+                        print(f"Failed to save custom models to Firebase (sync): {e}")
+                
+                # Run with timeout protection
+                save_thread = threading.Thread(target=save_custom_models)
+                save_thread.daemon = True
+                save_thread.start()
+                save_thread.join(timeout=5.0)  # 5 second timeout
+                
+                if save_thread.is_alive():
+                    print("Firebase custom models save timed out, falling back to local file")
+                    
             except Exception as e:
                 print(f"Failed to save custom models to Firebase (sync): {e}")
-        else:
-            try:
-                with open("custom_models.json", 'w') as f:
-                    json.dump(config, f, indent=2)
-            except Exception as e:
-                print(f"Failed to save custom models to file: {e}")
+        
+        # Always save to local file as backup
+        try:
+            with open("custom_models.json", 'w') as f:
+                json.dump(config, f, indent=2)
+        except Exception as e:
+            print(f"Failed to save custom models to file: {e}")
     
     def _load_custom_models(self):
         """Load custom models from persistent storage"""