Текущий пользователь в обработчике события

public function handle(OrderWasCancelled $event, Context $context) {
    // $context->getUserId()
}

class ConnectionContext
{
    // everything I need
}

class Connection
{

    public function __construct(RatchetConnectionInterface $ratchetConnection, ConnectionContext $connectionContext)
    {
        $this->conn = $ratchetConnection;
        $this->setContext($connectionContext);
    }

    ....
}

class ConnectionsRegistry
{

    /**
     * @var \SplObjectStorage
     */
    private $connections;

    /**
     * @param RatchetConnectionInterface $conn
     * @param ConnectionContext $connectionContext
     */
    public function registerConnection(RatchetConnectionInterface $conn, ConnectionContext $connectionContext)
    {
        $this->connections->attach($conn, new Connection($conn, $connectionContext));
    }

    /**
     * @param RatchetConnectionInterface $conn
     */
    public function unregisterConnection(RatchetConnectionInterface $conn)
    {
        $connection = $this->find($conn);
        if ($connection) {
            $connection->close();
        }
        $this->connections->detach($conn);
    }

    /**
     * @param RatchetConnectionInterface $conn
     * @return Connection|null
     */
    public function find(RatchetConnectionInterface $conn)
    {
        if ($this->connections->contains($conn)) {
            return $this->connections->offsetGet($conn);
        } else {
            return null;
        }
    }
}

class ServerController implements MessageComponentInterface
{
    ...
    public function onOpen(RatchetConnectionInterface $ratchetConnection)
    {
        $this->connectionsRegistry->registerConnection($ratchetConnnetion, new ConnectionContext());
    }

    public function onMessage(RatchetConnectionInterface $ratchetConnection, $buffer)
    {
        if (null !== $connection = $this->connectionsRegistry->find($ratchetConnection)) {
            $this->messageRouter->handleMessage($buffer, $connection);
        } else {
            $this->logger->warning(
                'Got a message from an unregistered connection, closing: ' . json_encode((array)$ratchetConnection)
            );
            $conn->close();
        }
    }
    ...
}

...

// ну и где-то там в обработчике action-ов...
$context = $connection->getContext();
$context->associateUser($user);
$context->hasAssociatedUser();
$context->getAssociatedUser();
#etc

public function savePage($request) 
{
    $pages = $this->getEntityManager()->getRepository('pages');
    $page = $this->getEntityManager()->getEntity('pages');
    $page = $this->hydrateFromRequest($request);
    $pages->save($page);
}

'onSave' => function ($entity, $context) {
    if (!$entity->getUser()) {
        $entity->setUser($context->getCurrentUser());
    }
},

public function savePage($request) 
{
    $pages = $this->getEntityManager()->getRepository('pages');
    $page = $this->getEntityManager()->getEntity('pages');
    $page->getEventManager()->setContext($request->getAttribute('context'));
    $page = $this->hydrateFromRequest($request);
    $pages->save($page);
}

public function getEventManager()
{
    if (!$this->eventManager) {
        $this->eventManage = new \EventManager;
    }
  
    return $this->eventManager;
}

// BEGIN TRANSACTION
$user = $this->userRepository->find(...); // SELECT ... FOR UPDATE
$user->doSomething();
$events = $user->getEvents();
$this->userRepository->save($user);
// COMMIT
$this->eventDispatcher->dispatch($events, $context);