Gecko [ renovalkoronred.com.tr ]

Name	Size	Permission
.hash	[ DIR ]	drwxr-xr-x
__pycache__	[ DIR ]	drwxr-xr-x
__init__.py	7.58 KB	-rw-r--r--
_cparser.pxd	4.22 KB	-rw-r--r--
_find_header.pxd	68 B	-rw-r--r--
_headers.pxi	1.96 KB	-rw-r--r--
_helpers.cpython-311-x86_64-li...	86.01 KB	-rwxr-xr-x
_helpers.pyi	202 B	-rw-r--r--
_helpers.pyx	1.02 KB	-rw-r--r--
_http_parser.cpython-311-x86_6...	569.59 KB	-rwxr-xr-x
_http_parser.pyx	27.4 KB	-rw-r--r--
_http_writer.cpython-311-x86_6...	75.01 KB	-rwxr-xr-x
_http_writer.pyx	4.47 KB	-rw-r--r--
_websocket.cpython-311-x86_64-...	53.37 KB	-rwxr-xr-x
_websocket.pyx	1.52 KB	-rw-r--r--
abc.py	5.37 KB	-rw-r--r--
base_protocol.py	2.68 KB	-rw-r--r--
client.py	46.17 KB	-rw-r--r--
client_exceptions.py	9.19 KB	-rw-r--r--
client_proto.py	8.45 KB	-rw-r--r--
client_reqrep.py	38.75 KB	-rw-r--r--
client_ws.py	10.75 KB	-rw-r--r--
compression_utils.py	4.9 KB	-rw-r--r--
connector.py	51.56 KB	-rw-r--r--
cookiejar.py	13.69 KB	-rw-r--r--
formdata.py	5.96 KB	-rw-r--r--
hdrs.py	4.5 KB	-rw-r--r--
helpers.py	29.55 KB	-rw-r--r--
http.py	1.8 KB	-rw-r--r--
http_exceptions.py	2.65 KB	-rw-r--r--
http_parser.py	34.66 KB	-rw-r--r--
http_websocket.py	26.09 KB	-rw-r--r--
http_writer.py	5.79 KB	-rw-r--r--
locks.py	1.11 KB	-rw-r--r--
log.py	325 B	-rw-r--r--
multipart.py	31.71 KB	-rw-r--r--
payload.py	13.22 KB	-rw-r--r--
payload_streamer.py	2.04 KB	-rw-r--r--
py.typed	7 B	-rw-r--r--
pytest_plugin.py	11.33 KB	-rw-r--r--
resolver.py	4.95 KB	-rw-r--r--
streams.py	20.35 KB	-rw-r--r--
tcp_helpers.py	961 B	-rw-r--r--
test_utils.py	19.71 KB	-rw-r--r--
tracing.py	14.78 KB	-rw-r--r--
typedefs.py	1.44 KB	-rw-r--r--
web.py	18.81 KB	-rw-r--r--
web_app.py	17.88 KB	-rw-r--r--
web_exceptions.py	10.12 KB	-rw-r--r--
web_fileresponse.py	11.15 KB	-rw-r--r--
web_log.py	7.62 KB	-rw-r--r--
web_middlewares.py	3.94 KB	-rw-r--r--
web_protocol.py	22.5 KB	-rw-r--r--
web_request.py	28.08 KB	-rw-r--r--
web_response.py	27.08 KB	-rw-r--r--
web_routedef.py	5.99 KB	-rw-r--r--
web_runner.py	11.46 KB	-rw-r--r--
web_server.py	2.53 KB	-rw-r--r--
web_urldispatcher.py	39.12 KB	-rw-r--r--
web_ws.py	18.21 KB	-rw-r--r--
worker.py	7.78 KB	-rw-r--r--

Code Editor : http_writer.py

"""Http related parsers and protocol."""

import asyncio
import zlib
from typing import Any, Awaitable, Callable, NamedTuple, Optional, Union  # noqa

from multidict import CIMultiDict

from .abc import AbstractStreamWriter
from .base_protocol import BaseProtocol
from .compression_utils import ZLibCompressor
from .helpers import NO_EXTENSIONS

__all__ = ("StreamWriter", "HttpVersion", "HttpVersion10", "HttpVersion11")

class HttpVersion(NamedTuple):
    major: int
    minor: int

HttpVersion10 = HttpVersion(1, 0)
HttpVersion11 = HttpVersion(1, 1)

_T_OnChunkSent = Optional[Callable[[bytes], Awaitable[None]]]
_T_OnHeadersSent = Optional[Callable[["CIMultiDict[str]"], Awaitable[None]]]

class StreamWriter(AbstractStreamWriter):
    def __init__(
        self,
        protocol: BaseProtocol,
        loop: asyncio.AbstractEventLoop,
        on_chunk_sent: _T_OnChunkSent = None,
        on_headers_sent: _T_OnHeadersSent = None,
    ) -> None:
        self._protocol = protocol

self.loop = loop
        self.length = None
        self.chunked = False
        self.buffer_size = 0
        self.output_size = 0

self._eof = False
        self._compress: Optional[ZLibCompressor] = None
        self._drain_waiter = None

self._on_chunk_sent: _T_OnChunkSent = on_chunk_sent
        self._on_headers_sent: _T_OnHeadersSent = on_headers_sent

@property
    def transport(self) -> Optional[asyncio.Transport]:
        return self._protocol.transport

@property
    def protocol(self) -> BaseProtocol:
        return self._protocol

def enable_chunking(self) -> None:
        self.chunked = True

def enable_compression(
        self, encoding: str = "deflate", strategy: int = zlib.Z_DEFAULT_STRATEGY
    ) -> None:
        self._compress = ZLibCompressor(encoding=encoding, strategy=strategy)

def _write(self, chunk: bytes) -> None:
        size = len(chunk)
        self.buffer_size += size
        self.output_size += size
        transport = self.transport
        if not self._protocol.connected or transport is None or transport.is_closing():
            raise ConnectionResetError("Cannot write to closing transport")
        transport.write(chunk)

async def write(
        self, chunk: bytes, *, drain: bool = True, LIMIT: int = 0x10000
    ) -> None:
        """Writes chunk of data to a stream.

write_eof() indicates end of stream.
        writer can't be used after write_eof() method being called.
        write() return drain future.
        """
        if self._on_chunk_sent is not None:
            await self._on_chunk_sent(chunk)

if isinstance(chunk, memoryview):
            if chunk.nbytes != len(chunk):
                # just reshape it
                chunk = chunk.cast("c")

if self._compress is not None:
            chunk = await self._compress.compress(chunk)
            if not chunk:
                return

if self.length is not None:
            chunk_len = len(chunk)
            if self.length >= chunk_len:
                self.length = self.length - chunk_len
            else:
                chunk = chunk[: self.length]
                self.length = 0
                if not chunk:
                    return

if chunk:
            if self.chunked:
                chunk_len_pre = ("%x\r\n" % len(chunk)).encode("ascii")
                chunk = chunk_len_pre + chunk + b"\r\n"

self._write(chunk)

if self.buffer_size > LIMIT and drain:
                self.buffer_size = 0
                await self.drain()

async def write_headers(
        self, status_line: str, headers: "CIMultiDict[str]"
    ) -> None:
        """Write request/response status and headers."""
        if self._on_headers_sent is not None:
            await self._on_headers_sent(headers)

# status + headers
        buf = _serialize_headers(status_line, headers)
        self._write(buf)

async def write_eof(self, chunk: bytes = b"") -> None:
        if self._eof:
            return

if chunk and self._on_chunk_sent is not None:
            await self._on_chunk_sent(chunk)

if self._compress:
            if chunk:
                chunk = await self._compress.compress(chunk)

chunk += self._compress.flush()
            if chunk and self.chunked:
                chunk_len = ("%x\r\n" % len(chunk)).encode("ascii")
                chunk = chunk_len + chunk + b"\r\n0\r\n\r\n"
        else:
            if self.chunked:
                if chunk:
                    chunk_len = ("%x\r\n" % len(chunk)).encode("ascii")
                    chunk = chunk_len + chunk + b"\r\n0\r\n\r\n"
                else:
                    chunk = b"0\r\n\r\n"

if chunk:
            self._write(chunk)

await self.drain()

self._eof = True

async def drain(self) -> None:
        """Flush the write buffer.

The intended use is to write

await w.write(data)
          await w.drain()
        """
        if self._protocol.transport is not None:
            await self._protocol._drain_helper()

def _safe_header(string: str) -> str:
    if "\r" in string or "\n" in string:
        raise ValueError(
            "Newline or carriage return detected in headers. "
            "Potential header injection attack."
        )
    return string

def _py_serialize_headers(status_line: str, headers: "CIMultiDict[str]") -> bytes:
    headers_gen = (_safe_header(k) + ": " + _safe_header(v) for k, v in headers.items())
    line = status_line + "\r\n" + "\r\n".join(headers_gen) + "\r\n\r\n"
    return line.encode("utf-8")

_serialize_headers = _py_serialize_headers

try:
    import aiohttp._http_writer as _http_writer  # type: ignore[import-not-found]

_c_serialize_headers = _http_writer._serialize_headers
    if not NO_EXTENSIONS:
        _serialize_headers = _c_serialize_headers
except ImportError:
    pass

${this.title}

Code Editor : http_writer.py