*/
require_once('init.php');
use Phem\Core\Collection;
use Phem\Environment\Application;
use Phem\Libraries\MessageBus\MessageBus;
use Ratchet\Http\HttpServer;
use Ratchet\Server\IoServer;
use Ratchet\WebSocket\WsServer;
use React\EventLoop\Factory;
use React\Socket\Server;
$loop = Factory::create();
$msgBus = new MessageBus();
// Listen for the application notifications
$pullerClassName = ROOT_NAMESPACE."\\Libraries\\MessageBus\\"
. WEBSOCKET_PULLER_MODE."Puller";
if (class_exists($pullerClassName))
{
$puller = new $pullerClassName($loop,$msgBus);
$puller->listen(WEBSOCKET_PULLER_BIND_ADDR,WEBSOCKET_PULLER_PORT);
}
else if (strtolower(WEBSOCKET_PULLER_MODE) != "disabled")
{
throw new Exception("Unsupported mode given by WEBSOCKET_PULLER_MODE");
}
// Listen for the websocket connections
$webSock = new Server($loop);
$webSock->listen(WEBSOCKET_PORT, WEBSOCKET_BIND_ADDR);
$server = new IoServer(new HttpServer(new WsServer($msgBus)), $webSock);
// Clear previous application scope user cache
Application::setUsers(new Collection());
$loop->run();
WebSVN
- freenet-router
- Blame
- Rev 2
- /trunk/freenet-router/var/www/freenet-router/socket.run.php
