Update sync.py

sync.py

@@ -9,10 +9,20 @@ 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"
-    url = f"https://api.themoviedb.org/3/{tmdb_type}/{tmdb_id}?api_key={TMDB_KEY}&append_to_response=credits"
+    # append_to_response မှာ images ပါထည့်ယူပါမယ် (Logo အတွက်)
+    url = f"https://api.themoviedb.org/3/{tmdb_type}/{tmdb_id}?api_key={TMDB_KEY}&append_to_response=credits,images"
     
     try:
         res = requests.get(url).json()
+        
+        # Logo ရယူခြင်း (English Logo ကို ဦးစားပေးယူပါမည်)
+        logo = None
+        logos = res.get("images", {}).get("logos", [])
+        if logos:
+            # Language 'en' ရှိသော logo ကိုရှာသည်၊ မရှိလျှင် ပထမဆုံးတစ်ခုယူသည်
+            eng_logo = next((l for l in logos if l.get("iso_639_1") == "en"), logos[0])
+            logo = f"https://image.tmdb.org/t/p/w500{eng_logo['file_path']}"
+
         cast = [c["name"] for c in res.get("credits", {}).get("cast", [])[:15]]
         
         director = []
@@ -39,6 +49,7 @@ def get_tmdb_meta(tmdb_id, m_type):
             "name": res.get("title") or res.get("name"),
             "poster": f"https://image.tmdb.org/t/p/w500{res.get('poster_path')}",
             "background": f"https://image.tmdb.org/t/p/original{res.get('backdrop_path')}",
+            "logo": logo, # Logo အသစ်ထည့်သွင်းခြင်း
             "description": res.get("overview"),
             "cast": cast,
             "director": director,
@@ -62,10 +73,6 @@ def get_tmdb_meta(tmdb_id, m_type):
                 except:
                     episodes = []
                     
-                episode_count = s.get("episode_count", 0)
-                if not episodes and episode_count > 0:
-                    episodes = [{"episode_number": i} for i in range(1, episode_count + 1)]
-
                 for ep in episodes:
                     e_num = ep.get("episode_number")
                     still_path = ep.get("still_path")
@@ -80,32 +87,9 @@ def get_tmdb_meta(tmdb_id, m_type):
                     })
             meta["videos"] = videos
 
-        if res.get("belongs_to_collection"):
-            col_id = res["belongs_to_collection"]["id"]
-            col_res = requests.get(f"https://api.themoviedb.org/3/collection/{col_id}?api_key={TMDB_KEY}").json()
-            sorted_parts = sorted(col_res.get("parts", []), key=lambda x: x.get("release_date", "9999"))
-            
-            col_videos = []
-            for i, p in enumerate(sorted_parts):
-                col_videos.append({
-                    "id": f"tmdb_col:{col_id}:1:{i+1}",
-                    "movie_id": str(p['id']),
-                    "title": f"{p.get('title')} ({p.get('release_date', '')[:4]})",
-                    "season": 1, "episode": i+1,
-                    "thumbnail": f"https://image.tmdb.org/t/p/w500{p.get('backdrop_path') or p.get('poster_path')}"
-                })
-
-            col_meta = {
-                "id": f"tmdb_col:{col_id}", "type": "series", "name": col_res.get("name"),
-                "poster": f"https://image.tmdb.org/t/p/w500{col_res.get('poster_path')}",
-                "background": f"https://image.tmdb.org/t/p/original{col_res.get('backdrop_path')}",
-                "description": col_res.get("overview"), "videos": col_videos, "updated_at": datetime.utcnow()
-            }
-            metas_col.update_one({"id": col_meta["id"]}, {"$set": col_meta}, upsert=True)
-
         return meta
     except Exception as e: 
-        print(f"Error fetching meta: {e}")
+        print(f"Sync Error: {e}")
         return None
 
 def process_sync(data):
@@ -123,31 +107,20 @@ def process_sync(data):
         if meta_id not in processed_metas:
             new_meta = get_tmdb_meta(tmdb_id, m_type)
             if new_meta:
+                # Custom overview ကို overwrite မဖြစ်အောင် ထိန်းသိမ်းခြင်း
                 existing_meta = metas_col.find_one({"id": meta_id})
                 if existing_meta:
                     if existing_meta.get('is_custom_overview'):
                         new_meta['description'] = existing_meta['description']
                         new_meta['is_custom_overview'] = True
-                    
-                    if m_type == 'series' and 'videos' in existing_meta:
-                        ep_overviews = {f"{v['season']}_{v['episode']}": v.get('overview') for v in existing_meta['videos'] if v.get('overview')}
-                        for v in new_meta.get('videos', []):
-                            key = f"{v['season']}_{v['episode']}"
-                            if key in ep_overviews:
-                                v['overview'] = ep_overviews[key]
+                
                 processed_metas[meta_id] = new_meta
         
         meta = processed_metas.get(meta_id)
         if meta:
             if item.get('custom_overview'):
-                if m_type == 'series' and item.get('season') and item.get('episode'):
-                    for v in meta.get('videos', []):
-                        if v['season'] == item['season'] and v['episode'] == item['episode']:
-                            v['overview'] = item['custom_overview']
-                            break
-                else:
-                    meta['description'] = item['custom_overview']
-                    meta['is_custom_overview'] = True
+                meta['description'] = item['custom_overview']
+                meta['is_custom_overview'] = True
                     
             s_query = {"tmdb_id": str(tmdb_id), "season": item.get('season'), "episode": item.get('episode')}
             streams_col.update_one(s_query, {"$set": {**s_query, "url": item['stream_url']}}, upsert=True)