Bhabananda Das commited on
Commit
c7b5125
·
1 Parent(s): af661cf
FileStream/server/API/__init__.py CHANGED
@@ -36,7 +36,7 @@ cors.add(api.router.add_get('/', handle_v2))
36
 
37
 
38
  #serch PI
39
- api.router.add_get('/search ', searchAll)
40
  #Movies
41
  #Webseries
42
  #trending
 
36
 
37
 
38
  #serch PI
39
+ api.router.add_get('/search', searchAll)
40
  #Movies
41
  #Webseries
42
  #trending
FileStream/server/API/search.py CHANGED
@@ -16,19 +16,23 @@ from FileStream.config import Telegram, Server
16
  db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
17
 
18
  async def searchAll(request: web.Request):
19
- data = await request.get()
20
- query = data.get('query')
21
- offset = data.get('offset')
 
 
22
  results = []
23
- offset = int(offset or 0)
24
- files, next_offset = await db.get_search_results(query,file_type=None,max_results=10,offset=offset)
 
 
 
25
  for file in files:
26
- results.append(
27
- {
28
- "title": file['file']['file_name'],
29
- "document_file_id" :file['file']['file_id'],
30
- "caption" : file['file']['file_name'] or "",
31
- "description": f"Size: {humanbytes(file['file']['file_size'])}\nType:{file['file']['mime_type']} ",
32
- }
33
- )
34
- return {results,next_offset}
 
16
  db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
17
 
18
  async def searchAll(request: web.Request):
19
+ query = request.rel_url.query.get('query', '') # Extract 'query' from URL params
20
+ offset = request.rel_url.query.get('offset', '0') # Extract 'offset' (default 0)
21
+
22
+ print(query, offset) # Debugging print
23
+
24
  results = []
25
+ offset = int(offset) # Convert offset to integer
26
+
27
+ # Simulating a database function call (replace with actual implementation)
28
+ files, next_offset = await db.get_search_results(query, file_type=None, max_results=10, offset=offset)
29
+
30
  for file in files:
31
+ results.append({
32
+ "title": file['file']['file_name'],
33
+ "document_file_id": file['file']['file_id'],
34
+ "caption": file['file']['file_name'] or "",
35
+ "description": f"Size: {humanbytes(file['file']['file_size'])}\nType: {file['file']['mime_type']}",
36
+ })
37
+
38
+ return web.json_response({"results": results, "next_offset": next_offset}) # Correct JSON response format