WebsocketHandler::onOpen() - Code Metrics - swooletw/laravel-swoole - Measure and Improve Code Quality continuously with Scrutinizer

WebsocketHandler::onOpen() A
last analyzed 2022-04-06 07:13 UTC

↳ Parent: WebsocketHandler

Complexity

Conditions	2
Paths	2

Size

Total Lines	21
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	2
eloc	12
c	1
b	0
f	0
nc	2
nop	2
dl	0
loc	21
rs	9.8666

<?php

namespace SwooleTW\Http\Websocket\SocketIO;

use Illuminate\Http\Request;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\Config;
use Swoole\Websocket\Frame;
use SwooleTW\Http\Server\Facades\Server;
use SwooleTW\Http\Websocket\HandlerContract;

class WebsocketHandler implements HandlerContract
{
    /**
     * "onOpen" listener.
     *
     * @param int $fd
     * @param \Illuminate\Http\Request $request
     *
     * @return bool
     */
    public function onOpen($fd, Request $request)
    {
        if (! $request->input('sid')) {
            $payload = json_encode(
                [
                    'sid' => base64_encode(uniqid()),
                    'upgrades' => [],
                    'pingInterval' => Config::get('swoole_websocket.ping_interval'),
                    'pingTimeout' => Config::get('swoole_websocket.ping_timeout'),
                ]
            );
            $initPayload = Packet::OPEN . $payload;
            $connectPayload = Packet::MESSAGE . Packet::CONNECT;

            App::make(Server::class)->push($fd, $initPayload);
            App::make(Server::class)->push($fd, $connectPayload);

            return true;
        }

        return false;
    }

    /**
     * "onMessage" listener.
     *  only triggered when event handler not found
     *
     * @param \Swoole\Websocket\Frame $frame
     */
    public function onMessage(Frame $frame)
    {
        return;
    }

    /**
     * "onClose" listener.
     *
     * @param int $fd
     * @param int $reactorId
     */
    public function onClose($fd, $reactorId)
    {
        return;
    }
}


1			<?php
2
3			namespace SwooleTW\Http\Websocket\SocketIO;
4
5			use Illuminate\Http\Request;
6			use Illuminate\Support\Facades\App;
7			use Illuminate\Support\Facades\Config;
8			use Swoole\Websocket\Frame;
9			use SwooleTW\Http\Server\Facades\Server;
10			use SwooleTW\Http\Websocket\HandlerContract;
11
12			class WebsocketHandler implements HandlerContract
13			{
14			/**
15			* "onOpen" listener.
16			*
17			* @param int $fd
18			* @param \Illuminate\Http\Request $request
19			*
20			* @return bool
21			*/
22			public function onOpen($fd, Request $request)
23			{
24			if (! $request->input('sid')) {
25			$payload = json_encode(
26			[
27			'sid' => base64_encode(uniqid()),
28			'upgrades' => [],
29			'pingInterval' => Config::get('swoole_websocket.ping_interval'),
30			'pingTimeout' => Config::get('swoole_websocket.ping_timeout'),
31			]
32			);
33			$initPayload = Packet::OPEN . $payload;
34			$connectPayload = Packet::MESSAGE . Packet::CONNECT;
35
36			App::make(Server::class)->push($fd, $initPayload);
37			App::make(Server::class)->push($fd, $connectPayload);
38
39			return true;
40			}
41
42			return false;
43			}
44
45			/**
46			* "onMessage" listener.
47			* only triggered when event handler not found
48			*
49			* @param \Swoole\Websocket\Frame $frame
50			*/
51			public function onMessage(Frame $frame)
52			{
53			return;
54			}
55
56			/**
57			* "onClose" listener.
58			*
59			* @param int $fd
60			* @param int $reactorId
61			*/
62			public function onClose($fd, $reactorId)
63			{
64			return;
65			}
66			}
67

swooletw / laravel-swoole

WebsocketHandler::onOpen() A last analyzed 2022-04-06 07:13 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

WebsocketHandler::onOpen() A
last analyzed 2022-04-06 07:13 UTC