TelegramApiServer/examples/websocket-events.php

<?php

/**
 * Get all updates from MadelineProto EventHandler running inside TelegramApiServer via websocket
 * @see \TelegramApiServer\Controllers\EventsController
 */

require 'vendor/autoload.php';

use Amp\Websocket\Client\Rfc6455Connection;
use Amp\Websocket\Message;
use function Amp\Websocket\Client\connect;

$shortopts = 'u::';
$longopts = [
    'url::',
];
$options = getopt($shortopts, $longopts);
$options = [
    'url' => $options['url'] ?? $options['u'] ?? 'ws://127.0.0.1:9503/events',
];

Amp\Loop::run(static function () use ($options) {
    echo "Connecting to: {$options['url']}" . PHP_EOL;

    while (true) {
        try {
            /** @var Rfc6455Connection $connection */
            $connection = yield connect($options['url']);

            $connection->onClose(static function () use ($connection) {
                printf("Connection closed. Reason: %s\n", $connection->getCloseReason());
            });

            echo 'Waiting for events...' . PHP_EOL;
            while ($message = yield $connection->receive()) {
                /** @var Message $message */
                $payload = yield $message->buffer();
                printf("[%s] Received event: %s\n", date('Y-m-d H:i:s'), $payload);
            }
        } catch (\Throwable $e) {
            printf("Error: %s\n", $e->getMessage());
        }
        yield new Amp\Delayed(500);
    }

});