Merge branch 'bugfix/archive-post'

Author: Ruben Schmidmeister

API/src/Commands/Posts/ArchivePostCommand.php

@@ -9,8 +9,9 @@
  */
 namespace Timetabio\API\Commands\Posts
 {
-    use Timetabio\API\DataStore\DataStoreWriter;
     use Timetabio\API\Services\PostService;
+    use Timetabio\Framework\Backends\ElasticBackend;
+    use Timetabio\Framework\ValueObjects\StringDateTime;
 
     class ArchivePostCommand
     {
@@ -20,21 +21,23 @@ class ArchivePostCommand
         private $postService;
 
         /**
-         * @var DataStoreWriter
+         * @var ElasticBackend
          */
-        private $dataStoreWriter;
+        private $elasticBackend;
 
-        public function __construct(PostService $postService, DataStoreWriter $dataStoreWriter)
+        public function __construct(PostService $postService, ElasticBackend $elasticBackend)
         {
             $this->postService = $postService;
-            $this->dataStoreWriter = $dataStoreWriter;
+            $this->elasticBackend = $elasticBackend;
         }
 
         public function execute(string $postId): string
         {
             $archived = $this->postService->archivePost($postId);
 
-            $this->dataStoreWriter->queueTask(new \Timetabio\Library\Tasks\IndexPostTask($postId));
+            $this->elasticBackend->updateDocument('post', $postId, [
+                'archived' => (new StringDateTime($archived))->getTimestamp()
+            ]);
 
             return $archived;
         }

API/src/Commands/Posts/RestorePostCommand.php

@@ -9,8 +9,8 @@
  */
 namespace Timetabio\API\Commands\Posts
 {
-    use Timetabio\API\DataStore\DataStoreWriter;
     use Timetabio\API\Services\PostService;
+    use Timetabio\Framework\Backends\ElasticBackend;
 
     class RestorePostCommand
     {
@@ -20,20 +20,23 @@ class RestorePostCommand
         private $postService;
 
         /**
-         * @var DataStoreWriter
+         * @var ElasticBackend
          */
-        private $dataStoreWriter;
+        private $elasticBackend;
 
-        public function __construct(PostService $postService, DataStoreWriter $dataStoreWriter)
+        public function __construct(PostService $postService, ElasticBackend $elasticBackend)
         {
             $this->postService = $postService;
-            $this->dataStoreWriter = $dataStoreWriter;
+            $this->elasticBackend = $elasticBackend;
         }
 
         public function execute(string $postId): void
         {
             $this->postService->restorePost($postId);
-            $this->dataStoreWriter->queueTask(new \Timetabio\Library\Tasks\IndexPostTask($postId));
+
+            $this->elasticBackend->updateDocument('post', $postId, [
+                'archived' => null
+            ]);
         }
     }
 }

API/src/Factories/CommandFactory.php

@@ -214,15 +214,15 @@ public function createArchivePostCommand(): \Timetabio\API\Commands\Posts\Archiv
         {
             return new \Timetabio\API\Commands\Posts\ArchivePostCommand(
                 $this->getMasterFactory()->createPostService(),
-                $this->getMasterFactory()->createDataStoreWriter()
+                $this->getMasterFactory()->createElasticBackend()
             );
         }
 
         public function createRestorePostCommand(): \Timetabio\API\Commands\Posts\RestorePostCommand
         {
             return new \Timetabio\API\Commands\Posts\RestorePostCommand(
                 $this->getMasterFactory()->createPostService(),
-                $this->getMasterFactory()->createDataStoreWriter()
+                $this->getMasterFactory()->createElasticBackend()
             );
         }
     }

Framework/src/Backends/ElasticBackend.php

@@ -61,6 +61,18 @@ public function indexChildDocument(string $type, string $id, string $parent, arr
             ]);
         }
 
+        public function updateDocument(string $type, string $id, array $updates): array
+        {
+            return $this->client->update([
+                'index' => $this->index,
+                'type' => $type,
+                'id' => $id,
+                'body' => [
+                    'doc' => $updates
+                ]
+            ]);
+        }
+
         public function deleteDocument(string $type, string $id): array
         {
             return $this->client->delete([