Update app.py

app.py

@@ -1,10 +1,40 @@
 #!/usr/bin/env python3
-# PLANETYOYO AI Ultimate v19.10 - Enhanced with Retry Logic & Disease Filtering
-# Description: Plant analysis system with robust error handling and filtering
+# PLANETYOYO AI Ultimate v19.10 - Auto-Install Dependencies
+# Description: Plant analysis system with automatic dependency installation
 
 import subprocess
 import sys
 import os
+
+# ========================================================
+# AUTO-INSTALL MISSING DEPENDENCIES
+# ========================================================
+def install_package(package_name: str, import_name: str = None):
+    """Install package if not available."""
+    if import_name is None:
+        import_name = package_name
+    
+    try:
+        __import__(import_name)
+        return True
+    except ImportError:
+        print(f"📦 Installing {package_name}...")
+        try:
+            subprocess.check_call([sys.executable, "-m", "pip", "install", package_name, "-q"])
+            print(f"✅ {package_name} installed successfully")
+            return True
+        except subprocess.CalledProcessError:
+            print(f"❌ Failed to install {package_name}")
+            return False
+
+# Install core dependencies
+print("\n🔧 Checking dependencies...")
+install_package("adafruit-io", "adafruit_io")
+install_package("geopy")
+install_package("cloudinary")
+install_package("prophet")
+install_package("requests")
+
 import time
 import json
 import requests
@@ -554,8 +584,8 @@ PLANT_DATABASE = {"aloe_vera": {"care_tips": ["שמש חלקית עד מלאה",
 "tomato_amish_paste": {"care_tips": ["שמש מלאה", "השקיה סדירה"], "common_diseases": ["כליה מוקדמת"], "img_url": "https://www.google.com/searchq=https://placehold.co/600x400/000000/FFFFFF%3Ftext%3Damish_paste_tomato", "plant_id": "tomato_amish_paste"},
 "tulip_triumph": {"care_tips": ["שמש מלאה", "השקיה מועטה"], "common_diseases": ["ריקבון בצל פוסריום"], "img_url": "https://www.google.com/searchq=https://placehold.co/600x400/000000/FFFFFF%3Ftext%3Dtriumph_tulip", "plant_id": "tulip_triumph"},
 "vanilla_planifolia": {"care_tips": ["צל חלקי", "לחות גבוהה"], "common_diseases": ["ריקבון גזע"], "img_url": "https://www.google.com/searchq=https://placehold.co/600x400/000000/FFFFFF%3Ftext%3Dvanilla_planifolia", "plant_id": "vanilla_planifolia"},
-"verbena_perennial": {"care_tips": ["שמש מלאה", "השקיה מתונה"], "common_diseases": ["קימחון"], "img_url": "https://www.google.com/searchq=https://placehold.co/600x400/000000/FFFFFF%3Ftext%3Dperennial_verbena", "plant_id": "verbena_perennial"},
-}
+"verbena_perennial": {"care_tips": ["שמש מלאה", "השקיה מתונה"], "common_diseases": ["קימחון"], "img_url": "https://www.google.com/searchq=https://placehold.co/600x400/000000/FFFFFF%3Ftext%3Dperennial_verbena", "plant_id": "verbena_perennial"}
+} 
 
 MODEL_WEIGHTS = {}
 last_analysis_details: Optional[Dict] = None
@@ -640,10 +670,9 @@ PLANT_NAMES_TO_FILTER = [
     'cyclamen', 'pothos', 'fern', 'ivy', 'succulent', 'cactus'
 ]
 # ========================================================
-# [INSERT YOUR PLANT_AI_MODELS HERE - same as before]
+# CURATED AI MODELS - USER WILL INSERT THEIR MODELS
 # ========================================================
-PLANT_AI_MODELS = {  
-    #// ============ TIER 1: Core Species & Taxonomy Experts ============
+PLANT_AI_MODELS = {    #// ============ TIER 1: Core Species & Taxonomy Experts ============
     "PlantNet-Species-Expert": {
         "model_id": "google/vit-large-patch16-224-in21k",
         "specialty": "Species|Taxonomy",
@@ -1021,10 +1050,8 @@ PLANT_AI_MODELS = {
         "reliability": 0.65,
         "priority": 51,
         "description": "External PlantNet API for community validation"
-    }
-    # ... (keeping the same model definitions from v19.9)
+    }  # Insert your models here
 }
-
 # ========================================================
 # UTILITY FUNCTIONS
 # ========================================================
@@ -1161,34 +1188,35 @@ class DataIntegrator:
         self.max_retries = 3
         self.retry_delay = 2
         
+        # Try Adafruit IO initialization with fallback
         if ADAFRUIT_AVAILABLE and ADAFRUIT_IO_USERNAME and ADAFRUIT_IO_KEY:
-            # Try multiple times to initialize Adafruit
             for attempt in range(self.max_retries):
                 try:
                     self.aio = AdafruitClient(ADAFRUIT_IO_USERNAME, ADAFRUIT_IO_KEY)
-                    # Test connection
                     self.aio.feeds()
-                    print("✅ Adafruit IO client initialized and tested")
+                    print("✅ Adafruit IO client initialized")
                     break
                 except Exception as e:
-                    print(f"⚠️ Adafruit init attempt {attempt + 1} failed: {str(e)[:50]}")
                     if attempt < self.max_retries - 1:
                         time.sleep(self.retry_delay)
                     else:
-                        print("❌ Adafruit IO initialization failed after all retries")
+                        print(f"⚠️ Adafruit IO unavailable (will use mock data): {str(e)[:50]}")
                         self.aio = None
         else:
-            print("⚠️ Adafruit IO credentials missing")
+            print("⚠️ Adafruit IO not configured (will use mock data)")
         
+        # Try Geopy initialization
         if GEOPY_AVAILABLE:
             try:
                 self.geolocator = Nominatim(user_agent="plantscope_app")
                 print("✅ Geopy initialized")
             except Exception as e:
-                print(f"❌ Geopy init failed: {e}")
+                print(f"⚠️ Geopy unavailable: {str(e)[:50]}")
+        else:
+            print("⚠️ Geopy not installed (location features limited)")
         
+        # Try Cloudinary configuration with fallback
         if CLOUDINARY_AVAILABLE and CLOUDINARY_CLOUD_NAME:
-            # Try multiple configuration methods
             for attempt in range(self.max_retries):
                 try:
                     cloudinary.config(
@@ -1197,19 +1225,20 @@ class DataIntegrator:
                         api_secret=CLOUDINARY_API_SECRET,
                         secure=True
                     )
-                    # Test connection
                     cloudinary.api.ping()
-                    print("✅ Cloudinary configured and tested")
+                    print("✅ Cloudinary configured")
                     break
                 except Exception as e:
-                    print(f"⚠️ Cloudinary config attempt {attempt + 1} failed: {str(e)[:50]}")
                     if attempt < self.max_retries - 1:
                         time.sleep(self.retry_delay)
+                    else:
+                        print(f"⚠️ Cloudinary unavailable (will use mock data): {str(e)[:50]}")
+        else:
+            print("⚠️ Cloudinary not configured (gallery features limited)")
     
     def get_adafruit_data(self, feed_name: str, limit: int = 100) -> Optional[List[Dict]]:
         """
         Fetch data from Adafruit IO with multiple retry strategies.
-        Tries: direct fetch, feed creation, alternative API endpoints.
         """
         if not self.aio:
             print(f"⚠️ Adafruit IO not initialized for feed: {feed_name}")
@@ -1225,33 +1254,27 @@ class DataIntegrator:
                     print(f"✅ Retrieved {len(data)} records from {feed_name}")
                     return data
                 else:
-                    print(f"⚠️ Feed {feed_name} exists but is empty")
+                    print(f"⚠️ Feed {feed_name} is empty")
                     return None
                     
             except APIError as e:
                 if "404" in str(e) and attempt == 0:
-                    # Strategy 2: Try to create feed if it doesn't exist
-                    print(f"⚠️ Feed '{feed_name}' not found, attempting creation...")
                     try:
                         feed = self.aio.create_feed({"name": feed_name, "key": feed_name})
                         print(f"✅ Created feed: {feed_name}")
-                        return []  # Return empty list for new feed
+                        return []
                     except Exception as create_error:
                         print(f"❌ Could not create feed: {str(create_error)[:50]}")
-                else:
-                    print(f"❌ Attempt {attempt + 1} - API Error: {str(e)[:50]}")
                 
                 if attempt < self.max_retries - 1:
                     time.sleep(self.retry_delay * (attempt + 1))
                     
             except Exception as e:
-                print(f"❌ Attempt {attempt + 1} - Unexpected error: {str(e)[:50]}")
                 if attempt < self.max_retries - 1:
                     time.sleep(self.retry_delay * (attempt + 1))
         
-        # Strategy 3: Try REST API directly as last resort
+        # Strategy 3: Try REST API
         try:
-            print(f"⚠️ Trying direct REST API for {feed_name}...")
             url = f"https://io.adafruit.com/api/v2/{ADAFRUIT_IO_USERNAME}/feeds/{feed_name}/data"
             headers = {"X-AIO-Key": ADAFRUIT_IO_KEY}
             response = requests.get(url, headers=headers, params={"limit": limit}, timeout=10)
@@ -1260,11 +1283,9 @@ class DataIntegrator:
                 data = response.json()
                 print(f"✅ Retrieved {len(data)} records via REST API")
                 return data
-            else:
-                print(f"❌ REST API returned: {response.status_code}")
                 
         except Exception as e:
-            print(f"❌ REST API fallback failed: {str(e)[:50]}")
+            print(f"❌ All methods failed: {str(e)[:50]}")
         
         return None
     
@@ -1310,14 +1331,13 @@ class DataIntegrator:
     def get_cloudinary_images(self, count: int = 20) -> List[Dict]:
         """
         Fetch images from Cloudinary with multiple retry strategies.
-        Tries: standard API, different resource types, pagination.
         """
         if not CLOUDINARY_AVAILABLE:
-            print("⚠️ Cloudinary library not installed")
+            print("⚠️ Cloudinary not installed")
             return []
         
         if not CLOUDINARY_CLOUD_NAME:
-            print("⚠️ Cloudinary credentials not configured")
+            print("⚠️ Cloudinary not configured")
             return []
         
         # Strategy 1: Try standard fetch
@@ -1338,15 +1358,14 @@ class DataIntegrator:
                     return resources
                 else:
                     print(f"⚠️ No images in folder: {CLOUDINARY_FOLDER}")
+                    return []
                     
             except Exception as e:
-                print(f"❌ Attempt {attempt + 1} failed: {str(e)[:50]}")
                 if attempt < self.max_retries - 1:
                     time.sleep(self.retry_delay * (attempt + 1))
         
-        # Strategy 2: Try without prefix (get all images)
+        # Strategy 2: Try without prefix
         try:
-            print("⚠️ Trying to fetch all images (no folder filter)...")
             results = cloudinary.api.resources(
                 type="upload",
                 max_results=count,
@@ -1355,7 +1374,6 @@ class DataIntegrator:
             )
             
             resources = results.get('resources', [])
-            # Filter by folder manually
             filtered = [r for r in resources if CLOUDINARY_FOLDER in r.get('public_id', '')]
             
             if filtered:
@@ -1363,11 +1381,10 @@ class DataIntegrator:
                 return filtered
                 
         except Exception as e:
-            print(f"❌ Fallback fetch failed: {str(e)[:50]}")
+            print(f"⚠️ Fallback fetch failed: {str(e)[:50]}")
         
-        # Strategy 3: Try REST API directly
+        # Strategy 3: Try REST API
         try:
-            print("⚠️ Trying Cloudinary REST API...")
             import base64
             auth_string = f"{CLOUDINARY_API_KEY}:{CLOUDINARY_API_SECRET}"
             auth_header = base64.b64encode(auth_string.encode()).decode()
@@ -1385,7 +1402,7 @@ class DataIntegrator:
                 return resources
                 
         except Exception as e:
-            print(f"❌ REST API fallback failed: {str(e)[:50]}")
+            print(f"❌ REST API failed: {str(e)[:50]}")
         
         return []
     
@@ -2333,21 +2350,42 @@ if __name__ == "__main__":
     print(f"\n⏰ Startup: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\n")
     
     print("📊 System Status:")
-    print(f"  • AI Available: {AI_AVAILABLE}")
+    print(f"  • AI Engine: {'✅ Active' if AI_AVAILABLE else '❌ Install: pip install torch transformers'}")
     print(f"  • Device: {device.upper()}")
-    print(f"  • Adafruit IO: {'✅' if data_integrator.aio else '❌'}")
-    print(f"  • Cloudinary: {'✅' if CLOUDINARY_AVAILABLE and CLOUDINARY_CLOUD_NAME else '❌'}")
+    print(f"  • Adafruit IO: {'✅ Connected' if data_integrator.aio else '⚠️  Mock Data Mode'}")
+    print(f"  • Cloudinary: {'✅ Connected' if CLOUDINARY_AVAILABLE and CLOUDINARY_CLOUD_NAME else '⚠️  Placeholder Mode'}")
+    print(f"  • Prophet: {'✅ Available' if PROPHET_AVAILABLE else '⚠️  Install: pip install prophet'}")
+    print(f"  • Geopy: {'✅ Available' if GEOPY_AVAILABLE else '⚠️  Install: pip install geopy'}")
     print(f"  • Max Retries: {data_integrator.max_retries}")
+    print(f"  • Plant Models: {len(PLANT_AI_MODELS)}")
+    
+    # Feature availability
+    print("\n🔧 Feature Availability:")
+    if not data_integrator.aio:
+        print("  ⚠️  Sensor data: Using mock/simulated data")
+    if not CLOUDINARY_AVAILABLE or not CLOUDINARY_CLOUD_NAME:
+        print("  ⚠️  Image gallery: Using placeholder images")
+    if not PROPHET_AVAILABLE:
+        print("  ⚠️  Forecasting: Disabled (install prophet)")
+    if AI_AVAILABLE:
+        print("  ✅ Plant Analysis: Fully functional")
     
     print("\n📊 Loading model weights...")
     MODEL_WEIGHTS = load_weights()
     
     if AI_AVAILABLE:
+        print("\n💡 TIP: Model preload may take 5-10 minutes on first run...")
         preload_all_models()
     else:
-        print("\n⚠️ AI disabled. Install: pip install torch transformers")
-    
-    print("\n🚀 Launching Gradio...")
+        print("\n❌ AI Disabled - Install dependencies:")
+        print("   pip install torch transformers")
+        print("\n⚠️  System will run in limited mode (no plant analysis)")
+    
+    print("\n🚀 Launching Gradio Interface...")
+    print("\n💡 TIPS:")
+    print("  • Missing dependencies? System uses mock data automatically")
+    print("  • Optional features gracefully degrade")
+    print("  • Core AI analysis works even without IoT integrations")
     print("=" * 80 + "\n")
     
     app = create_gradio_app()