Как отправить сообщение конкретному пользователю Ratchet?

Question

[Шлёпа Коммунистка]

Я разрабатываю чат платформу.
В качестве серверной части использую Laravel + библиотеку Ratchet для работы с сокетами.

Когда пользователь октрывает чат, устанавливается соединение по сокетам. Однако, когда собеседник пишет сообщение в чат, то оно отправляется всем остальным, а не конкретному второму собеседнику в чате. (ВАЖНО: чат только 1 на 1)

Я перечитал много туториалов и посмотрел большое количество примеров, однако я все также не понимаю, как мне отправить сообщение конкретному пользователю?
Я сохранию id подключения в отдельном массиве users, но как оттуда выбрать нужного мне пользователя - не могу понять.

Стоит отметить, что в базу данных сообщения приходят правильно, они закреплены за нужными чат комнатами.
Вот мод класс чата:

class ChatSocket extends BaseSocket
{
    protected $clients;
    protected $users;

    public function __construct()
    {
        $this->clients = new \SplObjectStorage();
        $this->users = [];
    }

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients->attach($conn);
        $this->users[$conn->resourceId] = $conn;

        echo "New connection! ({$conn->resourceId})\n";
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        $numRecv = count($this->clients) - 1;

        echo sprintf('Connection %d sending message "%s" to %d other connection%s' . "\n"
            , $from->resourceId, $msg, $numRecv, $numRecv == 1 ? '' : 's');

        $data = json_decode($msg, true, 512, JSON_THROW_ON_ERROR);

//        Save to Database
        $message = new MessageController();
        $responseData = $message->store($data);

        foreach ($this->clients as $client) {
            if ($client === $from) {
                $client->send(json_encode($responseData, JSON_THROW_ON_ERROR));
            }
        }
    }



    public function onClose(ConnectionInterface $conn)
    {
        $this->clients->detach($conn);
        echo "Connection {$conn->resourceId} has disconnected\n";
    }

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

Вот код клиента (очень топорный, в качестве id я отправляю айдишники пользователей (берется из БД).

form.addEventListener('submit', function (e) {
            e.preventDefault();
            
            let data = {
                sender_id: 1,
                to: 2,
                chat_room_id: 1,
                message: this.message.value
            };

            socket.send(JSON.stringify(data));

        })

        socket.onmessage = function(event) {
            let data = JSON.parse(event.data);
            console.log(data);
}

Comments

[Шлёпа Коммунистка]

Я понимаю, что мне нужно что-то вроде такого, однако как получить этот самый $to - не понимаю.

public function onMessage(ConnectionInterface $to, $msg) {
foreach ($this->clients as $client) {
	if ($to== $client) {	
		$client->send();
       }
}
}