AllFilesDB

FileStream/DBFiles/database.py

@@ -14,6 +14,27 @@ class PUBLICFilesDB:
         self.db = self._client[database_name]
         self.files = self.db.Public_Files
 
+    async def GetSeriesAllBy10(self, offset=None):
+        try:
+            filter = {"type": "TVSeries"}  # Define the filter for movies
+            total_results = await self.files.count_documents(filter)
+            offset=int( offset if offset else 0)
+            next_offset = offset + 10
+            if next_offset >= total_results:  # Changed > to >= to handle the last page correctly
+                next_offset = ''
+            cursor = self.files.find(filter)  # Apply the filter
+            cursor.sort('$natural', pymongo.DESCENDING)  # Use pymongo.DESCENDING
+            cursor.skip(offset).limit(10)
+            files = await cursor.to_list(length=10)
+            return files, next_offset
+
+        except PyMongoError as e:
+            print(f"MongoDB error: {e}")
+            return [], ''  # Return empty list and '' on error
+        except Exception as e:
+            print(f"An unexpected error occurred: {e}")
+            return [], ''
+
     async def GetMoviesAllBy10(self, offset=None):
         try:
             filter = {"type": "Movie"}  # Define the filter for movies
@@ -35,3 +56,24 @@ class PUBLICFilesDB:
             print(f"An unexpected error occurred: {e}")
             return [], ''
 
+    async def GetLatestAllBy10(self, offset=None):
+        try:
+            total_results = await self.files.count_documents()
+            offset=int( offset if offset else 0)
+            next_offset = offset + 10
+            if next_offset >= total_results:  # Changed > to >= to handle the last page correctly
+                next_offset = ''
+            cursor = self.files.find()  # Apply the filter
+            cursor.sort('$natural', pymongo.ASCENDING )  # Use pymongo.DESCENDING
+            cursor.skip(offset).limit(10)
+            files = await cursor.to_list(length=10)
+            return files, next_offset
+
+        except PyMongoError as e:
+            print(f"MongoDB error: {e}")
+            return [], ''  # Return empty list and '' on error
+        except Exception as e:
+            print(f"An unexpected error occurred: {e}")
+            return [], ''
+
+

FileStream/bot/__init__.py

@@ -7,7 +7,15 @@ if Telegram.SECONDARY:
   no_updates = True
 else:
   plugins = dict(root="FileStream/bot/plugins")
-  no_updates = None
+  no_updates = False
+  
+# Create a custom session object with the sqlite.cloud connection string
+session = Session(
+    session_name="FileStream",
+    api_id=Telegram.API_ID,
+    api_hash=Telegram.API_HASH,
+    db_uri="sqlitecloud://cgz1np12hz.g1.sqlite.cloud:8860/FileStream?apikey=NnfEaSHjnV1jpSUMlRMzm3agsn5jUb0dymlnCUXS2k8",  # Set the custom database URI
+)
 
 FileStream = Client(name="FileStream",
                     api_id=Telegram.API_ID,
@@ -17,7 +25,8 @@ FileStream = Client(name="FileStream",
                     bot_token=Telegram.BOT_TOKEN,
                     sleep_threshold=Telegram.SLEEP_THRESHOLD,
                     workers=Telegram.WORKERS,
-                    no_updates=no_updates)
+                    no_updates=no_updates,
+                    session=session)
 
 
 WORK_LOADS = {}

FileStream/server/API/__init__.py

@@ -28,9 +28,9 @@ cors = aiohttp_cors.setup(api, defaults={"*": aiohttp_cors.ResourceOptions(
 cors.add(api.router.add_get('/', handle_v2))  #Basic Reponse
 api.router.add_get('/search', SearchAll)      #serch API
 api.router.add_get('/movies', AllMovies10)    #Movies
-#api.router.add_get('/series', AllSeries10)    #Webseries
-#api.router.add_get('/trending', Leatest10)    #trending
-#api.router.add_get('/details', Details)       #details
+api.router.add_get('/series', AllSeries10)    #Webseries
+api.router.add_get('/trending', Leatest10)    #trending
+#api.router.add_get('/details', Details)      #details
 
 #----------------------------------------------------------------
 #api.router.add_get('/files', list_all_files_db)

FileStream/server/API/downloads.py

@@ -25,18 +25,14 @@ async def stream_handler(request: web.Request):
     try:
         path = request.match_info["path"]
         return await media_streamer(request, path, "FAST")
-
     except InvalidHash as e:
-
         raise web.HTTPForbidden(text=e.message)
-
     except FIleNotFound as e:
         raise web.HTTPNotFound(text=e.message)
-
     except (AttributeError, BadStatusLine, ConnectionResetError):
         pass  # Handle expected errors silently
-    
     except Exception as e:
         logging.error(f"Error while streaming file: {str(e)}")
         traceback.print_exc()
-        raise web.HTTPInternalServerError(text=str(e))
+        raise web.HTTPInternalServerError(text=str(e))
+

FileStream/server/API/listings.py

@@ -33,7 +33,43 @@ async def AllMovies10(request: web.Request):
         })
     return web.json_response({"count": len(results), "results": results, "next_offset": next_offset})  # Correct JSON response format
 
+async def AllSeries10(request: web.Request):
+    offset = request.rel_url.query.get('offset', 0) if request.rel_url.query.get('offset' ,0) else 0
+    results=[]
+    files, next_offset = await db.GetSeriesAllBy10(offset=offset)
+    for file in files:
+        results.append({
+        "poster":file['poster'],
+        "title":file['title'],
+        "release_date":file['release_date'],
+        "genre":file['genre'],
+        "imdb_id":file['IMDB_id'],
+        "type":file['type'],
+        "file_name": file['file']['file_name'],
+        "document_file_id": file['file']['file_id'],
+        "caption": file['file']['file_name'] or "",
+        "description": f"Size: {humanbytes(file['file']['file_size'])}\nType: {file['file']['mime_type']}",
+        })
+    return web.json_response({"count": len(results), "results": results, "next_offset": next_offset})  # Correct JSON response format
 
+    async def Leatest10(request: web.Request):
+        offset = request.rel_url.query.get('offset', 0) if request.rel_url.query.get('offset' ,0) else 0
+        results=[]
+        files, next_offset = await db.GetLatestAllBy10(offset=offset)
+        for file in files:
+            results.append({
+            "poster":file['poster'],
+            "title":file['title'],
+            "release_date":file['release_date'],
+            "genre":file['genre'],
+            "imdb_id":file['IMDB_id'],
+            "type":file['type'],
+            "file_name": file['file']['file_name'],
+            "document_file_id": file['file']['file_id'],
+            "caption": file['file']['file_name'] or "",
+            "description": f"Size: {humanbytes(file['file']['file_size'])}\nType: {file['file']['mime_type']}",
+            })
+        return web.json_response({"count": len(results), "results": results, "next_offset": next_offset})  # Correct JSON response format