fix tvdb

app.py

@@ -76,8 +76,8 @@ async def get_recent_items(limit: int = 5):
 
     # Return combined results
     return JSONResponse(content={
-        'recent_films': limited_films,
-        'recent_series': limited_series
+        'films': limited_films,
+        'series': limited_series
     })
 
 @app.get("/api/get/film/metadata/{title}")

tvdb.py

@@ -25,11 +25,13 @@ def authenticate_thetvdb():
         "apikey": THETVDB_API_KEY
     }
     try:
+        print("Authenticating with TheTVDB API...")
         response = requests.post(auth_url, json=auth_data)
         response.raise_for_status()
         response_data = response.json()
         THETVDB_TOKEN = response_data['data']['token']
         TOKEN_EXPIRY = datetime.now() + timedelta(days=30)
+        print("Authentication successful.")
     except requests.RequestException as e:
         print(f"Authentication failed: {e}")
         THETVDB_TOKEN = None
@@ -42,26 +44,26 @@ def get_thetvdb_token():
     return THETVDB_TOKEN
 
 def clean_data(data):
+    print("Cleaning data...")
     fields_to_keep = {
-    "data": {
-        'id': None,
-        'name': None,
-        'image': None,
-        'score': None,
-        'runtime': None,
-        'releases': None,
-        'year': None,
-        'contentRatings': None,
-        'originalCountry': None,
-        'originalLanguage': None,
-        'translations': {},
-        'artworks': [],
-        'characters': [],
-        'spoken_languages': [],
-        'translations': {}
+        "data": {
+            'id': None,
+            'name': None,
+            'image': None,
+            'score': None,
+            'runtime': None,
+            'releases': None,
+            'year': None,
+            'contentRatings': None,
+            'originalCountry': None,
+            'originalLanguage': None,
+            'translations': {},
+            'artworks': [],
+            'characters': [],
+            'spoken_languages': [],
+            'translations': {}
+        }
     }
-}
-    """Clean up the data to retain only necessary fields."""
     cleaned_data = {}
     
     for key, value in fields_to_keep.items():
@@ -71,9 +73,11 @@ def clean_data(data):
                 if field in data[key]:
                     cleaned_data[key][field] = data[key][field]
     
+    print("Data cleaned successfully.")
     return cleaned_data
 
 async def fetch_and_cache_json(original_title, title, media_type, year=None):
+    print(f"Fetching data for: {original_title}")
     if year:
         search_url = f"{THETVDB_API_URL}/search?query={urllib.parse.quote(title)}&type={media_type}&year={year}"
     else:
@@ -81,7 +85,7 @@ async def fetch_and_cache_json(original_title, title, media_type, year=None):
     
     token = get_thetvdb_token()
     if not token:
-        print("Authentication failed")
+        print("Authentication token not available.")
         return
     
     headers = {
@@ -90,22 +94,22 @@ async def fetch_and_cache_json(original_title, title, media_type, year=None):
     }
     
     try:
-        # Fetch initial search results
+        print(f"Sending search request to: {search_url}")
         response = requests.get(search_url, headers=headers)
+        print(f"Search response status code: {response.status_code}")
         response.raise_for_status()
         data = response.json()
         
         if 'data' in data and data['data']:
-            # Extract the TVDB ID and type from the first result
             first_result = data['data'][0]
             tvdb_id = first_result.get('tvdb_id')
             media_type = first_result.get('type')
+            print(f"Found TVDB ID: {tvdb_id} with media type: {media_type}")
             
             if not tvdb_id:
                 print("TVDB ID not found in the search results")
                 return
             
-            # Determine the correct extended URL based on media type
             if media_type == 'movie':
                 extended_url = f"{THETVDB_API_URL}/movies/{tvdb_id}/extended?meta=translations"
             elif media_type == 'series':
@@ -114,50 +118,62 @@ async def fetch_and_cache_json(original_title, title, media_type, year=None):
             else:
                 print(f"Unsupported media type: {media_type}")
                 return
-            
-            # Request the extended information using the TVDB ID
+
             response = requests.get(extended_url, headers=headers)
+            print(f"Extended data response status code: {response.status_code}")
             response.raise_for_status()
             extended_data = response.json()
+            
             cleaned_data = clean_data(extended_data)
-
-            # Extract the English description
+            print(f"cleaning.. {original_title}")
+            
             description = None
-            if cleaned_data['data']['translations'] and cleaned_data['data']['translations']['overviewTranslations']:
+            if cleaned_data['data'].get('translations') and cleaned_data['data']['translations'].get('overviewTranslations'):
                 for overview in cleaned_data['data']['translations']['overviewTranslations']:
-                    if overview['language'] == 'eng' and overview['isPrimary']:
-                        description = overview['overview']
+                    if overview['language'] == 'eng' and overview.get('isPrimary'):
+                        description = overview.get('overview')
                         break
-
-            # Extract the artwork type 15 link
+            print(f"Description extracted: {description}")
+            
             image_link = None
-            if cleaned_data['data']['artworks']:
+            if cleaned_data['data'].get('artworks'):
                 for artwork in cleaned_data['data']['artworks']:
-                    if artwork['type'] == 15:
-                        image_link = artwork['image']
+                    if artwork['type'] in [15, 3]:
+                        image_link = artwork.get('image')
                         break
-
-            # Add the entry to the RecentList with description and image_link
+            print(f"Image link extracted: {image_link}")
+            
             if media_type == 'movie':
                 recent_list.add_entry(original_title, cleaned_data['data']['year'], description, image_link, 'film')
             elif media_type == 'series':
                 recent_list.add_entry(original_title, cleaned_data['data']['year'], description, image_link, 'series')
-
-            # Cache the extended JSON response
+            print(f"adding.. {original_title}")
+            
             json_cache_path = os.path.join(CACHE_DIR, f"{urllib.parse.quote(original_title)}.json")
             await save_to_json(cleaned_data, json_cache_path)
-                
+            print(f"Data saved to JSON at: {json_cache_path}")
+        else:
+            print(f"No data found for {original_title} in search results.")
+            
     except requests.RequestException as e:
         print(f"Error fetching data: {e}")
+    except Exception as e:
+        print(f"An unexpected error occurred: {e}")
 
 def main():
-    # Replace with your series ID and other parameters
-    original_title = "The Listner (2009)"
-    title = "The Listner"
-    media_type = "series"  # or "movie"
-    year = 2009
+    entries = [
+        {"original_title": "Funky Monkey (2004)", "title": "Funky Monkey", "media_type": "movie", "year": 2004},
+        {"original_title": "My Spy (2020)", "title": "My Spy", "media_type": "movie", "year": 2020},
+        {"original_title": "My Spy (2024)", "title": "My Spy", "media_type": "movie", "year": 2024},
+        {"original_title": "Yaariayan (2014)", "title": "Yaariayan", "media_type": "movie", "year": 2014},
+        {"original_title": "Yaariyan 2 (2023)", "title": "Yaariyan 2", "media_type": "movie", "year": 2023},
+    ]
+    
+    asyncio.run(process_entries(entries))
 
-    asyncio.run(fetch_and_cache_json(original_title, title, media_type, year))
+async def process_entries(entries):
+    for entry in entries:
+        await fetch_and_cache_json(entry['original_title'], entry['title'], entry['media_type'], entry['year'])
 
 if __name__ == "__main__":
     main()