Как создать приватный чат на symfony?

<?php
namespace OwrBundle\Command;

use Symfony\Component\Console\{Command\Command, Input\InputInterface, Output\OutputInterface};
use Ratchet\{Server\IoServer, Http\HttpServer, WebSocket\WsServer};
use OwrBundle\Sockets\Chat;

class SocketCommand extends Command
{
    protected function configure()
    {
        $this->setName('sockets:start-chat')
            // the short description shown while running "php bin/console list"
            ->setHelp("Starts the chat socket demo")
            // the full command description shown when running the command with
            ->setDescription('Starts the chat socket demo')
        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $output->writeln([
            'Chat socket',// A line
            '============',// Another line
            'Starting chat, open your browser.',// Empty line
        ]);

        $server = IoServer::factory(
            new HttpServer(
                new WsServer(
                    new Chat()
                )
            ),
            8080
        );

        $server->run();
    }
}

<?php
namespace OwrBundle\Sockets;

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class Chat implements MessageComponentInterface {
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($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');

        foreach ($this->clients as $client) {
            if ($from !== $client) {
                // The sender is not the receiver, send to each client connected
                $client->send($msg);
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        // The connection is closed, remove it, as we can no longer send it messages
        $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();
    }
}

Как узнать какой пользователь подключается к чату если тут нету контейнера?

<?php
namespace OwrBundle\Entity;

use Doctrine\ORM\Mapping as ORM;

/**
 * @ORM\Entity
 * @ORM\Table(name="session")
 * @ORM\HasLifecycleCallbacks
 */
class Session
{
    /**
     * @ORM\Id
     * @ORM\GeneratedValue(strategy="AUTO")
     * @ORM\Column(type="integer")
     */
    protected $id;

    /**
     * @ORM\Column(type="string", name="session", unique=true)
     */
    protected $session;

    /**
     * @ORM\ManyToOne(targetEntity="User", inversedBy="session")
     * @ORM\JoinColumn(name="user_id", referencedColumnName="user_id")
     */
    protected $user;

    /**
     * @ORM\Column(type="datetime")
     */
    protected $date;

<?php
namespace OwrBundle\Services;

use OwrBundle\Entity\Session;
use Symfony\Component\Security\Http\Event\InteractiveLoginEvent;
use Doctrine\Common\Persistence\ObjectManager;

class LoginListener
{
    protected $doctrine;
    protected $session;

    public function __construct(ObjectManager $doctrine, $session)
    {
        $this->doctrine = $doctrine;
        $this->session  = $session;
    }

    public function onLogin(InteractiveLoginEvent $event)
    {
        $user = $event->getAuthenticationToken()->getUser();
        $em = $this->doctrine;

        if($user) {
            $session = new Session();
            $session->setSession($this->session->getId());
            $session->setUser($user);
            $em->persist($session);
            $user->addSession($session);
            $em->persist($user);
            $em->flush();

            $em->createQueryBuilder()
                ->delete('OwrBundle:Session', 's')
                ->where('s.date < ?1')
                ->setParameter(1, (new \DateTime(''))->modify('-1 month'))
                ->getQuery()
                ->getResult();
        }
    }
}

public function onOpen(ConnectionInterface $conn) {
        $sessionDB = $this
                        ->em
                        ->getRepository('OwrBundle:Session')
                        ->findOneBy([
                            'session' => $conn->Session->getId()
                        ]);

        if ($sessionDB && $user = $sessionDB->getUser()) {
            $conn->user = $user->getId();
            $this->connections[ $conn->resourceId ] = $conn;
            $this->relations[ $user->getId() ][] = $conn->resourceId;
            $this->users[ $user->getId() ] = $user;
        } else {
            $conn->close();
        }
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        if (!array_key_exists($from->user, $this->users)) {
            return;
        }
//....
    }