ghostjat / php-darknet

example/react.php

<?php
require __DIR__.'/../vendor/autoload.php';

use Ratchet\MessageComponentInterface;

The type Ratchet\MessageComponentInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Ratchet\ConnectionInterface;

The type Ratchet\ConnectionInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Ratchet\Server\IoServer;

The type Ratchet\Server\IoServer was not found. Maybe you did not declare it correctly or list all dependencies?

use Ratchet\Http\HttpServer;

The type Ratchet\Http\HttpServer was not found. Maybe you did not declare it correctly or list all dependencies?

use Ratchet\WebSocket\WsServer;

The type Ratchet\WebSocket\WsServer was not found. Maybe you did not declare it correctly or list all dependencies?

use darknet\core;

/**
 * Description of react
 *
 * @author ghost
 */
class reactApp implements MessageComponentInterface {
    protected $client, $objDetc;
    
    public function __construct() {
        $this->client = new \SplObjectStorage();
        $this->yolo();
    }

    public function onClose(ConnectionInterface $conn) {
        $this->client->detach($conn);
        echo "Connection closed for CID:-> {$conn->resourceId}\n";
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "An Error has occurred: {$e->getMessage()}\n";
        $conn->close();
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        foreach ($this->client as $client) {
            if($from !== $client) {
                if(!is_null($msg)){
                    $this->objDetc->remotePR($client,$msg);
                }
                else {
                    $data = ['id' => $from->resourceId, 'msg' => $msg];
                    $client->send(json_encode($data));
                }
            }
        }
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->client->attach($conn);
        echo "New connection for CID:-> ({$conn->resourceId})\n";
    }
    
    protected function yolo() {
        return $this->objDetc = new core(core::MOBILE_NET_V2_VOC,core::DATA_VOC);
    }

}

$server = IoServer::factory(
	new HttpServer(
		new WsServer(
			new reactApp()
		)
	),8080,'0.0.0.0');
$server->run();