Use ?refresh for immediate updates

timetabio · Jan 11, 2017 · d869121 · d869121
1 parent dcbfd54
commit d869121
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 5 deletions.
diff --git a/API/src/Commands/Posts/ArchivePostCommand.php b/API/src/Commands/Posts/ArchivePostCommand.php
@@ -36,12 +36,14 @@ public function execute(string $postId): string
             $archived = $this->postService->archivePost($postId);
             $timestamp = (new StringDateTime($archived))->getTimestamp();
 
-            $this->elasticBackend->updateDocument('post', $postId, [
+            $document = [
                 'archived' => $timestamp,
                 'meta' => [
                     'delete_timestamp' => $timestamp + 3600 * 24 * 30
                 ]
-            ]);
+            ];
+
+            $this->elasticBackend->updateDocument('post', $postId, $document, true);
 
             return $archived;
         }

diff --git a/API/src/Commands/Posts/RestorePostCommand.php b/API/src/Commands/Posts/RestorePostCommand.php
@@ -41,12 +41,14 @@ public function execute(string $postId): void
         {
             $this->postService->restorePost($postId);
 
-            $this->elasticBackend->updateDocument('post', $postId, [
+            $document = [
                 'archived' => null,
                 'meta' => [
                     'delete_timestamp' => null
                 ]
-            ]);
+            ];
+
+            $this->elasticBackend->updateDocument('post', $postId, $document, true);
 
             $this->dataStoreWriter->queueTask(new \Timetabio\Library\Tasks\IndexPostTask($postId));
         }

diff --git a/Framework/src/Backends/ElasticBackend.php b/Framework/src/Backends/ElasticBackend.php
@@ -61,12 +61,13 @@ public function indexChildDocument(string $type, string $id, string $parent, arr
             ]);
         }
 
-        public function updateDocument(string $type, string $id, array $updates): array
+        public function updateDocument(string $type, string $id, array $updates, bool $refresh = false): array
         {
             return $this->client->update([
                 'index' => $this->index,
                 'type' => $type,
                 'id' => $id,
+                'refresh' => $refresh,
                 'body' => [
                     'doc' => $updates
                 ]