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

Merge pull request #2 from danog/upstream_docker_image

Browse Source 
Upstream docker image
This commit is contained in:
Daniil Gentili 2024-07-14 12:26:54 +02:00 committed by GitHub
commit 151c00516f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
37 changed files with 2797 additions and 465 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
Dockerfile
View File

@ -1,31 +1,13 @@
FROM php:8.3-cli
FROM danog/madelineproto:latest
RUN apt-get update && apt-get upgrade -y
RUN true \
# Install main extension
&& apt-get install procps git zip vim libzip-dev libgmp-dev libuv1-dev libssl-dev libnghttp2-dev libffi-dev libicu-dev libonig-dev libxml2-dev libpng-dev -y \
&& docker-php-ext-install -j$(nproc) sockets bcmath mysqli pdo_mysql pcntl ffi intl gmp zip gd \
# Install additional extension
&& mkdir -p /usr/src/php/ext/ && cd /usr/src/php/ext/ \
&& pecl bundle uv && pecl bundle igbinary \
&& docker-php-ext-install -j$(nproc) uv igbinary \
# Install PrimeModule for AuthKey generation speedup
&& git clone https://github.com/danog/PrimeModule-ext \
&& cd PrimeModule-ext && make -j$(nproc) \
&& make install \
&& cd ../ \
&& rm -rf PrimeModule-ext/ \
# Install composer
&& curl -sS https://getcomposer.org/installer | php -- --install-dir=/usr/local/bin --filename=composer \
# Cleanup
&& docker-php-source delete \
&& apt-get autoremove --purge -y && apt-get autoclean -y && apt-get clean -y \
&& rm -rf /usr/src
RUN curl -sS https://getcomposer.org/installer | php -- --install-dir=/usr/local/bin --filename=composer
COPY --from=ghcr.io/ufoscout/docker-compose-wait:latest /wait /usr/local/bin/docker-compose-wait
ADD docker/php/conf.d/. "$PHP_INI_DIR/conf.d/"
RUN echo 1.0.0 > /tas_version
EXPOSE 9503
ENTRYPOINT ["./entrypoint.sh"]
ENV UV_USE_IO_URING=0
ENTRYPOINT ["./entrypoint.sh"]

14
Dockerfile-dev
View File

@ -1,12 +1,16 @@
FROM xtrime/telegram-api-server:latest
ADD docker/php/conf.d/. "$PHP_INI_DIR/conf.d/"
ADD https://github.com/mlocati/docker-php-extension-installer/releases/latest/download/install-php-extensions /usr/local/bin/
RUN pecl install xdebug \
&& echo "" >> "$PHP_INI_DIR/conf.d/xdebug.ini" \
&& echo "zend_extension=xdebug.so" >> "$PHP_INI_DIR/conf.d/xdebug.ini"
RUN echo "opcache.jit=disable" >> "$PHP_INI_DIR/conf.d/xdebug.ini"
RUN chmod +x /usr/local/bin/install-php-extensions && \
install-php-extensions xdebug && \
rm /usr/local/bin/install-php-extensions
ADD dev/. "$PHP_INI_DIR/conf.d/"
EXPOSE 9503
EXPOSE 9003
ENTRYPOINT ["./entrypoint.sh"]
ENTRYPOINT ["./entrypoint.sh"]

17
bootstrap.php
View File

@ -1,5 +1,9 @@
<?php
use Amp\Future\UnhandledFutureError;
use Amp\SignalException;
use Amp\Sql\SqlException;
use danog\MadelineProto\SecurityException;
use Revolt\EventLoop;
use TelegramApiServer\Logger;
use TelegramApiServer\Migrations\EnvUpgrade;
@ -113,3 +117,16 @@ if (!function_exists('emergency')) {
Logger::getInstance()->emergency($message, $context);
}
}
EventLoop::setErrorHandler(function (\Throwable $e) {
if ($e instanceof UnhandledFutureError) {
$e = $e->getPrevious();
}
if ($e instanceof SecurityException || $e instanceof SignalException || $e instanceof SqlException) {
throw $e;
}
if (str_starts_with($e->getMessage(), 'Could not connect to DC ')) {
throw $e;
}
emergency((string) $e);
});

16
composer.json
View File

@ -24,19 +24,22 @@
}
],
"require": {
"php": "^8.1",
"php": "^8.2",
"ext-json": "*",
"ext-mbstring": "*",
"amphp/http-server": "^v3",
"amphp/http": "^v2",
"amphp/http-server": "^3.3.1",
"amphp/http": "^2.1.1",
"amphp/http-server-router": "^2",
"amphp/http-server-form-parser": "^v2",
"amphp/websocket-server": "^v3",
"amphp/websocket-server": "^3.0.1",
"amphp/websocket-client": "^v2",
"vlucas/phpdotenv": "^4",
"vlucas/phpdotenv": "^4.3",
"danog/madelineproto": "dev-v8_fix_cleanup",
"amphp/dns": "2.x-dev"
},
"require-dev": {
"amphp/php-cs-fixer-config": "^2.0.1"
},
"suggest": {
"ext-pcntl": "Install pcintl for propper signal handling and healthcheck (enabled in .env)"
},
@ -57,5 +60,8 @@
"allow-plugins": {
"symfony/thanks": false
}
},
"scripts": {
"cs-fix": "PHP_CS_FIXER_IGNORE_ENV=1 php -d pcre.jit=0 vendor/bin/php-cs-fixer fix -v"
}
}

2475
composer.lock generated
View File

File diff suppressed because it is too large Load Diff

8
config.php
View File

@ -3,6 +3,8 @@
use danog\MadelineProto\Logger;
use TelegramApiServer\EventObservers\LogObserver;
use function Amp\Socket\SocketAddress\fromString;
$settings = [
'server' => [
'address' => (string)getenv('SERVER_ADDRESS'),
@ -58,6 +60,10 @@ $settings = [
'report_broken_media' => false,
'download_parallel_chunks' => 20,
],
'metrics' => [
'enable_prometheus_collection' => true, //(bool)getenv("PROMETHEUS_BIND_TO"),
'metrics_bind_to' => fromString("0.0.0.0:12345")
]
],
'api' => [
'ip_whitelist' => array_filter(
@ -79,4 +85,4 @@ if (empty($settings['telegram']['app_info']['api_id'])) {
throw new InvalidArgumentException('Need to fill TELEGRAM_API_ID in .env.docker or .env');
}
return $settings;
return $settings;

5
docker/php/conf.d/xdebug.ini → dev/xdebug.ini
View File

@ -1,5 +1,8 @@
opcache.jit=disable
zend_extension=xdebug.so
xdebug.max_nesting_level=512
xdebug.mode=debug
xdebug.start_with_request=yes
xdebug.client_host=host.docker.internal
xdebug.client_port=9003
xdebug.client_port=9003

2
docker-compose.base.yml
View File

@ -19,7 +19,7 @@ services:
max-size: "1024k"
max-file: "2"
healthcheck:
test: timeout 15 curl -f http://localhost:9503/system/healthcheck || bash -c 'kill -INT -1 && (sleep 5; kill -s 9 -1)'
test: timeout 15 curl -f http://localhost:9503/system/healthcheck || sh -c 'kill -INT -1 && (sleep 5; kill -s 9 -1)'
interval: 60s
timeout: 30s
retries: 1

3
docker-compose.yml
View File

@ -5,6 +5,7 @@ services:
service: base-api
ports:
- "127.0.0.1:9503:9503"
- "12345:12345"
command:
- "-s=session"
mysql:
@ -15,4 +16,4 @@ services:
- "127.0.0.1:9507:3306"
networks:
default:
name: telegram-api-server
name: telegram-api-server

1
docker/php/conf.d/common.ini
View File

@ -1 +0,0 @@
zend.assertions=-1

11
docker/php/conf.d/opcache.ini
View File

@ -1,11 +0,0 @@
; Extended PHP.ini file to enable JIT.
; ====================================
; Place this file under /usr/local/etc/php/conf.d/
zend_extension=opcache.so
opcache.enable=1
opcache.enable_cli=1
opcache.validate_timestamps=1
opcache.revalidate_freq=0
opcache.huge_code_pages=1
opcache.jit_buffer_size=100M
opcache.jit=function

14
entrypoint.sh
View File

@ -1,4 +1,14 @@
#!/usr/bin/env bash
#!/usr/bin/env sh
VERSION=1.0.0
CURRENT_VERSION=$(cat /tas_version)
if [ "$VERSION" != "$CURRENT_VERSION" ]; then
echo "Wrong docker image version, expected $VERSION, got $CURRENT_VERSION, please run docker compose pull!"
exit 1
fi
composer install
docker-compose-wait \
&& nice -n 20 php server.php -e=.env.docker --docker "$@"
&& nice -n 20 php server.php -e=.env.docker --docker "$@"

7
examples/websocket-events.php
View File

@ -1,7 +1,7 @@
<?php
<?php declare(strict_types=1);
/**
* Get all updates from MadelineProto EventHandler running inside TelegramApiServer via websocket
* Get all updates from MadelineProto EventHandler running inside TelegramApiServer via websocket.
* @see \TelegramApiServer\Controllers\EventsController
*/
@ -13,7 +13,6 @@ use function Amp\Websocket\Client\connect;
require 'vendor/autoload.php';
$shortopts = 'u::';
$longopts = [
'url::',
@ -55,4 +54,4 @@ if (defined('SIGINT')) {
$signal = Amp\trapSignal([SIGINT, SIGTERM]);
} else {
EventLoop::run();
}
}

3
server.php
View File

@ -83,9 +83,6 @@ foreach ($options['session'] as $session) {
}
StartUpFixes::fix();
foreach ($sessions as $session) {
StartUpFixes::removeBrokenIpc($session);
}
new TelegramApiServer\Server\Server(
$options,

47
src/Client.php
View File

@ -1,7 +1,8 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer;
use Amp\Sync\LocalKeyedMutex;
use danog\MadelineProto\API;
use danog\MadelineProto\APIWrapper;
use danog\MadelineProto\Settings;
@ -11,10 +12,9 @@ use InvalidArgumentException;
use Psr\Log\LogLevel;
use ReflectionProperty;
use RuntimeException;
use TelegramApiServer\EventObservers\EventHandler;
use TelegramApiServer\EventObservers\EventObserver;
class Client
final class Client
{
public static Client $self;
/** @var API[] */
@ -22,10 +22,10 @@ class Client
public static function getInstance(): Client
{
if (empty(static::$self)) {
static::$self = new static();
if (empty(self::$self)) {
self::$self = new static();
}
return static::$self;
return self::$self;
}
public function connect(array $sessionFiles)
@ -40,15 +40,19 @@ class Client
$this->startNotLoggedInSessions();
$sessionsCount = count($sessionFiles);
$sessionsCount = \count($sessionFiles);
warning(
"\nTelegramApiServer ready."
. "\nNumber of sessions: {$sessionsCount}."
);
}
private static LocalKeyedMutex $mutex;
public function addSession(string $session, array $settings = []): API
{
self::$mutex ??= new LocalKeyedMutex;
$lock = self::$mutex->acquire($session);
if (isset($this->instances[$session])) {
throw new InvalidArgumentException('Session already exists');
}
@ -58,8 +62,8 @@ class Client
if ($settings) {
Files::saveSessionSettings($session, $settings);
}
$settings = array_replace_recursive(
(array)Config::getInstance()->get('telegram'),
$settings = \array_replace_recursive(
(array) Config::getInstance()->get('telegram'),
Files::getSessionSettings($session),
);
@ -87,14 +91,9 @@ class Client
$instance->unsetEventHandler();
}
unset($instance);
gc_collect_cycles();
\gc_collect_cycles();
}
/**
* @param string|null $session
*
* @return API
*/
public function getSession(?string $session = null): API
{
if (!$this->instances) {
@ -104,8 +103,8 @@ class Client
}
if (!$session) {
if (count($this->instances) === 1) {
$session = (string)array_key_first($this->instances);
if (\count($this->instances) === 1) {
$session = (string) \array_key_first($this->instances);
} else {
throw new InvalidArgumentException(
'Multiple sessions detected. Specify which session to use. See README for examples.'
@ -160,9 +159,10 @@ class Client
return $wrapper;
}
private static function getSettingsFromArray(string $session, array $settings, SettingsAbstract $settingsObject = new Settings()): SettingsAbstract {
private static function getSettingsFromArray(string $session, array $settings, SettingsAbstract $settingsObject = new Settings()): SettingsAbstract
{
foreach ($settings as $key => $value) {
if (is_array($value) && $key !== 'proxies') {
if (\is_array($value) && $key !== 'proxies') {
if ($key === 'db' && isset($value['type'])) {
$type = match ($value['type']) {
'memory' => new Settings\Database\Memory(),
@ -180,23 +180,22 @@ class Client
}
unset($value[$value['type']], $value['type'],);
if (count($value) === 0) {
if (\count($value) === 0) {
continue;
}
}
$method = 'get' . ucfirst(str_replace('_', '', ucwords($key, '_')));
$method = 'get' . \ucfirst(\str_replace('_', '', \ucwords($key, '_')));
self::getSettingsFromArray($session, $value, $settingsObject->$method());
} else {
if ($key === 'serializer' && is_string($value)) {
if ($key === 'serializer' && \is_string($value)) {
$value = SerializerType::from($value);
}
$method = 'set' . ucfirst(str_replace('_', '', ucwords($key, '_')));
$method = 'set' . \ucfirst(\str_replace('_', '', \ucwords($key, '_')));
$settingsObject->$method($value);
}
}
return $settingsObject;
}
}

22
src/Config.php
View File

@ -1,26 +1,24 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer;
class Config
final class Config
{
private static ?Config $instance = null;
private array $config;
public static function getInstance(): Config
{
if (null === static::$instance) {
static::$instance = new static();
if (null === self::$instance) {
self::$instance = new static();
}
return static::$instance;
return self::$instance;
}
/**
* is not allowed to call from outside to prevent from creating multiple instances,
* to use the singleton, you have to obtain the instance from Singleton::getInstance() instead
* to use the singleton, you have to obtain the instance from Singleton::getInstance() instead.
*/
private function __construct()
{
@ -39,12 +37,12 @@ class Config
private function findByKey($key)
{
$key = (string)$key;
$path = explode('.', $key);
$key = (string) $key;
$path = \explode('.', $key);
$value = &$this->config;
foreach ($path as $pathKey) {
if (!is_array($value) || !array_key_exists($pathKey, $value)) {
if (!\is_array($value) || !\array_key_exists($pathKey, $value)) {
return null;
}
$value = &$value[$pathKey];
@ -53,4 +51,4 @@ class Config
return $value;
}
}
}

48
src/Controllers/AbstractApiController.php
View File

@ -1,4 +1,4 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Controllers;
@ -18,8 +18,6 @@ use TelegramApiServer\MadelineProtoExtensions\ApiExtensions;
use TelegramApiServer\MadelineProtoExtensions\SystemApiExtensions;
use Throwable;
use UnexpectedValueException;
use function Amp\delay;
use function mb_strpos;
abstract class AbstractApiController
{
@ -29,7 +27,6 @@ abstract class AbstractApiController
protected ?StreamedField $file = null;
protected string $extensionClass;
public array $page = [
'headers' => self::JSON_HEADER,
'success' => false,
@ -83,19 +80,19 @@ abstract class AbstractApiController
}
/**
* Получаем параметры из GET и POST
* Получаем параметры из GET и POST.
*
*/
private function resolveRequest(): void
{
$query = $this->request->getUri()->getQuery();
$contentType = (string)$this->request->getHeader('Content-Type');
$contentType = (string) $this->request->getHeader('Content-Type');
parse_str($query, $get);
\parse_str($query, $get);
switch (true) {
case $contentType === 'application/x-www-form-urlencoded':
case mb_strpos($contentType, 'multipart/form-data') !== false:
case \str_contains($contentType, 'multipart/form-data'):
$form = (new StreamingFormParser())->parseForm($this->request);
$post = [];
@ -107,27 +104,27 @@ abstract class AbstractApiController
//We need to break loop without getting file
//All other post field will be omitted, hope we dont need them :)
break;
} else {
$post[$field->getName()] = $field->buffer();
}
$post[$field->getName()] = $field->buffer();
}
break;
case $contentType === 'application/json':
$body = $this->request->getBody()->buffer();
$post = json_decode($body, 1);
$post = \json_decode($body, true);
break;
default:
$body = $this->request->getBody()->buffer();
parse_str($body, $post);
\parse_str($body, $post);
}
$this->parameters = array_merge((array)$post, $get);
$this->parameters = array_values($this->parameters);
$this->parameters = \array_merge((array) $post, $get);
$this->parameters = \array_values($this->parameters);
}
/**
* Получает посты для формирования ответа
* Получает посты для формирования ответа.
*
*/
private function generateResponse(): void
@ -159,16 +156,16 @@ abstract class AbstractApiController
protected function callApiCommon(API $madelineProto)
{
$pathCount = count($this->api);
if ($pathCount === 1 && method_exists($this->extensionClass, $this->api[0])) {
$pathCount = \count($this->api);
if ($pathCount === 1 && \method_exists($this->extensionClass, $this->api[0])) {
/** @var ApiExtensions|SystemApiExtensions $madelineProtoExtensions */
$madelineProtoExtensions = new $this->extensionClass($madelineProto, $this->request, $this->file);
$result = $madelineProtoExtensions->{$this->api[0]}(...$this->parameters);
} else {
if ($this->api[0] === 'API') {
$madelineProto = Client::getWrapper($madelineProto)->getAPI();
array_shift($this->api);
$pathCount = count($this->api);
\array_shift($this->api);
$pathCount = \count($this->api);
}
//Проверяем нет ли в MadilineProto такого метода.
switch ($pathCount) {
@ -190,9 +187,7 @@ abstract class AbstractApiController
}
/**
* @param Throwable $e
*
* @return AbstractApiController
* @throws Throwable
*/
private function setError(Throwable $e): self
@ -210,9 +205,8 @@ abstract class AbstractApiController
}
/**
* Кодирует ответ в нужный формат: json
* Кодирует ответ в нужный формат: json.
*
* @return Response|string
* @throws JsonException
*/
private function getResponse(): string|Response
@ -230,7 +224,7 @@ abstract class AbstractApiController
$data['success'] = true;
}
$result = json_encode(
$result = \json_encode(
$data,
JSON_THROW_ON_ERROR |
JSON_INVALID_UTF8_SUBSTITUTE |
@ -244,15 +238,13 @@ abstract class AbstractApiController
}
/**
* Устанавливает http код ответа (200, 400, 404 и тд.)
* Устанавливает http код ответа (200, 400, 404 и тд.).
*
* @param int $code
*
* @return AbstractApiController
*/
private function setPageCode(int $code): self
{
$this->page['code'] = $this->page['code'] === 200 ? $code : $this->page['code'];
return $this;
}
}
}

53
src/Controllers/ApiController.php
View File

@ -1,35 +1,25 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Controllers;
use Amp\Sync\LocalKeyedMutex;
use Amp\Sync\LocalMutex;
use Amp\Sync\StaticKeyMutex;
use Amp\Sync\SyncException;
use Exception;
use Revolt\EventLoop;
use TelegramApiServer\Client;
use TelegramApiServer\Config;
use TelegramApiServer\Logger;
use function Amp\async;
use function Amp\delay;
use function Amp\Future\awaitAll;
class ApiController extends AbstractApiController
final class ApiController extends AbstractApiController
{
private ?string $session = '';
/**
* Получаем параметры из uri
* Получаем параметры из uri.
*
* @param array $path
*
*/
protected function resolvePath(array $path): void
{
$this->session = $path['session'] ?? null;
$this->api = explode('.', $path['method'] ?? '');
$this->api = \explode('.', $path['method'] ?? '');
}
/**
@ -44,37 +34,6 @@ class ApiController extends AbstractApiController
return $this->callApiCommon($madelineProto);
}
//GROUP REQUESTS IN BULKS
static $futures = [];
$futures[] = $future = async($this->callApiCommon(...), $madelineProto);
delay($this->waitNextTick());
if ($futures) {
awaitAll($futures);
Logger::getInstance()->notice("Executed bulk requests:" . count($futures));
$futures = [];
}
return $future->await();
return $this->callApiCommon($madelineProto);
}
/**
* Sync threads execution via time ticks
* Need to enable madelineProto futures bulk execution
* @param float $tick interval of execution in seconds.
*/
protected function waitNextTick(float $tick = 0.5): float {
$tickMs = $tick * 1000;
$now = (int)(microtime(true) * 1000);
$currentTick = intdiv((int)(microtime(true) * 1000), $tickMs);
$nextTick = ($currentTick + 1);
$nextTickTime = $nextTick * $tickMs;
$wait = round(($nextTickTime - $now)/1000, 3);
Logger::getInstance()->notice("Waiting $wait seconds before tick");
return $wait;
}
}
}

12
src/Controllers/EventsController.php
View File

@ -1,11 +1,11 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Controllers;
use Amp\Http\HttpStatus;
use Amp\Http\Server\Request;
use Amp\Http\Server\Response;
use Amp\Http\Server\Router;
use Amp\Http\HttpStatus;
use Amp\Http\Server\SocketHttpServer;
use Amp\Websocket\Server\Rfc6455Acceptor;
use Amp\Websocket\Server\Websocket as WebsocketServer;
@ -20,7 +20,7 @@ use TelegramApiServer\EventObservers\EventObserver;
use TelegramApiServer\Logger;
use Throwable;
class EventsController implements WebsocketClientHandler, WebsocketAcceptor
final class EventsController implements WebsocketClientHandler, WebsocketAcceptor
{
private const PING_INTERVAL_MS = 10_000;
private WebsocketClientGateway $gateway;
@ -82,7 +82,7 @@ class EventsController implements WebsocketClientHandler, WebsocketAcceptor
EventObserver::startEventHandler($requestedSession);
$pingLoop = EventLoop::repeat(self::PING_INTERVAL_MS, static fn() => $client->ping());
$pingLoop = EventLoop::repeat(self::PING_INTERVAL_MS, static fn () => $client->ping());
$client->onClose(static function () use ($clientId, $requestedSession, $pingLoop) {
EventLoop::cancel($pingLoop);
@ -104,7 +104,7 @@ class EventsController implements WebsocketClientHandler, WebsocketAcceptor
];
$this->gateway->multicastText(
json_encode(
\json_encode(
$update,
JSON_THROW_ON_ERROR |
JSON_INVALID_UTF8_SUBSTITUTE |
@ -115,4 +115,4 @@ class EventsController implements WebsocketClientHandler, WebsocketAcceptor
);
});
}
}
}

10
src/Controllers/LogController.php
View File

@ -1,4 +1,4 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Controllers;
@ -17,7 +17,7 @@ use Revolt\EventLoop;
use TelegramApiServer\EventObservers\LogObserver;
use TelegramApiServer\Logger;
class LogController implements WebsocketClientHandler, WebsocketAcceptor
final class LogController implements WebsocketClientHandler, WebsocketAcceptor
{
private const PING_INTERVAL_MS = 10_000;
private WebsocketClientGateway $gateway;
@ -68,7 +68,7 @@ class LogController implements WebsocketClientHandler, WebsocketAcceptor
{
$clientId = $client->getId();
$pingLoop = EventLoop::repeat(self::PING_INTERVAL_MS, static fn() => $client->ping());
$pingLoop = EventLoop::repeat(self::PING_INTERVAL_MS, static fn () => $client->ping());
$client->onClose(static function () use ($clientId, $pingLoop) {
EventLoop::cancel($pingLoop);
@ -90,7 +90,7 @@ class LogController implements WebsocketClientHandler, WebsocketAcceptor
];
$this->gateway->multicastText(
json_encode(
\json_encode(
$update,
JSON_THROW_ON_ERROR |
JSON_INVALID_UTF8_SUBSTITUTE |
@ -101,4 +101,4 @@ class LogController implements WebsocketClientHandler, WebsocketAcceptor
);
});
}
}
}

12
src/Controllers/SystemController.php
View File

@ -1,25 +1,23 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Controllers;
use Exception;
use TelegramApiServer\Client;
class SystemController extends AbstractApiController
final class SystemController extends AbstractApiController
{
/**
* Получаем параметры из uri
* Получаем параметры из uri.
*
* @param array $path
*
*/
protected function resolvePath(array $path): void
{
$this->api = explode('.', $path['method'] ?? '');
$this->api = \explode('.', $path['method'] ?? '');
}
/**
* @return mixed
* @throws Exception
*/
protected function callApi()
@ -29,4 +27,4 @@ class SystemController extends AbstractApiController
return $result;
}
}
}

10
src/EventObservers/EventHandler.php
View File

@ -4,7 +4,7 @@ namespace TelegramApiServer\EventObservers;
use TelegramApiServer\Files;
class EventHandler extends \danog\MadelineProto\EventHandler
final class EventHandler extends \danog\MadelineProto\EventHandler
{
public static array $instances = [];
private string $sessionName;
@ -12,8 +12,8 @@ class EventHandler extends \danog\MadelineProto\EventHandler
public function onStart()
{
$this->sessionName = Files::getSessionName($this->wrapper->getSession()->getSessionPath());
if (empty(static::$instances[$this->sessionName])) {
static::$instances[$this->sessionName] = true;
if (empty(self::$instances[$this->sessionName])) {
self::$instances[$this->sessionName] = true;
warning("Event observer CONSTRUCTED: {$this->sessionName}");
}
}
@ -23,7 +23,7 @@ class EventHandler extends \danog\MadelineProto\EventHandler
if (empty($this->sessionName)) {
return;
}
unset(static::$instances[$this->sessionName]);
unset(self::$instances[$this->sessionName]);
warning("Event observer DESTRUCTED: {$this->sessionName}");
}
@ -32,4 +32,4 @@ class EventHandler extends \danog\MadelineProto\EventHandler
info("Received update from session: {$this->sessionName}");
EventObserver::notify($update, $this->sessionName);
}
}
}

35
src/EventObservers/EventObserver.php
View File

@ -1,15 +1,14 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\EventObservers;
use danog\MadelineProto\APIWrapper;
use ReflectionProperty;
use TelegramApiServer\Client;
use TelegramApiServer\Logger;
use Throwable;
class EventObserver
final class EventObserver
{
use ObserverTrait;
@ -18,7 +17,7 @@ class EventObserver
public static function notify(array $update, string $sessionName)
{
foreach (static::$subscribers as $clientId => $callback) {
foreach (self::$subscribers as $clientId => $callback) {
notice("Pass update to callback. ClientId: {$clientId}");
$callback($update, $sessionName);
}
@ -26,16 +25,16 @@ class EventObserver
private static function addSessionClient(string $session): void
{
if (empty(static::$sessionClients[$session])) {
static::$sessionClients[$session] = 0;
if (empty(self::$sessionClients[$session])) {
self::$sessionClients[$session] = 0;
}
++static::$sessionClients[$session];
++self::$sessionClients[$session];
}
private static function removeSessionClient(string $session): void
{
if (!empty(static::$sessionClients[$session])) {
--static::$sessionClients[$session];
if (!empty(self::$sessionClients[$session])) {
--self::$sessionClients[$session];
}
}
@ -43,14 +42,14 @@ class EventObserver
{
$sessions = [];
if ($requestedSession === null) {
$sessions = array_keys(Client::getInstance()->instances);
$sessions = \array_keys(Client::getInstance()->instances);
} else {
$sessions[] = $requestedSession;
}
foreach ($sessions as $session) {
static::addSessionClient($session);
if (static::$sessionClients[$session] === 1) {
self::addSessionClient($session);
if (self::$sessionClients[$session] === 1) {
warning("Start EventHandler: {$session}");
try {
$instance = Client::getInstance()->getSession($session);
@ -60,7 +59,7 @@ class EventObserver
EventHandler::cachePlugins(EventHandler::class);
$wrapper->getAPI()->setEventHandler(EventHandler::class);
} catch (Throwable $e) {
static::removeSessionClient($session);
self::removeSessionClient($session);
error('Cant set EventHandler', [
'session' => $session,
'exception' => Logger::getExceptionAsArray($e),
@ -74,19 +73,19 @@ class EventObserver
{
$sessions = [];
if ($requestedSession === null) {
$sessions = array_keys(Client::getInstance()->instances);
$sessions = \array_keys(Client::getInstance()->instances);
} else {
$sessions[] = $requestedSession;
}
foreach ($sessions as $session) {
static::removeSessionClient($session);
if (empty(static::$sessionClients[$session]) || $force) {
self::removeSessionClient($session);
if (empty(self::$sessionClients[$session]) || $force) {
warning("Stopping EventHandler: {$session}");
Client::getInstance()->instances[$session]->unsetEventHandler();
unset(EventHandler::$instances[$session], static::$sessionClients[$session]);
unset(EventHandler::$instances[$session], self::$sessionClients[$session]);
}
}
}
}
}

18
src/EventObservers/LogObserver.php
View File

@ -1,39 +1,39 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\EventObservers;
use TelegramApiServer\Logger;
use Throwable;
class LogObserver
final class LogObserver
{
use ObserverTrait;
public static function notify(string $level, string $message, array $context = []): void
{
foreach (static::$subscribers as $clientId => $callback) {
foreach (self::$subscribers as $clientId => $callback) {
$callback($level, $message, $context);
}
}
/**
* @param mixed|array|string $message
* @param int $level
*/
public static function log($message, int $level)
{
if (is_scalar($message)) {
Logger::getInstance()->log(Logger::$madelineLevels[$level], (string)$message);
if (\is_scalar($message)) {
Logger::getInstance()->log(Logger::$madelineLevels[$level], (string) $message);
} else {
if ($message instanceof Throwable) {
$message = Logger::getExceptionAsArray($message);
}
if (is_array($message)) {
if (\is_array($message)) {
Logger::getInstance()->log(Logger::$madelineLevels[$level], '', $message);
} else {
Logger::getInstance()->log(
Logger::$madelineLevels[$level],
json_encode($message,
\json_encode(
$message,
JSON_UNESCAPED_UNICODE |
JSON_PRETTY_PRINT |
JSON_INVALID_UTF8_SUBSTITUTE |
@ -43,4 +43,4 @@ class LogObserver
}
}
}
}
}

13
src/EventObservers/ObserverTrait.php
View File

@ -1,8 +1,7 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\EventObservers;
trait ObserverTrait
{
/** @var callable[] */
@ -11,17 +10,17 @@ trait ObserverTrait
public static function addSubscriber($clientId, callable $callback): void
{
notice("Add event listener. ClientId: {$clientId}");
static::$subscribers[$clientId] = $callback;
self::$subscribers[$clientId] = $callback;
}
public static function removeSubscriber($clientId): void
{
notice("Removing listener: {$clientId}");
unset(static::$subscribers[$clientId]);
$listenersCount = count(static::$subscribers);
unset(self::$subscribers[$clientId]);
$listenersCount = \count(self::$subscribers);
notice("Event listeners left: {$listenersCount}");
if ($listenersCount === 0) {
static::$subscribers = [];
self::$subscribers = [];
}
}
}
}

6
src/Exceptions/NoMediaException.php
View File

@ -1,8 +1,8 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Exceptions;
class NoMediaException extends NoticeException
final class NoMediaException extends NoticeException
{
}
}

4
src/Exceptions/NoticeException.php
View File

@ -1,4 +1,4 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Exceptions;
@ -7,4 +7,4 @@ use Exception;
class NoticeException extends Exception
{
}
}

53
src/Files.php
View File

@ -1,10 +1,10 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer;
use RuntimeException;
class Files
final class Files
{
public const SESSION_EXTENSION = '.madeline';
@ -13,11 +13,11 @@ class Files
public static function checkOrCreateSessionFolder(string $session): void
{
$directory = dirname($session);
if ($directory && $directory !== '.' && !is_dir($directory)) {
$parentDirectoryPermissions = fileperms(ROOT_DIR);
if (!mkdir($directory, $parentDirectoryPermissions, true) && !is_dir($directory)) {
throw new RuntimeException(sprintf('Directory "%s" was not created', $directory));
$directory = \dirname($session);
if ($directory && $directory !== '.' && !\is_dir($directory)) {
$parentDirectoryPermissions = \fileperms(ROOT_DIR);
if (!\mkdir($directory, $parentDirectoryPermissions, true) && !\is_dir($directory)) {
throw new RuntimeException(\sprintf('Directory "%s" was not created', $directory));
}
}
}
@ -28,8 +28,8 @@ class Files
return null;
}
preg_match(
'~' . static::SESSION_FOLDER . "/(?'sessionName'.*?)" . static::SESSION_EXTENSION . '~',
\preg_match(
'~' . self::SESSION_FOLDER . "/(?'sessionName'.*?)" . self::SESSION_EXTENSION . '~',
$sessionFile,
$matches
);
@ -37,31 +37,24 @@ class Files
return $matches['sessionName'] ?? null;
}
/**
* @param string|null $session
*
* @param string $extension
*
* @return string|null
*/
public static function getSessionFile(?string $session, string $extension = self::SESSION_EXTENSION): ?string
{
if (!$session) {
return null;
}
$session = trim(trim($session), '/');
$session = static::SESSION_FOLDER . '/' . $session . $extension;
$session = str_replace('//', '/', $session);
$session = \trim(\trim($session), '/');
$session = self::SESSION_FOLDER . '/' . $session . $extension;
$session = \str_replace('//', '/', $session);
return $session;
}
public static function getSessionSettings(string $session): array
{
$settingsFile = static::getSessionFile($session, static::SETTINGS_EXTENSION);
$settingsFile = self::getSessionFile($session, self::SETTINGS_EXTENSION);
$settings = [];
if (file_exists($settingsFile)) {
$settings = json_decode(
file_get_contents($settingsFile),
if (\file_exists($settingsFile)) {
$settings = \json_decode(
\file_get_contents($settingsFile),
true,
10,
JSON_THROW_ON_ERROR
@ -73,10 +66,10 @@ class Files
public static function saveSessionSettings(string $session, array $settings = []): void
{
$settingsFile = static::getSessionFile($session, static::SETTINGS_EXTENSION);
file_put_contents(
$settingsFile = self::getSessionFile($session, self::SETTINGS_EXTENSION);
\file_put_contents(
$settingsFile,
json_encode(
\json_encode(
$settings,
JSON_THROW_ON_ERROR |
JSON_INVALID_UTF8_SUBSTITUTE |
@ -89,11 +82,11 @@ class Files
public static function globRecursive($pattern, $flags = 0): array
{
$files = glob($pattern, $flags) ?: [];
foreach (glob(dirname($pattern) . '/*', GLOB_ONLYDIR | GLOB_NOSORT) as $dir) {
$files = [...$files, ...static::globRecursive($dir . '/' . basename($pattern), $flags)];
$files = \glob($pattern, $flags) ?: [];
foreach (\glob(\dirname($pattern) . '/*', GLOB_ONLYDIR | GLOB_NOSORT) as $dir) {
$files = [...$files, ...self::globRecursive($dir . '/' . \basename($pattern), $flags)];
}
return $files;
}
}
}

108
src/Logger.php
View File

@ -1,4 +1,4 @@
<?php
<?php declare(strict_types=1);
/*
* This file is part of the Symfony package.
@ -11,6 +11,8 @@
namespace TelegramApiServer;
use Amp\ByteStream\Pipe;
use Amp\ByteStream\WritableStream;
use danog\MadelineProto;
use DateTimeInterface;
use Psr\Log\AbstractLogger;
@ -18,17 +20,18 @@ use Psr\Log\InvalidArgumentException;
use Psr\Log\LogLevel;
use TelegramApiServer\EventObservers\LogObserver;
use Throwable;
use function get_class;
use function gettype;
use function is_object;
use const PHP_EOL;
use function Amp\async;
use function Amp\ByteStream\getStdout;
use function Amp\ByteStream\pipe;
/**
* Minimalist PSR-3 logger designed to write in stderr or any other stream.
*
* @author Kévin Dunglas <dunglas@gmail.com>
*/
class Logger extends AbstractLogger
final class Logger extends AbstractLogger
{
private static ?Logger $instanse = null;
@ -54,13 +57,19 @@ class Logger extends AbstractLogger
private static string $dateTimeFormat = 'Y-m-d H:i:s';
public int $minLevelIndex;
private array $formatter;
private \Closure $formatter;
protected function __construct(string $minLevel = LogLevel::WARNING, callable $formatter = null)
private WritableStream $stdout;
/**
* @var array<int, list{WritableStream, \Amp\Future}>
*/
private static array $closePromises = [];
protected function __construct(string $minLevel = LogLevel::WARNING, ?\Closure $formatter = null)
{
if (null === $minLevel) {
if (isset($_ENV['SHELL_VERBOSITY']) || isset($_SERVER['SHELL_VERBOSITY'])) {
switch ((int)(isset($_ENV['SHELL_VERBOSITY']) ? $_ENV['SHELL_VERBOSITY'] :
switch ((int) (isset($_ENV['SHELL_VERBOSITY']) ? $_ENV['SHELL_VERBOSITY'] :
$_SERVER['SHELL_VERBOSITY'])) {
case -1:
$minLevel = LogLevel::ERROR;
@ -79,23 +88,34 @@ class Logger extends AbstractLogger
}
if (!isset(self::$levels[$minLevel])) {
throw new InvalidArgumentException(sprintf('The log level "%s" does not exist.', $minLevel));
throw new InvalidArgumentException(\sprintf('The log level "%s" does not exist.', $minLevel));
}
$this->minLevelIndex = self::$levels[$minLevel];
$this->formatter = $formatter ?: [$this, 'format'];
$this->minLevelIndex = \min(self::$levels[$minLevel], self::$levels[self::$madelineLevels[MadelineProto\Logger::VERBOSE]]);
$this->formatter = $formatter ?: $this->format(...);
$pipe = new Pipe(PHP_INT_MAX);
$this->stdout = $pipe->getSink();
$source = $pipe->getSource();
$promise = async(static function () use ($source, &$promise): void {
try {
pipe($source, getStdout());
} finally {
unset(self::$closePromises[\spl_object_id($promise)]);
}
});
self::$closePromises[\spl_object_id($promise)] = [$this->stdout, $promise];
}
public static function getInstance(): Logger
{
if (!static::$instanse) {
if (!self::$instanse) {
$settings = Config::getInstance()->get('telegram');
$loggerLevel = static::$madelineLevels[$settings['logger']['level']];
static::$instanse = new static($loggerLevel);
$loggerLevel = self::$madelineLevels[$settings['logger']['level']];
self::$instanse = new static($loggerLevel);
}
return static::$instanse;
return self::$instanse;
}
/**
@ -104,7 +124,7 @@ class Logger extends AbstractLogger
public function log($level, $message, array $context = []): void
{
if (!isset(self::$levels[$level])) {
throw new InvalidArgumentException(sprintf('The log level "%s" does not exist.', $level));
throw new InvalidArgumentException(\sprintf('The log level "%s" does not exist.', $level));
}
LogObserver::notify($level, $message, $context);
@ -114,61 +134,77 @@ class Logger extends AbstractLogger
}
$formatter = $this->formatter;
/** @see Logger::format */
echo $formatter($level, $message, $context);
$data = $formatter($level, $message, $context);
;
try {
$this->stdout->write($data);
} catch (\Throwable) {
echo $data;
}
}
/**
* @internal Internal function used to flush the log buffer on shutdown.
*/
public static function finalize(): void
{
foreach (self::$closePromises as [$stdout, $promise]) {
$stdout->close();
$promise->await();
}
}
private function format(string $level, string $message, array $context): string
{
if (false !== strpos($message, '{')) {
if (false !== \strpos($message, '{')) {
$replacements = [];
foreach ($context as $key => $val) {
if ($val instanceof Throwable) {
$context[$key] = self::getExceptionAsArray($val);
}
if (null === $val || is_scalar($val) || (is_object($val) && method_exists($val, '__toString'))) {
if (null === $val || \is_scalar($val) || (\is_object($val) && \method_exists($val, '__toString'))) {
$replacements["{{$key}}"] = $val;
} else {
if ($val instanceof DateTimeInterface) {
$replacements["{{$key}}"] = $val->format(static::$dateTimeFormat);
$replacements["{{$key}}"] = $val->format(self::$dateTimeFormat);
} else {
if (is_object($val)) {
$replacements["{{$key}}"] = '[object ' . get_class($val) . ']';
if (\is_object($val)) {
$replacements["{{$key}}"] = '[object ' . \get_class($val) . ']';
} else {
$replacements["{{$key}}"] = '[' . gettype($val) . ']';
$replacements["{{$key}}"] = '[' . \gettype($val) . ']';
}
}
}
}
$message = strtr($message, $replacements);
$message = \strtr($message, $replacements);
}
return sprintf(
'[%s] [%s] %s %s',
date(static::$dateTimeFormat),
$level,
$message,
$context ?
return \sprintf(
'[%s] [%s] %s %s',
\date(self::$dateTimeFormat),
$level,
$message,
$context ?
"\n" .
json_encode(
\json_encode(
$context,
JSON_UNESCAPED_UNICODE | JSON_INVALID_UTF8_SUBSTITUTE | JSON_PRETTY_PRINT | JSON_UNESCAPED_LINE_TERMINATORS | JSON_UNESCAPED_SLASHES
)
: ''
) . PHP_EOL;
) . PHP_EOL;
}
public static function getExceptionAsArray(Throwable $exception)
{
return [
'exception' => get_class($exception),
'exception' => \get_class($exception),
'message' => $exception->getMessage(),
'file' => $exception->getFile(),
'line' => $exception->getLine(),
'code' => $exception->getCode(),
'backtrace' => array_slice($exception->getTrace(), 0, 3),
'backtrace' => \array_slice($exception->getTrace(), 0, 3),
'previous exception' => $exception->getPrevious(),
];
}
}
}

71
src/MadelineProtoExtensions/ApiExtensions.php
View File

@ -1,9 +1,7 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\MadelineProtoExtensions;
use Amp\Http\Server\FormParser\StreamedField;
use Amp\Http\Server\Request;
use Amp\Http\Server\Response;
@ -15,7 +13,7 @@ use TelegramApiServer\EventObservers\EventHandler;
use TelegramApiServer\Exceptions\NoMediaException;
use function Amp\delay;
class ApiExtensions
final class ApiExtensions
{
private MadelineProto\Api $madelineProto;
@ -43,12 +41,9 @@ class ApiExtensions
}
/**
* Проверяет есть ли подходящие медиа у сообщения
* Проверяет есть ли подходящие медиа у сообщения.
*
* @param array $message
* @param bool $allowWebPage
*
* @return bool
*/
private static function hasMedia(array $message = [], bool $allowWebPage = false): bool
{
@ -90,13 +85,13 @@ class ApiExtensions
$text = StrTools::mbSubstr($message, $entity['offset'], $entity['length']);
$template = $html[$entity['_']];
if (in_array($entity['_'], ['messageEntityTextUrl', 'messageEntityMention', 'messageEntityUrl'])) {
$textFormated = sprintf($template, strip_tags($entity['url'] ?? $text), $text);
if (\in_array($entity['_'], ['messageEntityTextUrl', 'messageEntityMention', 'messageEntityUrl'])) {
$textFormated = \sprintf($template, \strip_tags($entity['url'] ?? $text), $text);
} else {
$textFormated = sprintf($template, $text);
$textFormated = \sprintf($template, $text);
}
$message = static::substringReplace($message, $textFormated, $entity['offset'], $entity['length']);
$message = self::substringReplace($message, $textFormated, $entity['offset'], $entity['length']);
//Увеличим оффсеты всех следующих entity
foreach ($entities as $nextKey => &$nextEntity) {
@ -105,7 +100,7 @@ class ApiExtensions
}
if ($nextEntity['offset'] < ($entity['offset'] + $entity['length'])) {
$nextEntity['offset'] += StrTools::mbStrlen(
preg_replace('~(\>).*<\/.*$~', '$1', $textFormated)
\preg_replace('~(\>).*<\/.*$~', '$1', $textFormated)
);
} else {
$nextEntity['offset'] += StrTools::mbStrlen($textFormated) - StrTools::mbStrlen($text);
@ -115,7 +110,7 @@ class ApiExtensions
}
}
unset($entity);
$message = nl2br($message);
$message = \nl2br($message);
return $message;
}
@ -127,7 +122,7 @@ class ApiExtensions
}
/**
* Пересылает сообщения без ссылки на оригинал
* Пересылает сообщения без ссылки на оригинал.
*
* @param array $data
* <pre>
@ -141,7 +136,7 @@ class ApiExtensions
*/
public function copyMessages(array $data)
{
$data = array_merge(
$data = \array_merge(
[
'from_peer' => '',
'to_peer' => '',
@ -157,7 +152,7 @@ class ApiExtensions
]
);
$result = [];
if (!$response || !is_array($response) || !array_key_exists('messages', $response)) {
if (!$response || !\is_array($response) || !\array_key_exists('messages', $response)) {
return $result;
}
@ -167,14 +162,14 @@ class ApiExtensions
'peer' => $data['to_peer'],
'entities' => $message['entities'] ?? [],
];
if (static::hasMedia($message, false)) {
if (self::hasMedia($message, false)) {
$messageData['media'] = $message; //MadelineProto сама достанет все media из сообщения.
$result[] = $this->madelineProto->messages->sendMedia(...$messageData);
} else {
$result[] = $this->madelineProto->messages->sendMessage(...$messageData);
}
if ($key > 0) {
delay(random_int(300, 2000) / 1000);
delay(\random_int(300, 2000) / 1000);
}
}
@ -182,14 +177,13 @@ class ApiExtensions
}
/**
* Загружает медиафайл из указанного сообщения в поток
* Загружает медиафайл из указанного сообщения в поток.
*
* @param array $data
*
*/
public function getMedia(array $data): Response
{
$data = array_merge(
$data = \array_merge(
[
'peer' => '',
'id' => [0],
@ -203,7 +197,7 @@ class ApiExtensions
throw new NoMediaException('Empty message');
}
if (!static::hasMedia($message, true)) {
if (!self::hasMedia($message, true)) {
throw new NoMediaException('Message has no media');
}
@ -222,17 +216,16 @@ class ApiExtensions
}
}
return $this->downloadToResponse($info);
}
/**
* Загружает превью медиафайла из указанного сообщения в поток
* Загружает превью медиафайла из указанного сообщения в поток.
*
*/
public function getMediaPreview(array $data): Response
{
$data = array_merge(
$data = \array_merge(
[
'peer' => '',
'id' => [0],
@ -246,11 +239,11 @@ class ApiExtensions
throw new NoMediaException('Empty message');
}
if (!static::hasMedia($message, true)) {
if (!self::hasMedia($message, true)) {
throw new NoMediaException('Message has no media');
}
$media = $message['media'][array_key_last($message['media'])];
$media = $message['media'][\array_key_last($message['media'])];
$thumb = null;
switch (true) {
case isset($media['sizes']):
@ -308,15 +301,15 @@ class ApiExtensions
public function getMessages(array $data): array
{
$peerInfo = $this->madelineProto->getInfo($data['peer']);
if (in_array($peerInfo['type'], ['channel', 'supergroup'])) {
if (\in_array($peerInfo['type'], ['channel', 'supergroup'])) {
$response = $this->madelineProto->channels->getMessages(
[
'channel' => $data['peer'],
'id' => (array)$data['id'],
'id' => (array) $data['id'],
]
);
} else {
$response = $this->madelineProto->messages->getMessages(['id' => (array)$data['id']]);
$response = $this->madelineProto->messages->getMessages(['id' => (array) $data['id']]);
}
return $response;
@ -328,7 +321,6 @@ class ApiExtensions
* @param array $info
* Any downloadable array: message, media etc...
*
* @return Response
*/
public function downloadToResponse(array $info): Response
{
@ -336,7 +328,7 @@ class ApiExtensions
}
/**
* Адаптер для стандартного метода
* Адаптер для стандартного метода.
*
*/
public function downloadToBrowser(array $info): Response
@ -361,7 +353,7 @@ class ApiExtensions
$this->file->getMimeType(),
$this->file->getFilename()
);
$inputFile['id'] = unpack('P', $inputFile['id'])['1'];
$inputFile['id'] = \unpack('P', $inputFile['id'])['1'];
return [
'media' => [
'_' => 'inputMediaUploadedDocument',
@ -384,7 +376,6 @@ class ApiExtensions
Client::getWrapper($this->madelineProto)->serialize();
}
public function getUpdates(array $params): array
{
foreach ($params as $key => $value) {
@ -410,12 +401,13 @@ class ApiExtensions
Client::getWrapper($this->madelineProto)->serialize();
}
public function unsubscribeFromUpdates(?string $channel = null): array {
public function unsubscribeFromUpdates(?string $channel = null): array
{
$inputChannelId = null;
if ($channel) {
$id = (string) $this->madelineProto->getId($channel);
$inputChannelId = (int)str_replace(['-100', '-'], '', $id);
$inputChannelId = (int) \str_replace(['-100', '-'], '', $id);
if (!$inputChannelId) {
throw new InvalidArgumentException('Invalid id');
}
@ -438,11 +430,10 @@ class ApiExtensions
$counter++;
}
return [
'disabled_update_loops' => $counter,
'current_update_loops' => count(Client::getWrapper($this->madelineProto)->getAPI()->feeders),
'current_update_loops' => \count(Client::getWrapper($this->madelineProto)->getAPI()->feeders),
];
}
}
}

24
src/MadelineProtoExtensions/SystemApiExtensions.php
View File

@ -1,4 +1,4 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\MadelineProtoExtensions;
@ -13,7 +13,7 @@ use function Amp\async;
use function Amp\File\deleteFile;
use function Amp\Future\awaitAll;
class SystemApiExtensions
final class SystemApiExtensions
{
private Client $client;
@ -41,7 +41,7 @@ class SystemApiExtensions
public function addSession(string $session, array $settings = []): array
{
if (!empty($settings['app_info']['api_id'])) {
$settings['app_info']['api_id'] = (int)$settings['app_info']['api_id'];
$settings['app_info']['api_id'] = (int) $settings['app_info']['api_id'];
}
$instance = $this->client->addSession($session, $settings);
@ -75,7 +75,7 @@ class SystemApiExtensions
foreach ($this->client->instances as $session => $instance) {
$authorized = $instance->getAuthorization();
switch ($authorized) {
case API::NOT_LOGGED_IN;
case API::NOT_LOGGED_IN:
$status = 'NOT_LOGGED_IN';
break;
case API::WAITING_CODE:
@ -107,7 +107,7 @@ class SystemApiExtensions
return [
'sessions' => $sessions,
'memory' => $this->bytesToHuman(memory_get_usage(true)),
'memory' => $this->bytesToHuman(\memory_get_usage(true)),
];
}
@ -115,10 +115,10 @@ class SystemApiExtensions
{
$file = Files::getSessionFile($session);
if (is_file($file)) {
if (\is_file($file)) {
$futures = [];
foreach (glob("$file*") as $file) {
$futures[] = async(fn() => deleteFile($file));
foreach (\glob("$file*") as $file) {
$futures[] = async(fn () => deleteFile($file));
}
awaitAll($futures);
} else {
@ -140,7 +140,7 @@ class SystemApiExtensions
public function unlinkSessionSettings($session): string
{
$settings = Files::getSessionFile($session, Files::SETTINGS_EXTENSION);
if (is_file($settings)) {
if (\is_file($settings)) {
deleteFile($settings);
}
@ -149,7 +149,7 @@ class SystemApiExtensions
public function exit(): string
{
EventLoop::defer(static fn() => exit());
EventLoop::defer(static fn () => exit());
return 'ok';
}
@ -159,6 +159,6 @@ class SystemApiExtensions
for ($i = 0; $bytes > 1024; $i++) {
$bytes /= 1024;
}
return round($bytes, 2) . ' ' . $units[$i];
return \round($bytes, 2) . ' ' . $units[$i];
}
}
}

20
src/Migrations/StartUpFixes.php
View File

@ -1,20 +1,14 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Migrations;
class StartUpFixes
use danog\MadelineProto\Magic;
final class StartUpFixes
{
public static function fix(): void
{
define('MADELINE_WORKER_TYPE', 'madeline-ipc');
\define('MADELINE_WORKER_TYPE', 'madeline-ipc');
Magic::$isIpcWorker = true;
}
public static function removeBrokenIpc(string $session): void
{
info('Removing ipc sockets from sessions to fix startup' . PHP_EOL);
foreach (glob(ROOT_DIR . "/$session/*ipc") as $file) {
info("removing: $file");
unlink($file);
}
}
}
}

8
src/Server/AccessLoggerMiddleware.php
View File

@ -1,4 +1,4 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Server;
@ -9,7 +9,7 @@ use Amp\Http\Server\Response;
use Psr\Log\LoggerInterface as PsrLogger;
use Psr\Log\LogLevel;
class AccessLoggerMiddleware implements Middleware
final class AccessLoggerMiddleware implements Middleware
{
public function __construct(
private readonly PsrLogger $logger,
@ -20,7 +20,7 @@ class AccessLoggerMiddleware implements Middleware
{
$method = $request->getMethod();
$uri = (string)$request->getUri();
$uri = (string) $request->getUri();
$protocolVersion = $request->getProtocolVersion();
$remote = Server::getClientIp($request);
@ -58,7 +58,7 @@ class AccessLoggerMiddleware implements Middleware
],
];
$level = $status < 400 ? LogLevel::INFO : LogLevel::NOTICE;
$level = $status < 400 ? LogLevel::DEBUG : LogLevel::INFO;
$this->logger->log(
$level,

26
src/Server/Authorization.php
View File

@ -1,4 +1,4 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Server;
@ -9,7 +9,7 @@ use Amp\Http\Server\RequestHandler;
use Amp\Http\Server\Response;
use TelegramApiServer\Config;
class Authorization implements Middleware
final class Authorization implements Middleware
{
private array $ipWhitelist;
private int $selfIp;
@ -20,8 +20,8 @@ class Authorization implements Middleware
public function __construct()
{
$this->selfIp = ip2long(getHostByName(php_uname('n')));
$this->ipWhitelist = (array)Config::getInstance()->get('api.ip_whitelist', []);
$this->selfIp = \ip2long(\getHostByName(\php_uname('n')));
$this->ipWhitelist = (array) Config::getInstance()->get('api.ip_whitelist', []);
$this->passwords = Config::getInstance()->get('api.passwords', []);
if (!$this->ipWhitelist && !$this->passwords) {
error('API is unprotected! Please specify IP_WHITELIST or PASSWORD in .env.docker');
@ -37,11 +37,11 @@ class Authorization implements Middleware
}
if ($this->passwords) {
$header = (string)$request->getHeader('Authorization');
$header = (string) $request->getHeader('Authorization');
if ($header) {
sscanf($header, "Basic %s", $encodedPassword);
[$username, $password] = explode(':', base64_decode($encodedPassword), 2);
if (array_key_exists($username, $this->passwords) && $this->passwords[$username] === $password) {
\sscanf($header, "Basic %s", $encodedPassword);
[$username, $password] = \explode(':', \base64_decode($encodedPassword), 2);
if (\array_key_exists($username, $this->passwords) && $this->passwords[$username] === $password) {
return $requestHandler->handleRequest($request);
}
}
@ -59,25 +59,25 @@ class Authorization implements Middleware
private function isIpAllowed(string $host): bool
{
if ($this->ipWhitelist && !in_array($host, $this->ipWhitelist, true)) {
if ($this->ipWhitelist && !\in_array($host, $this->ipWhitelist, true)) {
return false;
}
return true;
}
private function isLocal(string $host): bool {
private function isLocal(string $host): bool
{
if ($host === '127.0.0.1' || $host === 'localhost') {
return true;
}
global $options;
if ($options['docker']) {
$isSameNetwork = abs(ip2long($host) - $this->selfIp) < 256;
$isSameNetwork = \abs(\ip2long($host) - $this->selfIp) < 256;
if ($isSameNetwork) {
return true;
}
}
return false;
}
}
}

10
src/Server/ErrorResponses.php
View File

@ -1,24 +1,22 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Server;
use Amp\Http\Server\Response;
use TelegramApiServer\Controllers\AbstractApiController;
class ErrorResponses
final class ErrorResponses
{
/**
* @param int $status
* @param string|array $message
*
* @return Response
*/
public static function get(int $status, $message): Response
{
return new Response(
$status,
AbstractApiController::JSON_HEADER,
json_encode(
\json_encode(
[
'success' => false,
'errors' => [
@ -33,4 +31,4 @@ class ErrorResponses
);
}
}
}

9
src/Server/Router.php
View File

@ -1,12 +1,12 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Server;
use Amp\Http\HttpStatus;
use Amp\Http\Server\ErrorHandler;
use Amp\Http\Server\Request;
use Amp\Http\Server\RequestHandler\ClosureRequestHandler;
use Amp\Http\Server\SocketHttpServer;
use Amp\Http\HttpStatus;
use TelegramApiServer\Controllers\ApiController;
use TelegramApiServer\Controllers\EventsController;
use TelegramApiServer\Controllers\LogController;
@ -16,7 +16,7 @@ use TelegramApiServer\MadelineProtoExtensions\ApiExtensions;
use TelegramApiServer\MadelineProtoExtensions\SystemApiExtensions;
use function Amp\Http\Server\Middleware\stackMiddleware;
class Router
final class Router
{
private \Amp\Http\Server\Router $router;
private SocketHttpServer $server;
@ -70,5 +70,4 @@ class Router
$this->router->addRoute('GET', '/log/{level:.*?[^/]}[/]', $logHandler);
}
}
}

37
src/Server/Server.php
View File

@ -1,4 +1,4 @@
<?php
<?php declare(strict_types=1);
namespace TelegramApiServer\Server;
@ -14,17 +14,14 @@ use Revolt\EventLoop;
use TelegramApiServer\Client;
use TelegramApiServer\Config;
use TelegramApiServer\Logger;
use function sprintf;
use const SIGINT;
use const SIGTERM;
class Server
final class Server
{
/**
* Server constructor.
*
* @param array $options
* @param array|null $sessionFiles
*/
public function __construct(array $options, ?array $sessionFiles)
{
@ -51,7 +48,6 @@ class Server
}
/**
* Stop the server gracefully when SIGINT is received.
* This is technically optional, but it is best to call Server::stop().
@ -60,29 +56,28 @@ class Server
*/
private static function registerShutdown(SocketHttpServer $server)
{
if (defined('SIGINT')) {
if (\defined('SIGINT')) {
// Await SIGINT or SIGTERM to be received.
$signal = Amp\trapSignal([SIGINT, SIGTERM]);
info(sprintf("Received signal %d, stopping HTTP server", $signal));
info(\sprintf("Received signal %d, stopping HTTP server", $signal));
$server->stop();
} else {
EventLoop::run();
info("Stopping http server");
$server->stop();
}
Logger::finalize();
}
/**
* Установить конфигурацию для http-сервера
* Установить конфигурацию для http-сервера.
*
* @param array $config
* @return array
*/
private function getConfig(array $config = []): array
{
$config = array_filter($config);
$config = \array_filter($config);
$config = array_merge(
$config = \array_merge(
Config::getInstance()->get('server', []),
$config
);
@ -96,18 +91,18 @@ class Server
if ($realIpHeader) {
$remote = $request->getHeader($realIpHeader);
if (!$remote) {
GOTO DIRECT;
goto DIRECT;
}
$tmp = explode(',', $remote);
$remote = trim(end($tmp));
$tmp = \explode(',', $remote);
$remote = \trim(\end($tmp));
} else {
DIRECT:
$remote = $request->getClient()->getRemoteAddress()->toString();
$hostArray = explode(':', $remote);
if (count($hostArray) >= 2) {
$port = (int)array_pop($hostArray);
$hostArray = \explode(':', $remote);
if (\count($hostArray) >= 2) {
$port = (int) \array_pop($hostArray);
if ($port > 0 && $port <= 65353) {
$remote = implode(':', $hostArray);
$remote = \implode(':', $hostArray);
}
}
@ -116,4 +111,4 @@ class Server
return $remote;
}
}
}