ONE PIECE HACKING

Ngiler SH3LL 360
: / home / tbf / membrubackend / app / Managers /

Information Server
MySQL : OFF Perl : OFF CURL : ON WGET : OFF PKEXEC : OFF

Directive	Local Value
IP Address	89.40.16.97
System	Linux server.atelieruldeit.ro 3.10.0-1160.el7.x86_64 #1 SMP Mon Oct 19 16:18:59 UTC 2020 x86_64
User	tbf
PHP Version	7.3.33
Software	Apache
Doc root	Writable

Edit File : WebSocketManager.php \| Size : 3.72 KB
<?php namespace App\Managers; use App\Exceptions\WebsocketException; use App\Models\WebsocketLog; use App\Services\IoServerWebsocket; use App\Services\WebSocketClientService; use App\Services\WebSocketServerService; use Exception; use Ratchet\Http\HttpServer; use Ratchet\WebSocket\WsServer; use React\EventLoop\Factory; use React\Socket\SecureServer; use React\Socket\Server; use RuntimeException; class WebSocketManager { /** * Start and maintain the websocket / public static function startWebSocket(): string { // ping the websocket, if it responds, no need to start it if (self::isWebSocketAlive()) { WebsocketLog::create([ 'action' => 'The websocket is already started, no need to start it again now', ]); return 'The websocket is already started, no need to start it again now'; } $crtFilePath = config('app.ws_tls_crt'); $keyFilePath = config('app.ws_tls_key'); try { if (!empty($crtFilePath)) { WebsocketLog::create([ 'action' => 'Starting WebSocket TLS server', ]); $loop = Factory::create(); // Set up our WebSocket server for clients wanting real-time updates $webSock = new Server('0.0.0.0:' . config('app.ws_port'), $loop); $webSock = new SecureServer($webSock, $loop, [ 'local_cert' => __DIR__ . '/../../resources/ssl/' . $crtFilePath, // path to your cert 'local_pk' => __DIR__ . '/../../resources/ssl/' . $keyFilePath, // path to your server private key 'allow_self_signed' => TRUE, // Allow self signed certs (should be false in production) 'verify_peer' => FALSE ]); $server = new IoServerWebsocket( new HttpServer( new WsServer( new WebSocketServerService() ) ), $webSock, $loop ); } else { WebsocketLog::create([ 'action' => 'Starting WebSocket TCP server', ]); $server = IoServerWebsocket::factory( new HttpServer( new WsServer( new WebSocketServerService() ) ), config('app.ws_port'), config('app.ws_host') ); } } catch (RuntimeException $e) { WebsocketLog::create([ 'action' => 'ERROR! WebSocket runtime exception -> '.$e->getMessage(), ]); return 'ERROR! WebSocket runtime exception -> '.$e->getMessage(); } try { $server->run(); } catch (WebsocketException $e) { WebsocketLog::create([ 'action' => 'ERROR! WebSocket exception -> '.$e->getMessage(), ]); return 'ERROR! WebSocket exception -> '.$e->getMessage(); } catch (Exception $e) { WebsocketLog::create([ 'action' => 'ERROR! -> '.$e->getMessage(), ]); return 'ERROR! -> '.$e->getMessage(); } return ''; } /* * Ping the websocket to see if its started * * @return bool */ public static function isWebSocketALive(): bool { $returnMessage = (new WebSocketClientService())->connectAndSendData(config('app.ws_host'), config('app.ws_port'), [ 'action' => 'ping', ]); if (WebSocketServerService::PING_TEXT === $returnMessage) { return true; } return false; } } Back

Edit File : WebSocketManager.php | Size : 3.72 KB

<?php

namespace App\Managers;

use App\Exceptions\WebsocketException;
use App\Models\WebsocketLog;
use App\Services\IoServerWebsocket;
use App\Services\WebSocketClientService;
use App\Services\WebSocketServerService;
use Exception;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use React\EventLoop\Factory;
use React\Socket\SecureServer;
use React\Socket\Server;
use RuntimeException;

class WebSocketManager
{
    /**
     * Start and maintain the websocket
     */
    public static function startWebSocket(): string
    {
        // ping the websocket, if it responds, no need to start it
        if (self::isWebSocketAlive()) {
            WebsocketLog::create([
                'action' => 'The websocket is already started, no need to start it again now',
            ]);

return 'The websocket is already started, no need to start it again now';
        }

$crtFilePath = config('app.ws_tls_crt');
        $keyFilePath = config('app.ws_tls_key');

try {
            if (!empty($crtFilePath)) {
                WebsocketLog::create([
                    'action' => 'Starting WebSocket TLS server',
                ]);

$loop = Factory::create();

// Set up our WebSocket server for clients wanting real-time updates
                $webSock = new Server('0.0.0.0:' . config('app.ws_port'), $loop);
                $webSock = new SecureServer($webSock, $loop, [
                    'local_cert' => __DIR__ . '/../../resources/ssl/' . $crtFilePath, // path to your cert
                    'local_pk' => __DIR__ . '/../../resources/ssl/' . $keyFilePath, // path to your server private key
                    'allow_self_signed' => TRUE, // Allow self signed certs (should be false in production)
                    'verify_peer' => FALSE
                ]);

$server = new IoServerWebsocket(
                    new HttpServer(
                        new WsServer(
                            new WebSocketServerService()
                        )
                    ), $webSock, $loop
                );
            } else {
                WebsocketLog::create([
                    'action' => 'Starting WebSocket TCP server',
                ]);

$server = IoServerWebsocket::factory(
                    new HttpServer(
                        new WsServer(
                            new WebSocketServerService()
                        )
                    ), config('app.ws_port'), config('app.ws_host')
                );
            }
        } catch (RuntimeException $e) {
            WebsocketLog::create([
                'action'    => 'ERROR! WebSocket runtime exception -> '.$e->getMessage(),
            ]);

return 'ERROR! WebSocket runtime exception -> '.$e->getMessage();
        }

try {
            $server->run();
        } catch (WebsocketException $e) {
            WebsocketLog::create([
                'action'    => 'ERROR! WebSocket exception -> '.$e->getMessage(),
            ]);

return 'ERROR! WebSocket exception -> '.$e->getMessage();
        } catch (Exception $e) {
            WebsocketLog::create([
                'action'    => 'ERROR! -> '.$e->getMessage(),
            ]);

return 'ERROR! -> '.$e->getMessage();
        }

return '';
    }

/**
     * Ping the websocket to see if its started
     *
     * @return bool
     */
    public static function isWebSocketALive(): bool
    {
        $returnMessage = (new WebSocketClientService())->connectAndSendData(config('app.ws_host'), config('app.ws_port'), [
            'action'    => 'ping',
        ]);

if (WebSocketServerService::PING_TEXT === $returnMessage) {
            return true;
        }

return false;
    }
}

Back