Message to client / public options

[emresaracoglu]

Hello,

There is an opportunity to send a message like an example in the article that. I wonder if it is possible to do this in your project or to combine these two projects?

Thank you again.

[heminei]

Yes, in the theory you can make everything. Your logic should be in the server file. Every client has a unique ID. You can store in DB and in $socket->on("receive".... can check DB and implement your logic

[emresaracoglu]

I made changes based on your suggestions.
Websocket connection run as an without error, but my message does not reach the other user.

Can you check this code below:

WebSocket.php (changed)

$response = $this->hybi10Encode($client, $data, "text", $masked);

to

$response = $this->hybi10Encode($client, json_encode($data), "text", $masked);

Client.php (added)

public $resourceId;

server.php

$socket->setEnableLogging(true);
$socket->on("connect", function (Client $client) use ($socket) {
	// Checks
	if (!$client || !$socket) {
			return false;
		}
		if (empty($client->getPath())) {
			return false;
		}
		if (preg_match("/(\/\?token=)[a-z0-9]*/i", $client->getPath(), $match)) {
			// Variables
			$token = str_replace("/?token=", "", $match[0]) ?: "";
			// Authorize Client
			authorize($client, $token);
			$soStorage = new SplObjectStorage();
			$client_id = new stdClass();
			$soStorage[$client_id] = $client;
		}
	});
	$socket->on("receive", function (\HemiFrame\Lib\WebSocket\Client $client, $data) use ($socket) {
		foreach ($socket->getClientsByPath($client->getPath()) as $item) {
			
			$data = json_decode($data);
			if (isset($data->command)) {
				switch ($data->command) {
					case "subscribe":
						$this->subscriptions[$client->resourceId] = $data->channel;
						break;
					case "groupchat":
						//
						// $client->sendData($item, json_encode($this->subscriptions));
						if (isset($this->subscriptions[$client->resourceId])) {
							$target = $this->subscriptions[$client->resourceId];
							foreach ($this->subscriptions as $id => $channel) {
								if ($channel == $target && $id != $client->resourceId) {
									$this->users[$id]->sendData($item, $data->message);
								}
							}
						}
						break;
					case "message":
						//
						if (isset($this->userresources[$data->to])) {
							foreach ($this->userresources[$data->to] as $key => $resourceId) {
								if (isset($this->users[$resourceId])) {
									$this->users[$resourceId]->sendData($item, $msg);
								}
							}
							$client->sendData($item, json_encode($this->userresources[$data->to]));
						}
						if (isset($this->userresources[$data->from])) {
							foreach ($this->userresources[$data->from] as $key => $resourceId) {
								if (isset($this->users[$resourceId]) && $client->resourceId != $resourceId) {
									$this->users[$resourceId]->sendData($item, $msg);
								}
							}
						}
						break;
					case "register":
						//
						if (isset($data->userId)) {
							if (isset($this->userresources[$data->userId])) {
								if (!in_array($client->resourceId, $this->userresources[$data->userId])) {
									$this->userresources[$data->userId][] = $client->resourceId;
								}
							} else {
								$this->userresources[$data->userId] = [];
								$this->userresources[$data->userId][] = $client->resourceId;
							}
						}
						break;
					default:
						$example = array(
							'methods' => [
								"subscribe" => '{command: "subscribe", channel: "global"}',
								"groupchat" => '{command: "groupchat", message: "hello glob", channel: "global"}',
								"message" => '{command: "message", to: "1", message: "it needs xss protection"}',
								"register" => '{command: "register", userId: 9}',
							],
						);
						$client->sendData($item, json_encode($example));
						break;
				}
			}
		}
	});