Merge pull request #8 from olekjs/dev-release-v1.7.0

v1.7.0 add crud operations to builder

Author: olekjs

src/Builder/Builder.php

@@ -10,13 +10,18 @@
 use Olekjs\Elasticsearch\Contracts\ClientInterface;
 use Olekjs\Elasticsearch\Dto\BulkResponseDto;
 use Olekjs\Elasticsearch\Dto\FindResponseDto;
+use Olekjs\Elasticsearch\Dto\IndexResponseDto;
 use Olekjs\Elasticsearch\Dto\PaginateResponseDto;
 use Olekjs\Elasticsearch\Dto\SearchResponseDto;
+use Olekjs\Elasticsearch\Exceptions\ConflictResponseException;
 use Olekjs\Elasticsearch\Exceptions\CoreException;
+use Olekjs\Elasticsearch\Exceptions\DeleteResponseException;
 use Olekjs\Elasticsearch\Exceptions\FindResponseException;
 use Olekjs\Elasticsearch\Exceptions\IndexNotFoundResponseException;
+use Olekjs\Elasticsearch\Exceptions\IndexResponseException;
 use Olekjs\Elasticsearch\Exceptions\NotFoundResponseException;
 use Olekjs\Elasticsearch\Exceptions\SearchResponseException;
+use Olekjs\Elasticsearch\Exceptions\UpdateResponseException;
 
 class Builder implements BuilderInterface
 {
@@ -325,6 +330,50 @@ public function bulk(BulkOperationInterface $bulk): BulkResponseDto
         return $this->client->bulk($bulk);
     }
 
+    /**
+     * @throws IndexResponseException
+     */
+    public function create(string|int $id, array $data): IndexResponseDto
+    {
+        if (!isset($this->index)) {
+            throw new LogicException('Index name is required.');
+        }
+
+        return $this->client->create($this->index, $id, $data);
+    }
+
+    /**
+     * @throws NotFoundResponseException
+     * @throws UpdateResponseException
+     * @throws ConflictResponseException
+     */
+    public function update(
+        string|int $id,
+        array $data = [],
+        array $script = [],
+        ?int $primaryTerm = null,
+        ?int $sequenceNumber = null
+    ): IndexResponseDto {
+        if (!isset($this->index)) {
+            throw new LogicException('Index name is required.');
+        }
+
+        return $this->client->update($this->index, $id, $data, $script, $primaryTerm, $sequenceNumber);
+    }
+
+    /**
+     * @throws DeleteResponseException
+     * @throws NotFoundResponseException
+     */
+    public function delete(string|int $id): IndexResponseDto
+    {
+        if (!isset($this->index)) {
+            throw new LogicException('Index name is required.');
+        }
+
+        return $this->client->delete($this->index, $id);
+    }
+
     public function getIndex(): string
     {
         return $this->index;

src/Contracts/BuilderInterface.php

@@ -6,13 +6,18 @@
 use Olekjs\Elasticsearch\Builder\Builder;
 use Olekjs\Elasticsearch\Dto\BulkResponseDto;
 use Olekjs\Elasticsearch\Dto\FindResponseDto;
+use Olekjs\Elasticsearch\Dto\IndexResponseDto;
 use Olekjs\Elasticsearch\Dto\PaginateResponseDto;
 use Olekjs\Elasticsearch\Dto\SearchResponseDto;
+use Olekjs\Elasticsearch\Exceptions\ConflictResponseException;
 use Olekjs\Elasticsearch\Exceptions\CoreException;
+use Olekjs\Elasticsearch\Exceptions\DeleteResponseException;
 use Olekjs\Elasticsearch\Exceptions\FindResponseException;
 use Olekjs\Elasticsearch\Exceptions\IndexNotFoundResponseException;
+use Olekjs\Elasticsearch\Exceptions\IndexResponseException;
 use Olekjs\Elasticsearch\Exceptions\NotFoundResponseException;
 use Olekjs\Elasticsearch\Exceptions\SearchResponseException;
+use Olekjs\Elasticsearch\Exceptions\UpdateResponseException;
 
 interface BuilderInterface
 {
@@ -99,6 +104,30 @@ public function paginate(int $page = 1, int $perPage = 25): PaginateResponseDto;
      */
     public function bulk(BulkOperationInterface $bulk): BulkResponseDto;
 
+    /**
+     * @throws IndexResponseException
+     */
+    public function create(string|int $id, array $data): IndexResponseDto;
+
+    /**
+     * @throws NotFoundResponseException
+     * @throws UpdateResponseException
+     * @throws ConflictResponseException
+     */
+    public function update(
+        string|int $id,
+        array $data = [],
+        array $script = [],
+        ?int $primaryTerm = null,
+        ?int $sequenceNumber = null
+    ): IndexResponseDto;
+
+    /**
+     * @throws DeleteResponseException
+     * @throws NotFoundResponseException
+     */
+    public function delete(string|int $id): IndexResponseDto;
+
     public function getIndex(): string;
 
     public function getBody(): array;

tests/Unit/BuilderTest.php

@@ -8,6 +8,7 @@
 use Olekjs\Elasticsearch\Client;
 use Olekjs\Elasticsearch\Dto\BulkResponseDto;
 use Olekjs\Elasticsearch\Dto\FindResponseDto;
+use Olekjs\Elasticsearch\Dto\IndexResponseDto;
 use Olekjs\Elasticsearch\Dto\PaginateResponseDto;
 use Olekjs\Elasticsearch\Dto\SearchHitsDto;
 use Olekjs\Elasticsearch\Dto\SearchResponseDto;
@@ -515,4 +516,31 @@ public function testBulkMethod(): void
 
         $this->assertInstanceOf(BulkResponseDto::class, $result);
     }
+
+    public function testCreateMethod(): void
+    {
+        $client = $this->getMockBuilder(Client::class)->getMock();
+
+        $result = Builder::query($client)->index('test')->create(1, []);
+
+        $this->assertInstanceOf(IndexResponseDto::class, $result);
+    }
+
+    public function testUpdateMethod(): void
+    {
+        $client = $this->getMockBuilder(Client::class)->getMock();
+
+        $result = Builder::query($client)->index('test')->update(1, ['name' => 'test']);
+
+        $this->assertInstanceOf(IndexResponseDto::class, $result);
+    }
+
+    public function testDeleteMethod(): void
+    {
+        $client = $this->getMockBuilder(Client::class)->getMock();
+
+        $result = Builder::query($client)->index('test')->delete(1);
+
+        $this->assertInstanceOf(IndexResponseDto::class, $result);
+    }
 }