Feature/#11

src/Messaging/FQCNMessageFactory.php

@@ -0,0 +1,48 @@
+<?php
+/*
+ * This file is part of the prooph/common.
+ * (c) 2014-2015 prooph software GmbH <contact@prooph.de>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ * 
+ * Date: 7/26/15 - 12:11 AM
+ */
+namespace Prooph\Common\Messaging;
+use Assert\Assertion;
+
+/**
+ * Class FQCNMessageFactory
+ *
+ * @package Prooph\Common\Messaging
+ * @author Alexander Miertsch <kontakt@codeliner.ws>
+ */
+class FQCNMessageFactory implements MessageFactory
+{
+    /**
+     * @param string $messageName
+     * @param array $messageData
+     * @throws \UnexpectedValueException
+     * @return DomainMessage
+     */
+    public function createMessageFromArray($messageName, array $messageData)
+    {
+        if (! class_exists($messageName)) {
+            throw new \UnexpectedValueException('Given message name is not a valid class: ' . (string)$messageName);
+        }
+
+        $ref = new \ReflectionClass($messageName);
+
+        if (!$ref->isSubclassOf(DomainMessage::class)) {
+            throw new \UnexpectedValueException(sprintf(
+                'Message class %s is not a sub class of %s',
+                $messageName,
+                DomainMessage::class
+            ));
+        }
+
+        $messageData['name'] = $messageName;
+
+        return $messageName::fromArray($messageData);
+    }
+}

src/ServiceLocator/ServiceInitializer.php → src/Messaging/MessageFactory.php

@@ -6,22 +6,23 @@
  * For the full copyright and license information, please view the LICENSE
  * file that was distributed with this source code.
  * 
- * Date: 5/9/15 - 9:57 PM
+ * Date: 7/26/15 - 12:08 AM
  */
 
-namespace Prooph\Common\ServiceLocator;
+namespace Prooph\Common\Messaging;
 
 /**
- * Interface ServiceInitializer
+ * Interface MessageFactory
  *
- * @package Prooph\Common\ServiceLocator
+ * @package Prooph\Common\Messaging
  * @author Alexander Miertsch <kontakt@codeliner.ws>
  */
-interface ServiceInitializer 
+interface MessageFactory 
 {
     /**
-     * @param mixed $service
-     * @param ServiceLocator $serviceLocator
+     * @param string $messageName
+     * @param array $messageData
+     * @return DomainMessage
      */
-    public function initialize($service, ServiceLocator $serviceLocator);
+    public function createMessageFromArray($messageName, array $messageData);
 } 

tests/Messaging/FQCNMessageFactoryTest.php

@@ -0,0 +1,58 @@
+<?php
+/*
+ * This file is part of the prooph/common.
+ * (c) 2014-2015 prooph software GmbH <contact@prooph.de>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ * 
+ * Date: 7/26/15 - 12:14 AM
+ */
+namespace ProophTest\Common\Messaging;
+use Prooph\Common\Messaging\FQCNMessageFactory;
+use ProophTest\Common\Mock\DoSomething;
+use Rhumsaa\Uuid\Uuid;
+
+/**
+ * Class FQCNMessageFactoryTest
+ *
+ * @package ProophTest\Common\Messaging
+ * @author Alexander Miertsch <kontakt@codeliner.ws>
+ */
+final class FQCNMessageFactoryTest extends \PHPUnit_Framework_TestCase
+{
+    /**
+     * @var FQCNMessageFactory
+     */
+    private $messageFactory;
+
+    protected function setUp()
+    {
+        $this->messageFactory = new FQCNMessageFactory();
+    }
+
+    /**
+     * @test
+     */
+    function it_creates_a_new_message_from_array_and_fqcn()
+    {
+        $uuid = Uuid::uuid4();
+        $createdAt = new \DateTimeImmutable();
+
+
+        $command = $this->messageFactory->createMessageFromArray(DoSomething::class, [
+            'uuid' => $uuid->toString(),
+            'version' => 1,
+            'payload' => ['command' => 'payload'],
+            'metadata' => ['command' => 'metadata'],
+            'created_at' => $createdAt->format(\DateTime::ISO8601),
+        ]);
+
+        $this->assertEquals(DoSomething::class, $command->messageName());
+        $this->assertEquals($uuid->toString(), $command->uuid()->toString());
+        $this->assertEquals($createdAt->format(\DateTime::ISO8601), $command->createdAt()->format(\DateTime::ISO8601));
+        $this->assertEquals(1, $command->version());
+        $this->assertEquals(['command' => 'payload'], $command->payload());
+        $this->assertEquals(['command' => 'metadata'], $command->metadata());
+    }
+}