PHPDaemon\Examples\ExamplePubSubWebSocketRoute

Complexity

Total Complexity

4

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	onFrame()	0	15	2
A	sendObject()	0	4	1
A	onFinish()	0	4	1

<?php
namespace PHPDaemon\Examples;

class ExamplePubSubWebSocketRoute extends ExampleWebSocketRoute
{
    use \PHPDaemon\Traits\StaticObjectWatchdog;

    /**
     * Called when new frame received.
     * @param string  Frame's contents.
     * @param integer Frame's type.
     * @return void
     */
    public function onFrame($data, $type)
    {
        $ws = $this;
        $req = json_decode($data, true);
        if ($req['type'] === 'subscribe') {
            $eventName = $req['event'];
            $this->appInstance->pubsub->sub($req['event'], $this, function ($data) use ($ws, $eventName) {

The property pubsub does not seem to exist in PHPDaemon\Core\AppInstance.

                $ws->sendObject([
                    'type' => 'event',
                    'event' => $eventName,
                    'data' => $data,
                ]);
            });
        }
    }

    public function sendObject($obj)
    {
        $this->client->sendFrame(json_encode($obj), 'STRING');
    }

    public function onFinish()
    {
        $this->appInstance->pubsub->unsubFromAll($this);

The property pubsub does not seem to exist in PHPDaemon\Core\AppInstance.

    }
}