BZIon\Command\ServerCommand::execute()

Complexity

Conditions	4
Paths	5

Size

Total Lines	52
Code Lines	29

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        // Make sure that websockets are enabled in the config so that the proper
        // session storage handler is used
        if (!$this->getContainer()->getParameter('bzion.features.websocket.enabled')) {
            $message = "You need to enable websockets in your config before using the push server";
            $output->writeln("<bg=red;options=bold>\n\n [ERROR] $message\n</>");

            return;
        }

        $loop = EventLoopFactory::create();
        $pusher = new EventPusher($loop, $output);

        $pushPort = ($input->getOption('push')) ?: $this->getContainer()
            ->getParameter('bzion.features.websocket.push_port');

        $pullPort = ($input->getOption('pull')) ?: $this->getContainer()
            ->getParameter('bzion.features.websocket.pull_port');

        $pullSocket = new Server($loop);
        $pullSocket->on('connection', function ($conn) use ($pusher) {
            $conn->on('data', function ($data) use ($pusher) {
                $pusher->onServerEvent(json_decode($data));
            });
        });

        // Bind to 127.0.0.1, so that only the server can send messages to the socket
        $pullSocket->listen($pullPort, '127.0.0.1');
        $output->writeln(" <fg=green>Running pull service on port $pullPort</>");

        $session = new SessionProvider(
                $pusher,
                new DatabaseSessionHandler()
            );

        $pushSocket = new Server($loop);

        $webServer = new IoServer(

$webServer is not used, you could remove the assignment.

            new WsServer(
                $session
            ),
            $pushSocket
        );

        // Binding to 0.0.0.0 means remotes can connect
        $pushSocket->listen($pushPort, '0.0.0.0');
        $output->writeln(" <fg=green>Running push service on port $pushPort</>");

        $output->writeln("\n <bg=green;options=bold>Welcome to the BZiON live notification server!</>");
        $loop->run();
    }
}