working websocket client and server w/o session handling and storage

2016-10-18 15:58:53 +02:00
parent 8578a94caf
commit fbfbe5a13b
9 changed files with 229 additions and 15 deletions
--- a/src/Mine/SeekerBundle/Topic/AcmeTopic.php
+++ b/src/Mine/SeekerBundle/Topic/AcmeTopic.php
@@ -0,0 +1,89 @@
+<?php
+
+namespace Mine\SeekerBundle\Topic;
+
+//use Gos\Bundle\WebSocketBundle\Client\ClientManipulatorInterface;
+use Gos\Bundle\WebSocketBundle\Topic\TopicInterface;
+use Gos\Bundle\WebSocketBundle\Router\WampRequest;
+use Ratchet\ConnectionInterface;
+use Ratchet\Wamp\Topic;
+
+class AcmeTopic implements TopicInterface
+{
+//    protected $clientManipulator;
+//
+//    /**
+//     * @param ClientManipulatorInterface $clientManipulator
+//     */
+//    public function __construct(ClientManipulatorInterface $clientManipulator)
+//    {
+//        $this->clientManipulator = $clientManipulator;
+//    }
+
+    /**
+     * This will receive any Subscription requests for this topic.
+     *
+     * @param ConnectionInterface $connection
+     * @param Topic $topic
+     * @param WampRequest $request
+     * @return void
+     */
+    public function onSubscribe(ConnectionInterface $connection, Topic $topic, WampRequest $request)
+    {
+//        $user = $this->clientManipulator->getClient($connection);
+        $user = "";
+        //this will broadcast the message to ALL subscribers of this topic.
+        $topic->broadcast([
+            'msg' => $connection->resourceId . " has joined " . $topic->getId(),
+            'user' => $user
+        ]);
+    }
+
+    /**
+     * This will receive any UnSubscription requests for this topic.
+     *
+     * @param ConnectionInterface $connection
+     * @param Topic $topic
+     * @param WampRequest $request
+     * @return void
+     */
+    public function onUnSubscribe(ConnectionInterface $connection, Topic $topic, WampRequest $request)
+    {
+        //this will broadcast the message to ALL subscribers of this topic.
+        $topic->broadcast(['msg' => $connection->resourceId . " has left " . $topic->getId()]);
+    }
+
+    /**
+     * This will receive any Publish requests for this topic.
+     *
+     * @param ConnectionInterface $connection
+     * @param Topic $topic
+     * @param WampRequest $request
+     * @param $event
+     * @param array $exclude
+     * @param array $eligible
+     * @return mixed|void
+     * @internal param Topic $Topic
+     * @internal param array $eligibles
+     */
+    public function onPublish(ConnectionInterface $connection, Topic $topic, WampRequest $request, $event, array $exclude, array $eligible)
+    {
+        /*
+            $topic->getId() will contain the FULL requested uri, so you can proceed based on that
+            if ($topic->getId() == "acme/channel/shout")
+               //shout something to all subs.
+        */
+        $topic->broadcast([
+            'msg' => $event
+        ]);
+    }
+
+    /**
+     * Like RPC is will use to prefix the channel
+     * @return string
+     */
+    public function getName()
+    {
+        return 'acme.topic';
+    }
+}