Add websocket pusher

Author: prophet777

DependencyInjection/Configuration.php

@@ -119,13 +119,43 @@ public function getConfigTreeBuilder()
             ->arrayNode('pushers')
                 ->append($this->addZmqNode())
                 ->append($this->addAmqpNode())
+                ->append($this->addWampNode())
                 ->end()
             ->end()
         ->end();
 
         return $treeBuilder;
     }
 
+    protected function addWampNode()
+    {
+        $builder = new TreeBuilder();
+        $node = $builder->root('wamp');
+
+        $node
+            ->addDefaultsIfNotSet()
+            ->children()
+                ->scalarNode('host')
+                    ->example('127.0.0.1')
+                    ->isRequired()
+                    ->cannotBeEmpty()
+                ->end()
+                ->scalarNode('port')
+                    ->example('1337')
+                    ->isRequired()
+                    ->cannotBeEmpty()
+                ->end()
+                ->booleanNode('ssl')
+                    ->defaultValue(false)
+                ->end()
+                ->scalarNode('origin')
+                    ->defaultValue(null)
+                ->end()
+            ->end();
+
+        return $node;
+    }
+
     protected function addZmqNode()
     {
         $builder = new TreeBuilder();

Pusher/AbstractPusher.php

@@ -106,8 +106,8 @@ public function isConnected()
      */
     public function push($data, $routeName, $routeParameters, Array $context = [])
     {
-        $chanel = $this->router->generate($routeName, $routeParameters);
-        $message = new Message($chanel, $data);
+        $channel = $this->router->generate($routeName, $routeParameters);
+        $message = new Message($channel, $data);
 
         return $this->doPush($this->serializer->serialize($message), $context);
     }

Pusher/Message.php

@@ -16,7 +16,7 @@ class Message implements MessageInterface
      */
     public function __construct($topic, $data)
     {
-        $this->name = $topic;
+        $this->topic = $topic;
         $this->data = $data;
     }
 
@@ -25,7 +25,7 @@ public function __construct($topic, $data)
      */
     public function getTopic()
     {
-        return $this->name;
+        return $this->topic;
     }
 
     /**

Pusher/Wamp/WampPusher.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace Gos\Bundle\WebSocketBundle\Pusher\Wamp;
+
+use Gos\Bundle\WebSocketBundle\Pusher\AbstractPusher;
+use Gos\Bundle\WebSocketBundle\Pusher\Serializer\MessageSerializer;
+use Gos\Component\WebSocketClient\Wamp\Client;
+
+class WampPusher extends AbstractPusher
+{
+    /** @var  MessageSerializer */
+    protected $serializer;
+
+    /**
+     * @param MessageSerializer $serializer
+     */
+    public function __construct(MessageSerializer $serializer)
+    {
+        $this->serializer = $serializer;
+    }
+
+    /**
+     * @param string $data
+     * @param array  $context
+     */
+    protected function doPush($data, array $context)
+    {
+        if (false === $this->isConnected()) {
+            $config = $this->getConfig();
+
+            $this->connection = new Client($config['host'], $config['port'], $config['ssl'], $config['origin']);
+            $this->connection->connect('/');
+            $this->setConnected();
+        }
+
+        $message = $this->serializer->deserialize($data);
+
+        $this->connection->publish($message->getTopic(), json_encode($message->getData()));
+    }
+
+    public function close()
+    {
+        if (false === $this->isConnected()) {
+            return;
+        }
+
+        $this->connection->disconnect();
+    }
+}

Resources/config/services/services.yml

@@ -213,6 +213,14 @@ services:
         tags:
             - { name: gos_web_socket.pusher, alias: amqp }
 
+    gos_web_socket.wamp.pusher:
+        parent: gos_web_socket.abstract.pusher
+        class: Gos\Bundle\WebSocketBundle\Pusher\Wamp\WampPusher
+        arguments:
+            - @gos_web_socket.push_message.serializer
+        tags:
+            - { name: gos_web_socket.pusher, alias: wamp }
+
     gos_web_socket.amqp.server_push_handler:
         class: Gos\Bundle\WebSocketBundle\Pusher\Amqp\AmqpServerPushHandler
         arguments:

Resources/docs/Pusher.md

@@ -105,7 +105,27 @@ $pusher->push(['my_data' => 'data'], 'user_notification', ['username' => 'user1'
 **NOTE :** `$context` is optional but you can pass option to publish method like 'routing_key', 'publish_flags' and 'attributes' (**See** : https://github.com/pdezwart/php-amqp/blob/master/amqp_exchange.c#L576) 
 ## Websocket Pusher
 
-**NOTE :** Websocket Pusher is not the most faster and powerfull because he have a lot of overhead.
+**NOTE :** Websocket Pusher is not the most faster and powerful because he have a lot of overhead (Handshake have high cost).
+
+**NOTE 2 :** He call directly `onPublish` method not `onPush` because we use WAMP protocol.
+
+**1. Bundle Configuration**
+
+```yml
+gos_web_socket:
+    pushers:
+        wamp:
+            host: 127.0.0.1
+            port: 1337
+```
+
+**2. Push**
+
+```php
+$pusher = $this->container->get('gos_web_socket.wamp.pusher');
+//push(data, route_name, route_arguments)
+$pusher->push(['my_data' => 'data'], 'user_notification', ['username' => 'user1']);
+```
 
 ## Rely push to your topic