danog/TelegramApiServer
1
0
Fork 0
mirror of https://github.com/danog/TelegramApiServer.git synced 2024-11-26 20:04:45 +01:00
Code Issues Projects Releases Wiki Activity

Big request body support.

Browse Source
This commit is contained in:
Alexander Pankratov 2019-06-24 17:13:00 +03:00
parent e93a5a8891
commit f7e79e7d5c
1 changed files with 30 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
src/Server.php
View File

@ -28,32 +28,42 @@ class Server
Socket\listen("{$this->config['address']}:{$this->config['port']}"),
];
$server = new Amp\Http\Server\Server($sockets, new CallableRequestHandler(function (Request $request) use($client) {
//На каждый запрос должны создаваться новые экземпляры классов парсера и коллбеков,
//иначе их данные будут в области видимости всех запросов.
$server = new Amp\Http\Server\Server(
$sockets,
new CallableRequestHandler(function (Request $request) use($client) {
//На каждый запрос должны создаваться новые экземпляры классов парсера и коллбеков,
//иначе их данные будут в области видимости всех запросов.
//Телеграм клиент инициализируется 1 раз и используется во всех запросах.
//Телеграм клиент инициализируется 1 раз и используется во всех запросах.
$body = yield $request->getBody()->read();
$requestCallback = new RequestCallback($client, $request, $body);
try {
if ($requestCallback->page['response'] instanceof Promise) {
$requestCallback->page['response'] = yield $requestCallback->page['response'];
$body = '';
while ($chunk = yield $request->getBody()->read()) {
$body .= $chunk;
}
} catch (\Throwable $e) {
$requestCallback->setError($e);
}
return new Response(
$requestCallback->page['code'],
$requestCallback->page['headers'],
$requestCallback->getResponse()
);
$requestCallback = new RequestCallback($client, $request, $body);
try {
if ($requestCallback->page['response'] instanceof Promise) {
$requestCallback->page['response'] = yield $requestCallback->page['response'];
}
} catch (\Throwable $e) {
$requestCallback->setError($e);
}
return new Response(
$requestCallback->page['code'],
$requestCallback->page['headers'],
$requestCallback->getResponse()
);
}), new Logger(LogLevel::DEBUG));
}),
new Logger(LogLevel::DEBUG),
(new Amp\Http\Server\Options())
->withCompression()
->withBodySizeLimit(30*1024*1024)
);
yield $server->start();