Merge pull request #28 from codeliner/update_user_read_table

Update user view on TodoWasMarkedAsDone

Author: Alexander Miertsch

config/prooph.php

@@ -43,6 +43,7 @@
                         ],
                         \Prooph\Proophessor\Model\Todo\Event\TodoWasMarkedAsDone::class => [
                             \Prooph\Proophessor\Projection\Todo\TodoProjector::class,
+                            \Prooph\Proophessor\Projection\User\UserProjector::class,
                         ],
                     ]
                 ]

src/Container/Projection/User/UserProjectorFactory.php

@@ -11,6 +11,7 @@
 namespace Prooph\Proophessor\Container\Projection\User;
 
 use Interop\Container\ContainerInterface;
+use Prooph\Proophessor\Projection\User\UserFinder;
 use Prooph\Proophessor\Projection\User\UserProjector;
 
 /**
@@ -27,6 +28,9 @@ final class UserProjectorFactory
      */
     public function __invoke(ContainerInterface $container)
     {
-        return new UserProjector($container->get('doctrine.connection.default'));
+        return new UserProjector(
+            $container->get('doctrine.connection.default'),
+            $container->get(UserFinder::class)
+        );
     }
 }

src/Projection/User/UserFinder.php

@@ -51,4 +51,20 @@ public function findById($userId)
         $stmt->execute();
         return $stmt->fetch();
     }
+
+    /**
+     * @param $todoId
+     * @return null|\stdClass containing userData
+     */
+    public function findUserOfTodo($todoId)
+    {
+        $stmt = $this->connection->prepare(sprintf(
+            "SELECT u.* FROM %s as u JOIN %s as t ON u.id = t.assignee_id  where t.id = :todo_id",
+            Table::USER,
+            Table::TODO
+        ));
+        $stmt->bindValue('todo_id', $todoId);
+        $stmt->execute();
+        return $stmt->fetch();
+    }
 }

src/Projection/User/UserProjector.php

@@ -10,6 +10,7 @@
  */
 namespace Prooph\Proophessor\Projection\User;
 
+use Prooph\Proophessor\Model\Todo\Event\TodoWasMarkedAsDone;
 use Prooph\Proophessor\Model\Todo\Event\TodoWasPosted;
 use Prooph\Proophessor\Model\User\Event\UserWasRegistered;
 use Prooph\Proophessor\Projection\Table;
@@ -28,12 +29,19 @@ final class UserProjector
      */
     private $connection;
 
+    /**
+     * @var UserFinder
+     */
+    private $userFinder;
+
     /**
      * @param Connection $connection
+     * @param UserFinder $userFinder
      */
-    public function __construct(Connection $connection)
+    public function __construct(Connection $connection, UserFinder $userFinder)
     {
         $this->connection = $connection;
+        $this->userFinder = $userFinder;
     }
 
     /**
@@ -61,4 +69,28 @@ public function onTodoWasPosted(TodoWasPosted $event)
 
         $stmt->execute();
     }
+
+    /**
+     * @param TodoWasMarkedAsDone $event
+     * @throws \RuntimeException if data of the the assigned user can not be found
+     */
+    public function onTodoWasMarkedAsDone(TodoWasMarkedAsDone $event)
+    {
+        $user = $this->userFinder->findUserOfTodo($event->todoId()->toString());
+
+        if (! $user) {
+            throw new \RuntimeException(
+                sprintf(
+                    "Data of the assigned user of the todo %s cannot be found",
+                    $event->todoId()->toString()
+                )
+            );
+        }
+
+        $stmt = $this->connection->prepare(sprintf('UPDATE %s SET open_todos = open_todos - 1, done_todos = done_todos + 1 WHERE id = :assignee_id', Table::USER));
+
+        $stmt->bindValue('assignee_id', $user->id);
+
+        $stmt->execute();
+    }
 }