Merge pull request repejota#99 from repejota/feature/yaml_encoder

Feature/yaml encoder

Author: repejota

src/Nats/Encoders/YAMLEncoder.php

@@ -0,0 +1,40 @@
+<?php
+namespace Nats\Encoders;
+
+/**
+ * Class YAMLEncoder
+ *
+ * Encodes and decodes messages in YAML format.
+ *
+ * @package Nats
+ */
+class YAMLEncoder implements Encoder
+{
+
+
+    /**
+     * Encodes a message to YAML.
+     *
+     * @param string $payload Message to decode.
+     *
+     * @return mixed
+     */
+    public function encode($payload)
+    {
+        $payload = yaml_emit($payload);
+        return $payload;
+    }
+
+    /**
+     * Decodes a message from YAML.
+     *
+     * @param string $payload Message to decode.
+     *
+     * @return mixed
+     */
+    public function decode($payload)
+    {
+        $payload = yaml_parse($payload);
+        return $payload;
+    }
+}

test/EncodedConnectionTest.php

@@ -2,8 +2,8 @@
 namespace Nats\tests\Unit;
 
 use Nats;
+use Nats\Connection;
 use Nats\ConnectionOptions;
-use Nats\EncodedConnection;
 use Nats\Encoders\JSONEncoder;
 
 /**
@@ -29,7 +29,7 @@ public function setUp()
     {
         $encoder = new JSONEncoder();
         $options = new ConnectionOptions();
-        $this->c = new EncodedConnection($options, $encoder);
+        $this->c = new Connection($options, $encoder);
         $this->c->connect();
     }
 
@@ -88,30 +88,4 @@ function ($res) {
             }
         );
     }
-
-    /**
-     * Test Request command.
-     *
-     * @return void
-     */
-    public function testRequestArray()
-    {
-        $this->c->subscribe(
-            'sayhello',
-            function ($res) {
-                $res->reply('Hello, '.$res->getBody()[1].' !!!');
-            }
-        );
-
-        $this->c->request(
-            'sayhello',
-            [
-             'foo',
-             'McFly',
-            ],
-            function ($res) {
-                $this->assertEquals('Hello, McFly !!!', $res->getBody());
-            }
-        );
-    }
 }

test/JSONEncoderTest.php

@@ -0,0 +1,61 @@
+<?php
+namespace Nats\tests\Unit;
+
+use Nats;
+use Nats\ConnectionOptions;
+use Nats\EncodedConnection;
+use Nats\Encoders\JSONEncoder;
+
+/**
+ * Class JSONEncoderTest.
+ */
+class JSONEncoderTest extends \PHPUnit_Framework_TestCase
+{
+
+    /**
+     * Client.
+     *
+     * @var Nats\Connection Client
+     */
+    private $c;
+
+
+    /**
+     * SetUp test suite.
+     *
+     * @return void
+     */
+    public function setUp()
+    {
+        $encoder = new JSONEncoder();
+        $options = new ConnectionOptions();
+        $this->c = new EncodedConnection($options, $encoder);
+        $this->c->connect();
+    }
+
+    /**
+     * Test Request command.
+     *
+     * @return void
+     */
+    public function testRequestArray()
+    {
+        $this->c->subscribe(
+            'sayhello',
+            function ($res) {
+                $res->reply('Hello, '.$res->getBody()[1].' !!!');
+            }
+        );
+
+        $this->c->request(
+            'sayhello',
+            [
+             'foo',
+             'McFly',
+            ],
+            function ($res) {
+                $this->assertEquals('Hello, McFly !!!', $res->getBody());
+            }
+        );
+    }
+}

test/YAMLEncoderTest.php

@@ -0,0 +1,65 @@
+<?php
+namespace Nats\tests\Unit;
+
+use Nats;
+use Nats\ConnectionOptions;
+use Nats\EncodedConnection;
+use Nats\Encoders\YAMLEncoder;
+
+/**
+ * Class YAMLEncoderTest.
+ */
+class YAMLEncoderTest extends \PHPUnit_Framework_TestCase
+{
+
+    /**
+     * Client.
+     *
+     * @var Nats\Connection Client
+     */
+    private $c;
+
+
+    /**
+     * SetUp test suite.
+     *
+     * @return void
+     */
+    public function setUp()
+    {
+        $encoder = new YAMLEncoder();
+        $options = new ConnectionOptions();
+        $this->c = new EncodedConnection($options, $encoder);
+        $this->c->connect();
+    }
+
+    /**
+     * Test Request command.
+     *
+     * @return void
+     */
+    public function testRequestArray()
+    {
+        $this->markTestSkipped(
+            'The YAML extension is not available.'
+        );
+
+        $this->c->subscribe(
+            'sayhello',
+            function ($res) {
+                $res->reply('Hello, '.$res->getBody()[1].' !!!');
+            }
+        );
+
+        $this->c->request(
+            'sayhello',
+            [
+             'foo',
+             'McFly',
+            ],
+            function ($res) {
+                $this->assertEquals('Hello, McFly !!!', $res->getBody());
+            }
+        );
+    }
+}