Merge pull request #36 from Smolevich/35-add-replication

Add new method for ns service
Smolevich · Feb 18, 2024 · 0a13e07 · 0a13e07
2 parents dc21bc7 + 4ab413c
commit 0a13e07
Show file tree

Hide file tree

Showing 2 changed files with 60 additions and 0 deletions.
diff --git a/src/Reindexer/Services/Namespaces.php b/src/Reindexer/Services/Namespaces.php
@@ -219,4 +219,23 @@ public function getMetaDataKey(string $name, string $key): Response
             $this->defaultHeaders
         );
     }
+
+    public function schema(string $name, array $config): Response
+    {
+        $uri = new Uri(
+            sprintf(
+                '/api/%s/db/%s/namespaces/%s/schema',
+                $this->version,
+                $this->getDatabase(),
+                $name
+            )
+        );
+
+        return $this->client->request(
+            'PUT',
+            (string)$uri,
+            json_encode($config),
+            $this->defaultHeaders
+        );
+    }
 }
diff --git a/tests/Feature/Reindexer/ServiceTest.php b/tests/Feature/Reindexer/ServiceTest.php
@@ -5,6 +5,7 @@
 use Reindexer\Client\Api;
 use Reindexer\Entities\Index;
 use Reindexer\Enum\IndexType;
+use Reindexer\Response;
 use Reindexer\Services\Database;
 use Reindexer\Services\Index as ReindexerIndex;
 use Reindexer\Services\Item;
@@ -172,4 +173,44 @@ public function testSetHeaders()
         );
         $this->assertCount(2, $response->getRequestHeaders());
     }
+
+    public function testSchema()
+    {
+        $config = [
+            'type' =>  'namespaces',
+            'namespaces' => [
+                'wal_size' => 5000000
+            ]
+        ];
+        $response = $this->nsService->schema($this->namespaceName, $config);
+        $this->assertSame(
+            [
+                'success' => true,
+                'response_code' => 200,
+                'description' => ''
+            ],
+            $response->getDecodedResponseBody(true)
+        );
+    }
+
+    public function testSetReplication()
+    {
+        $config = [
+            'type' => 'namespaces',
+            'replication' => [
+                'role' => 'master',
+                'cluster_id' => 2,
+                'server_id' =>  0
+            ]
+        ];
+        $this->itemService->setNamespace(urlencode('#config'));
+        $response = $this->itemService->update($config);
+        $this->assertSame(
+            [
+                'updated' => 1,
+                'success' => true,
+            ],
+            $response->getDecodedResponseBody(true)
+        );
+    }
 }