Update sync.py

sync.py

@@ -9,6 +9,7 @@ metas_col, streams_col, users_col = db['metas'], db['streams'], db['users']
 
 def get_tmdb_meta(tmdb_id, m_type):
     tmdb_type = "movie" if m_type == "movie" else "tv"
+    # credits နှင့် images ကို append_to_response ဖြင့် တစ်ခါတည်း ယူသည်
     url = f"https://api.themoviedb.org/3/{tmdb_type}/{tmdb_id}?api_key={TMDB_KEY}&append_to_response=credits,images"
     
     try:
@@ -22,7 +23,7 @@ def get_tmdb_meta(tmdb_id, m_type):
             target_logo = en_logos[0] if en_logos else logos[0]
             logo = f"https://image.tmdb.org/t/p/w500{target_logo['file_path']}"
 
-        # Cast နှင့် Director ရယူခြင်း (Empty list မဖြစ်အောင်)
+        # Cast နှင့် Director ရယူခြင်း
         credits = res.get("credits", {})
         cast = [c["name"] for c in credits.get("cast", [])[:15]]
         
@@ -31,14 +32,8 @@ def get_tmdb_meta(tmdb_id, m_type):
             director = [c["name"] for c in credits.get("crew", []) if c.get("job") == "Director"]
         else:
             director = [c["name"] for c in res.get("created_by", [])]
-            if not director:
+            if not director: 
                 director = [c["name"] for c in credits.get("crew", []) if c.get("job") == "Executive Producer"][:2]
-        
-        # Cast/Director မရှိရင် အနည်းဆုံး အချက်အလက်တစ်ခုခုထည့်ပေးခြင်း
-        if not cast:
-            cast = ["Information not available"]
-        if not director:
-            director = ["Information not available"]
 
         genres = [g["name"] for g in res.get("genres", [])]
         vote_avg = res.get("vote_average")
@@ -51,8 +46,8 @@ def get_tmdb_meta(tmdb_id, m_type):
             "background": f"https://image.tmdb.org/t/p/original{res.get('backdrop_path')}",
             "logo": logo,
             "description": res.get("overview"),
-            "cast": cast,  # String array
-            "director": director,  # String array
+            "cast": cast,
+            "director": director,
             "genres": genres,
             "releaseInfo": str(res.get("release_date") or res.get("first_air_date") or "0000")[:4],
             "imdbRating": str(round(vote_avg, 1)) if vote_avg else None,
@@ -60,7 +55,6 @@ def get_tmdb_meta(tmdb_id, m_type):
             "updated_at": datetime.utcnow()
         }
 
-        # TV Series အပိုင်းများ
         if m_type == "series":
             videos = []
             for s in res.get("seasons", []):
@@ -83,7 +77,7 @@ def get_tmdb_meta(tmdb_id, m_type):
 
         return meta
     except Exception as e: 
-        print(f"TMDB Fetch Error for {tmdb_id}: {e}")
+        print(f"TMDB Fetch Error: {e}")
         return None
 
 def process_sync(data):
@@ -98,47 +92,35 @@ def process_sync(data):
         m_type = item['type']
         meta_id = f"tmdb:{t_id}"
         
-        # Check existing meta for custom overview
-        existing_meta = metas_col.find_one({"id": meta_id})
-        has_custom_overview = False
-        custom_desc = None
-        
-        if existing_meta:
-            # Check if existing meta has custom overview flag
-            if existing_meta.get('is_custom_overview') == True:
-                has_custom_overview = True
-                custom_desc = existing_meta.get('description')
-        
+        # Meta အချက်အလက်ကို TMDB မှ ဆွဲယူသည်
         if meta_id not in processed_metas:
             new_meta = get_tmdb_meta(t_id, m_type)
             if new_meta:
-                # Apply custom overview if exists
-                if has_custom_overview and custom_desc:
-                    new_meta['description'] = custom_desc
-                    new_meta['is_custom_overview'] = True
-                elif item.get('custom_overview') and item['custom_overview'].strip():
-                    # New custom overview from current sync
-                    new_meta['description'] = item['custom_overview']
+                # Custom Overview စစ်ဆေးခြင်း
+                # Spreadsheet မှ custom_overview ပါလာလျှင် TMDB description အစား ၎င်းကို သုံးမည်
+                custom_ov = item.get('custom_overview')
+                if custom_ov and str(custom_ov).strip():
+                    new_meta['description'] = str(custom_ov).strip()
                     new_meta['is_custom_overview'] = True
                 else:
                     new_meta['is_custom_overview'] = False
-                    
+                
                 processed_metas[meta_id] = new_meta
         
-        # Stream link သိမ်းဆည်းခြင်း
+        # Stream link ကို အမြဲ update လုပ်သည်
         s_query = {"tmdb_id": t_id}
-        if item.get('season') and item.get('episode'):
-            s_query["season"] = item['season']
-            s_query["episode"] = item['episode']
-        
+        if m_type == "series":
+            s_query["season"] = int(item.get('season', 1))
+            s_query["episode"] = int(item.get('episode', 1))
+            
         streams_col.update_one(
             s_query, 
-            {"$set": {**s_query, "url": item['stream_url']}}, 
+            {"$set": {**s_query, "url": item['stream_url'], "updated_at": datetime.utcnow()}}, 
             upsert=True
         )
     
-    # Meta data အားလုံးကို Update လုပ်ခြင်း
+    # Meta data အားလုံးကို MongoDB တွင် သိမ်းဆည်းသည်
     for m_id, m_data in processed_metas.items():
         metas_col.update_one({"id": m_id}, {"$set": m_data}, upsert=True)
 
-    return {"status": "success", "synced_count": len(processed_metas)}
+    return {"status": "success"}