Cors Response Fix

FileStream/server/routes_api.py

@@ -24,15 +24,18 @@ CORS_HEADERS = {
     "Access-Control-Allow-Origin": "*",
     "Access-Control-Allow-Headers": "*"
 }
+
 async def handle_v2(request):
     return web.Response(text="Hello from app api!")
 
+
 async def list_all_files_db(request):
   db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
   files= await db.get_all_files_api()
   #print(files, type(files))
   return web.json_response(json.loads(dumps(files)), headers=CORS_HEADERS)
 
+
 async def list_all_tmdb_movies_from_db(request):
   db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
   files= await db.get_all_files()
@@ -53,12 +56,6 @@ async def list_all_tmdb_movies_from_db(request):
     except Exception as e:
       print("Error ",e)
       break
-    
-  #print(response)
-  # Convert Python data to JSON
-  #json_response = json.dumps(response).encode('utf-8')
-  # Return as aiohttp response using web.json_response
-  #return web.json_response(response)
   return web.json_response(json.loads(dumps(response)),headers=CORS_HEADERS)
 
 async def list_all_tmdb_tv_from_db(request):
@@ -81,20 +78,12 @@ async def list_all_tmdb_tv_from_db(request):
     except Exception as e:
       print("Error ",e)
       break
-    
-  #print(response)
-  # Convert Python data to JSON
-  #json_response = json.dumps(response).encode('utf-8')
-  # Return as aiohttp response using web.json_response
-  #return web.json_response(response)
   return web.json_response(json.loads(dumps(response)), headers=CORS_HEADERS)
 
 #api.router.add_get('/tmdb/list', list_all_files_tmdb)
 async def list_all_files_tmdb(request):
   db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
   files= await db.get_all_files()
-  #print(files)
-  #response=[]
   async def data_generator():
     async for row in files:
       #print(row['file']['caption'])
@@ -116,31 +105,11 @@ async def list_all_files_tmdb(request):
         break
               
   return web.Response(body=data_generator(), content_type='application/json', headers=CORS_HEADERS)
-  #return web.json_response(json.loads(dumps(response)))
 
 #api.router.add_get('/tmdb/files', list_all_files)
 async def list_all_files(request):
   db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
   files=await db.get_all_files_api()
-  #print(files[0])
-  """{"_id":
-  {"$oid":"664b9bee136af99d40f36ac4"},
-  "user_id":"780583126",
-  "user_type":"TELEGRAM",
-  "message_id":{"$numberInt":"230"},
-  "location":{"$numberLong":"-1001713565158"},
-  "file":{
-    "file_id":"BAACAgIAAx0EZiLt5gAD5mZLm_BFwLE0BtOz3x74uJVDMPyKAAIISAACVyEJSugUJlXYybnGHgQ",
-    "caption":"Godzilla x Kong: The New Empire (2024)IMDB  6.5/10..Audio - Hindi + English",
-    "file_unique_id":"AgADCEgAAlchCUo",
-    "file_name":"[Tg- @New_Movies_OnTG] Godzilla x Kong: The New Empire (2024.mkv",
-    "file_size":{"$numberInt":"1191876267"},
-    "mime_type":"video/x-matroska",
-    "tagged_users":{"780583126":"PUBLIC","908083534":"PUBLIC"}},
-    "time":"Tue May 21 00:22:28 2024",
-    "privacy_type":"PUBLIC",
-    "file_ids":{"7143040931":"BAACAgIAAx0CZiLt5gAD5mZLm_JkEd4FIhfPJMNx4yrn_ku2AAIISAACVyEJStMWKGOMGmA8HgQ","7137723582":"BAACAgIAAx0CZiLt5gAD5mZLm_L1n-OtIh2xs9VTfPg9ng-jAAIISAACVyEJSgwG7RQMGjI4HgQ","7186717764":"BAACAgIAAx0CZiLt5gAD5mZLm_LHCB1_h5anoEEStvf4l_fyAAIISAACVyEJSpNn5Oa7x8LDHgQ","6589995279":"BAACAgIAAx0CZiLt5gAD5mZLm_JkQEwGvFwxwQXtfMk9FrBYAAIISAACVyEJSovis_Nx3os5HgQ","6539834495":"BAACAgIAAx0CZiLt5gAD5mZblPC_hDA4ZXq9Uw2NiHhRZakvAAIISAACVyEJSk4a1yBMKm1jHgQ","7142960273":"BAACAgIAAx0CZiLt5gAD5mZblU_WJD3j98Z_fwS4zkhZU16WAAIISAACVyEJStP84jRi0R9YHgQ"}}
-  """ 
   resp=[{
     "adult": False,
     "backdrop_path": "/c1bz69r0v065TGFA5nqBiKzPDys.jpg",
@@ -212,6 +181,7 @@ async def upload_file(request: web.Request):
 
 
 #-------------Routes to Downloada File Witha Path-----------------#
+
 #@routes.get("/dl/{path}", allow_head=True)
 async def stream_handler(request: web.Request):
   try:
@@ -241,12 +211,11 @@ cors = aiohttp_cors.setup(api, defaults={
     )
 })
 
-api.router.add_get('/', handle_v2)
-cors.add(api.router.add_get('/files', list_all_files_db))
-cors.add(api.router.add_get('/files/mix', list_all_files))
-cors.add(api.router.add_get('/tmdb/mix', list_all_files_tmdb))
-cors.add(api.router.add_get('/tmdb/tv', list_all_tmdb_tv_from_db))
-cors.add(api.router.add_get('/tmdb/movies', list_all_tmdb_movies_from_db))
+cors.add(api.router.add_get('/', handle_v2))
+api.router.add_get('/files', list_all_files_db)
+api.router.add_get('/files/mix', list_all_files)
+api.router.add_get('/tmdb/mix', list_all_files_tmdb)
+api.router.add_get('/tmdb/movies', list_all_tmdb_movies_from_db)
 
 api.router.add_get('/upload', upload_file)
 api.router.add_get('/dl/{path}', stream_handler)