<?php

use Octamp\Server\Connection\Connection;

use Octamp\Server\Server;

use OpenSwoole\WebSocket\Frame;

require_once __DIR__ . '/../vendor/autoload.php';

$websocket = Server::createWebsocketServer('0.0.0.0', 8080, ['worker_num' => 2]);

$server = new Server($websocket);

$server->on('beforeStart', function (Server $server) {

$adapter = new \Octamp\Server\Adapter\RedisAdapter('0.0.0.0', 6379);

$server->setAdapter($adapter);

$server->setGenerator(new \Octamp\Server\Generator\RedisIDGenerator($server, $adapter));

});

$server->on('open', function (Server $server, Connection $connection) {

$connection->send('Welcome');

});

$server->on('message', function (Server $server, Connection $connection, Frame $frame) {

$connections = $server->getConnectionStorage()->getAll();

foreach ($connections as $connection) {

$connection->send($frame->data);

}

});

$server->on('close', function (Server $server, Connection $connection) {

echo 'Connection Closed: ' . $connection->getId() . PHP_EOL;

});

$server->start();