mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2025-10-30 23:47:33 +03:00
40 lines
1.2 KiB
Python
40 lines
1.2 KiB
Python
import asyncio
|
|
|
|
from .connection import Connection, PacketCodec
|
|
|
|
|
|
SSL_PORT = 443
|
|
|
|
|
|
class HttpPacketCodec(PacketCodec):
|
|
tag = None
|
|
obfuscate_tag = None
|
|
|
|
def encode_packet(self, data):
|
|
return ('POST /api HTTP/1.1\r\n'
|
|
'Host: {}:{}\r\n'
|
|
'Content-Type: application/x-www-form-urlencoded\r\n'
|
|
'Connection: keep-alive\r\n'
|
|
'Keep-Alive: timeout=100000, max=10000000\r\n'
|
|
'Content-Length: {}\r\n\r\n'
|
|
.format(self._conn._ip, self._conn._port, len(data))
|
|
.encode('ascii') + data)
|
|
|
|
async def read_packet(self, reader):
|
|
while True:
|
|
line = await reader.readline()
|
|
if not line or line[-1] != b'\n':
|
|
raise asyncio.IncompleteReadError(line, None)
|
|
|
|
if line.lower().startswith(b'content-length: '):
|
|
await reader.readexactly(2)
|
|
length = int(line[16:-2])
|
|
return await reader.readexactly(length)
|
|
|
|
|
|
class ConnectionHttp(Connection):
|
|
packet_codec = HttpPacketCodec
|
|
|
|
async def connect(self, timeout=None, ssl=None):
|
|
await super().connect(timeout=timeout, ssl=self._port == SSL_PORT)
|