Merge pull request repejota#102 from repejota/feature/101_serialize_encoder

Feature/101 serialize encoder

Author: repejota

src/Nats/Encoders/PHPEncoder.php

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

test/JSONEncoderTest.php test/Encoders/JSONEncoderTest.phptest/JSONEncoderTest.php renamed to test/Encoders/JSONEncoderTest.php

@@ -1,5 +1,5 @@
 <?php
-namespace Nats\tests\Unit;
+namespace Nats\tests\Encoders\Unit;
 
 use Nats;
 use Nats\ConnectionOptions;

test/Encoders/PHPEncoderTest.php

@@ -0,0 +1,61 @@
+<?php
+namespace Nats\tests\Encoders\Unit;
+
+use Nats;
+use Nats\ConnectionOptions;
+use Nats\EncodedConnection;
+use Nats\Encoders\PHPEncoder;
+
+/**
+ * Class PHPEncoderTest.
+ */
+class PHPEncoderTest extends \PHPUnit_Framework_TestCase
+{
+
+    /**
+     * Client.
+     *
+     * @var Nats\Connection Client
+     */
+    private $c;
+
+
+    /**
+     * SetUp test suite.
+     *
+     * @return void
+     */
+    public function setUp()
+    {
+        $encoder = new PHPEncoder();
+        $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 test/Encoders/YAMLEncoderTest.phptest/YAMLEncoderTest.php renamed to test/Encoders/YAMLEncoderTest.php

@@ -1,5 +1,5 @@
 <?php
-namespace Nats\tests\Unit;
+namespace Nats\tests\Encoders\Unit;
 
 use Nats;
 use Nats\ConnectionOptions;