initial commit

.gitignore

@@ -0,0 +1,3 @@
+.idea
+.DS_Store
+vendor

composer.json

@@ -0,0 +1,19 @@
+{
+    "name": "mannum/eventor",
+    "description": "Simple event-sourcing framework for EventStore.",
+    "keywords": ["event-sourcing"],
+
+    "authors": [
+      {
+        "name": "Alex Haproff",
+        "email": "[email protected]"
+      }
+    ],
+    "require": {
+        "predis/predis": "^1.0",
+        "guzzlehttp/guzzle": "^6.2"
+    },
+    "autoload": {
+        "psr-4": {"Eventor\\": "src/Eventor"}
+    }
+}

src/Eventor/CommandBus.php

@@ -0,0 +1,22 @@
+<?php
+namespace Eventor;
+
+
+class CommandBus implements CommandBusInterface
+{
+    protected $commandHandlers = [];
+
+    public function addCommandHandler($messageName, callable $handler)
+    {
+        $this->commandHandlers[$messageName] = $handler;
+    }
+
+    public function handle($message)
+    {
+        if (empty($message::$name)) return;
+
+        if (empty($this->commandHandlers[$message::$name])) return;
+
+        $this->commandHandlers[$message::$name]($message);
+    }
+}

src/Eventor/CommandBusInterface.php

@@ -0,0 +1,12 @@
+<?php
+namespace Eventor;
+
+
+interface CommandBusInterface
+{
+    /**
+     * @param object $message
+     * @return void
+     */
+    public function handle($message);
+}