From e4c486f77b0737214c0c63c1e1e34619c5b9fdd5 Mon Sep 17 00:00:00 2001
From: Matt Bonneau <matt@bonneau.net>
Date: Wed, 1 Jun 2016 23:02:00 -0400
Subject: [PATCH] Move over Serializer also

---
 src/Serializer/JsonSerializer.php      | 46 ++++++++++++++++++++++++++
 src/Serializer/SerializerInterface.php | 34 +++++++++++++++++++
 2 files changed, 80 insertions(+)
 create mode 100644 src/Serializer/JsonSerializer.php
 create mode 100644 src/Serializer/SerializerInterface.php

diff --git a/src/Serializer/JsonSerializer.php b/src/Serializer/JsonSerializer.php
new file mode 100644
index 0000000..07a033d
--- /dev/null
+++ b/src/Serializer/JsonSerializer.php
@@ -0,0 +1,46 @@
+<?php
+
+namespace Thruway\Serializer;
+
+use Thruway\Exception\DeserializationException;
+use Thruway\Message\Message;
+
+/**
+ * Class JsonSerializer
+ * Serialize and deserialize using JSON methods
+ *
+ * @package Thruway\Serializer
+ */
+class JsonSerializer implements SerializerInterface
+{
+
+    /**
+     * Serialize message
+     *
+     * @param \Thruway\Message\Message $msg
+     * @return string
+     */
+    public function serialize(Message $msg)
+    {
+        return json_encode($msg);
+    }
+
+    /**
+     * Deserialize message
+     *
+     * @param string $serializedData
+     * @return \Thruway\Message\Message
+     * @throws \Thruway\Exception\DeserializationException
+     */
+    public function deserialize($serializedData)
+    {
+        if (null === ($data = @json_decode($serializedData))) {
+            throw new DeserializationException("Error decoding json \"" . $serializedData . "\"");
+        }
+
+        $msg = Message::createMessageFromArray($data);
+
+        return $msg;
+    }
+
+}
diff --git a/src/Serializer/SerializerInterface.php b/src/Serializer/SerializerInterface.php
new file mode 100644
index 0000000..4a4eda4
--- /dev/null
+++ b/src/Serializer/SerializerInterface.php
@@ -0,0 +1,34 @@
+<?php
+
+namespace Thruway\Serializer;
+
+use Thruway\Message\Message;
+
+/**
+ * Interface SerializerInterface
+ *
+ * The serializer is responsible for converting input (specific to the serialization)
+ * into an array and also taking an array and converting it to output
+ *
+ * @package Thruway\Serializer
+ */
+interface SerializerInterface
+{
+
+    /**
+     * Serialize message
+     *
+     * @param \Thruway\Message\Message $msg
+     * @return mixed
+     */
+    public function serialize(Message $msg);
+
+    /**
+     * Deserialize message
+     *
+     * @param mixed $serializedData
+     * @return \Thruway\Message\Message
+     */
+    public function deserialize($serializedData);
+
+}