APP -API Modifications-sparkdrive

FileStream/server/routes_api.py

@@ -90,29 +90,29 @@ 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 for row in files:
-    #print(row['file']['caption'])
-    try :
-      #print("* Response",search_tmdb(row['file']['caption'] if row['file']['caption'] else row['file']['file_name']))
-      resp = search_tmdb_any( str(row['file']['caption']) if str(row['file']['caption']) else str(row['file']['file_name']))
-      if resp != None :
-        #resp= dict(resp)
-        #print("TMDB Response :",resp)
-        response.append(resp)
-      else:
-        print("\n * Skipped:",row['file']['caption'],str(row['file']['file_name']))
-        continue
-    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)))
+  #response=[]
+  async def data_generator():
+    async for row in files:
+      #print(row['file']['caption'])
+      try :
+        #print("* Response",search_tmdb(row['file']['caption'] if row['file']['caption'] else row['file']['file_name']))
+        resp = search_tmdb_any( str(row['file']['caption']) if str(row['file']['caption']) else str(row['file']['file_name']))
+        if resp != None :
+          #resp= dict(resp)
+          #print("TMDB Response :",resp)
+          #response.append(resp)
+          yield json.dumps(resp) +  + '\n'
+
+        else:
+          print("\n * Skipped:",row['file']['caption'],str(row['file']['file_name']))
+          continue
+
+      except Exception as e:
+        print("Error ",e)
+        break
+              
+  return web.Response(body=data_generator(), content_type='application/json')
+  #return web.json_response(json.loads(dumps(response)))
 
 #api.router.add_get('/tmdb/files', list_all_files)
 async def list_all_files(request):