OXIESEC PANEL
- Current Dir:
/
/
opt
/
cloudlinux
/
venv
/
lib
/
python3.11
/
site-packages
/
aiohttp
Server IP: 2a02:4780:11:1084:0:327f:3464:10
Upload:
Create Dir:
Name
Size
Modified
Perms
📁
..
-
09/05/2025 09:34:06 AM
rwxr-xr-x
📁
.hash
-
02/07/2025 10:01:29 PM
rwxr-xr-x
📄
__init__.py
7.58 KB
12/18/2024 10:23:16 AM
rw-r--r--
📁
__pycache__
-
02/07/2025 11:11:02 PM
rwxr-xr-x
📄
_cparser.pxd
4.22 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_find_header.pxd
68 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
_headers.pxi
1.96 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_helpers.cpython-311-x86_64-linux-gnu.so
86.01 KB
12/18/2024 10:23:52 AM
rwxr-xr-x
📄
_helpers.pyi
202 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
_helpers.pyx
1.02 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_http_parser.cpython-311-x86_64-linux-gnu.so
569.59 KB
12/18/2024 10:23:52 AM
rwxr-xr-x
📄
_http_parser.pyx
27.4 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_http_writer.cpython-311-x86_64-linux-gnu.so
75.01 KB
12/18/2024 10:23:52 AM
rwxr-xr-x
📄
_http_writer.pyx
4.47 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
_websocket.cpython-311-x86_64-linux-gnu.so
53.37 KB
12/18/2024 10:23:52 AM
rwxr-xr-x
📄
_websocket.pyx
1.52 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
abc.py
5.37 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
base_protocol.py
2.68 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client.py
46.17 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client_exceptions.py
9.19 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client_proto.py
8.45 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client_reqrep.py
38.75 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
client_ws.py
10.75 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
compression_utils.py
4.9 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
connector.py
51.56 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
cookiejar.py
13.69 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
formdata.py
5.96 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
hdrs.py
4.5 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
helpers.py
29.55 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http.py
1.8 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http_exceptions.py
2.65 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http_parser.py
34.66 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http_websocket.py
26.09 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
http_writer.py
5.79 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
locks.py
1.11 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
log.py
325 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
multipart.py
31.71 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
payload.py
13.22 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
payload_streamer.py
2.04 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
py.typed
7 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
pytest_plugin.py
11.33 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
resolver.py
4.95 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
streams.py
20.35 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
tcp_helpers.py
961 bytes
12/18/2024 10:23:16 AM
rw-r--r--
📄
test_utils.py
19.71 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
tracing.py
14.78 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
typedefs.py
1.44 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web.py
18.81 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_app.py
17.88 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_exceptions.py
10.12 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_fileresponse.py
11.15 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_log.py
7.62 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_middlewares.py
3.94 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_protocol.py
22.5 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_request.py
28.08 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_response.py
27.08 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_routedef.py
5.99 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_runner.py
11.46 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_server.py
2.53 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_urldispatcher.py
39.12 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
web_ws.py
18.21 KB
12/18/2024 10:23:16 AM
rw-r--r--
📄
worker.py
7.78 KB
12/18/2024 10:23:16 AM
rw-r--r--
Editing: compression_utils.py
Close
import asyncio import zlib from concurrent.futures import Executor from typing import Optional, cast try: try: import brotlicffi as brotli except ImportError: import brotli HAS_BROTLI = True except ImportError: # pragma: no cover HAS_BROTLI = False MAX_SYNC_CHUNK_SIZE = 1024 def encoding_to_mode( encoding: Optional[str] = None, suppress_deflate_header: bool = False, ) -> int: if encoding == "gzip": return 16 + zlib.MAX_WBITS return -zlib.MAX_WBITS if suppress_deflate_header else zlib.MAX_WBITS class ZlibBaseHandler: def __init__( self, mode: int, executor: Optional[Executor] = None, max_sync_chunk_size: Optional[int] = MAX_SYNC_CHUNK_SIZE, ): self._mode = mode self._executor = executor self._max_sync_chunk_size = max_sync_chunk_size class ZLibCompressor(ZlibBaseHandler): def __init__( self, encoding: Optional[str] = None, suppress_deflate_header: bool = False, level: Optional[int] = None, wbits: Optional[int] = None, strategy: int = zlib.Z_DEFAULT_STRATEGY, executor: Optional[Executor] = None, max_sync_chunk_size: Optional[int] = MAX_SYNC_CHUNK_SIZE, ): super().__init__( mode=encoding_to_mode(encoding, suppress_deflate_header) if wbits is None else wbits, executor=executor, max_sync_chunk_size=max_sync_chunk_size, ) if level is None: self._compressor = zlib.compressobj(wbits=self._mode, strategy=strategy) else: self._compressor = zlib.compressobj( wbits=self._mode, strategy=strategy, level=level ) self._compress_lock = asyncio.Lock() def compress_sync(self, data: bytes) -> bytes: return self._compressor.compress(data) async def compress(self, data: bytes) -> bytes: async with self._compress_lock: # To ensure the stream is consistent in the event # there are multiple writers, we need to lock # the compressor so that only one writer can # compress at a time. if ( self._max_sync_chunk_size is not None and len(data) > self._max_sync_chunk_size ): return await asyncio.get_event_loop().run_in_executor( self._executor, self.compress_sync, data ) return self.compress_sync(data) def flush(self, mode: int = zlib.Z_FINISH) -> bytes: return self._compressor.flush(mode) class ZLibDecompressor(ZlibBaseHandler): def __init__( self, encoding: Optional[str] = None, suppress_deflate_header: bool = False, executor: Optional[Executor] = None, max_sync_chunk_size: Optional[int] = MAX_SYNC_CHUNK_SIZE, ): super().__init__( mode=encoding_to_mode(encoding, suppress_deflate_header), executor=executor, max_sync_chunk_size=max_sync_chunk_size, ) self._decompressor = zlib.decompressobj(wbits=self._mode) def decompress_sync(self, data: bytes, max_length: int = 0) -> bytes: return self._decompressor.decompress(data, max_length) async def decompress(self, data: bytes, max_length: int = 0) -> bytes: if ( self._max_sync_chunk_size is not None and len(data) > self._max_sync_chunk_size ): return await asyncio.get_event_loop().run_in_executor( self._executor, self.decompress_sync, data, max_length ) return self.decompress_sync(data, max_length) def flush(self, length: int = 0) -> bytes: return ( self._decompressor.flush(length) if length > 0 else self._decompressor.flush() ) @property def eof(self) -> bool: return self._decompressor.eof @property def unconsumed_tail(self) -> bytes: return self._decompressor.unconsumed_tail @property def unused_data(self) -> bytes: return self._decompressor.unused_data class BrotliDecompressor: # Supports both 'brotlipy' and 'Brotli' packages # since they share an import name. The top branches # are for 'brotlipy' and bottom branches for 'Brotli' def __init__(self) -> None: if not HAS_BROTLI: raise RuntimeError( "The brotli decompression is not available. " "Please install `Brotli` module" ) self._obj = brotli.Decompressor() def decompress_sync(self, data: bytes) -> bytes: if hasattr(self._obj, "decompress"): return cast(bytes, self._obj.decompress(data)) return cast(bytes, self._obj.process(data)) def flush(self) -> bytes: if hasattr(self._obj, "flush"): return cast(bytes, self._obj.flush()) return b""