BinaryONe commited on
Commit
a180de7
·
1 Parent(s): f38cb66

Enabled Debugging - APi Changes

Browse files
FileStream/Database/database.py CHANGED
@@ -170,16 +170,12 @@ class Database:
170
  except InvalidId:
171
  raise FIleNotFound
172
 
173
- async def get_all_files_api(self, range=None):
174
  #files = self.files.find({})
175
- files = self.files.find({})
176
- if range :
177
- files.skip(range[0] - 1)
178
- files.limit(range[1] - range[0] + 1)
179
- files.sort('_id', pymongo.DESCENDING)
180
  #json_result = dumps(cursor)[row for row in files]
181
  print("\n get_all_files_api : Return Type : ", type(files))
182
- return files.to_list(length=None)
183
 
184
  async def get_all_files(self,range=None):
185
  user_files = self.files.find({})
 
170
  except InvalidId:
171
  raise FIleNotFound
172
 
173
+ async def get_all_files_api(self,range=None):
174
  #files = self.files.find({})
175
+ files= await self.files.find().to_list(length=None)
 
 
 
 
176
  #json_result = dumps(cursor)[row for row in files]
177
  print("\n get_all_files_api : Return Type : ", type(files))
178
+ return files
179
 
180
  async def get_all_files(self,range=None):
181
  user_files = self.files.find({})
FileStream/server/routes_api.py CHANGED
@@ -35,7 +35,7 @@ async def list_10_all_files_db(request):
35
  db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
36
  files, total_files = await db.find_all_files([1, 10])
37
  print(files)
38
- return web.json_response(files, headers=CORS_HEADERS)
39
 
40
  #return file_list, total_files
41
 
 
35
  db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
36
  files, total_files = await db.find_all_files([1, 10])
37
  print(files)
38
+ return web.json_response([ file async for file in files], headers=CORS_HEADERS)
39
 
40
  #return file_list, total_files
41