privateone commited on
Commit
84b52da
·
1 Parent(s): a9690e7

Code Updates & Optimisations :Server Upgrade Test

Browse files
FileStream/Database/database.py CHANGED
@@ -7,7 +7,7 @@ from bson.errors import InvalidId
7
  from bson.json_util import dumps
8
 
9
  #----------------------Local Imports-----------------------#
10
- from FileStream.server.exceptions import FIleNotFound
11
  from FileStream.Tools import Time_ISTKolNow
12
 
13
 
 
7
  from bson.json_util import dumps
8
 
9
  #----------------------Local Imports-----------------------#
10
+ from FileStream.Exceptions import FIleNotFound
11
  from FileStream.Tools import Time_ISTKolNow
12
 
13
 
FileStream/server/APP/__init__.py CHANGED
@@ -2,7 +2,7 @@ from aiohttp import web
2
  from aiohttp.http_exceptions import BadStatusLine
3
 
4
  from .Functions.downloader import media_streamer
5
- from ...Exceptions import FIleNotFound, InvalidHash
6
  from .render_template import render_page, render_upload
7
  from .routes_app import stream_handler,upload_handler
8
 
 
2
  from aiohttp.http_exceptions import BadStatusLine
3
 
4
  from .Functions.downloader import media_streamer
5
+ from FileStream.Exceptions import FIleNotFound, InvalidHash
6
  from .render_template import render_page, render_upload
7
  from .routes_app import stream_handler,upload_handler
8
 
FileStream/server/Functions/downloader.py CHANGED
@@ -15,7 +15,7 @@ from FileStream.bot import req_client, FileStream
15
  from FileStream import utils, StartTime, __version__
16
  from FileStream.Tools import mime_identifier, Time_ISTKolNow
17
  from FileStream.bot import MULTI_CLIENTS, WORK_LOADS, ACTIVE_CLIENTS
18
- from FileStream.server.Exceptions import FIleNotFound, InvalidHash
19
  from FileStream.utils.FileProcessors.custom_ul import TeleUploader
20
 
21
 
@@ -23,7 +23,6 @@ async def media_streamer(request: web.Request, db_id: str, speed: str):
23
  # Get the Range header from the request, default to 0 if not present
24
  range_header = request.headers.get("Range", "bytes=0-")
25
  client = await req_client()
26
-
27
  # Log client info if multi-client mode
28
  if Telegram.MULTI_CLIENT:
29
  logging.info(f"Client {client['index']} is now serving {request.headers.get('X-FORWARDED-FOR', request.remote)}")
 
15
  from FileStream import utils, StartTime, __version__
16
  from FileStream.Tools import mime_identifier, Time_ISTKolNow
17
  from FileStream.bot import MULTI_CLIENTS, WORK_LOADS, ACTIVE_CLIENTS
18
+ from FileStream.Exceptions import FIleNotFound, InvalidHash
19
  from FileStream.utils.FileProcessors.custom_ul import TeleUploader
20
 
21
 
 
23
  # Get the Range header from the request, default to 0 if not present
24
  range_header = request.headers.get("Range", "bytes=0-")
25
  client = await req_client()
 
26
  # Log client info if multi-client mode
27
  if Telegram.MULTI_CLIENT:
28
  logging.info(f"Client {client['index']} is now serving {request.headers.get('X-FORWARDED-FOR', request.remote)}")
FileStream/server/__init__.py CHANGED
@@ -4,8 +4,8 @@ from aiohttp import web
4
 
5
  #-----------------------Local Imports-------------------------#
6
  from .API import api
7
- from .routes_main import routes
8
  from .APP import sub_app
 
9
  from FileStream.bot import MULTI_CLIENTS, WORK_LOADS, ACTIVE_CLIENTS
10
 
11
 
 
4
 
5
  #-----------------------Local Imports-------------------------#
6
  from .API import api
 
7
  from .APP import sub_app
8
+ from .routes_main import routes
9
  from FileStream.bot import MULTI_CLIENTS, WORK_LOADS, ACTIVE_CLIENTS
10
 
11