News methods New format handling CSV NDJSON

src/Contracts/Http.php

@@ -8,7 +8,7 @@ interface Http
 {
     public function get($path, array $query = []);
 
-    public function post(string $path, $body = null, array $query = []);
+    public function post(string $path, $body = null, array $query = [], string $content_type = null);
 
     public function put(string $path, $body = null, array $query = []);
 

src/Endpoints/Delegates/HandlesDocuments.php

@@ -40,6 +40,21 @@ public function addDocumentsInBatches(array $documents, ?int $batchSize = 1000,
         return $promises;
     }
 
+    public function addDocumentsJson(string $documents, ?string $primaryKey = null)
+    {
+        return $this->http->post(self::PATH.'/'.$this->uid.'/documents', $documents, ['primaryKey' => $primaryKey], 'application/json');
+    }
+
+    public function addDocumentsNdjson(string $documents, ?string $primaryKey = null)
+    {
+        return $this->http->post(self::PATH.'/'.$this->uid.'/documents', $documents, ['primaryKey' => $primaryKey], 'application/x-ndjson');
+    }
+
+    public function addDocumentsCsv(string $documents, ?string $primaryKey = null)
+    {
+        return $this->http->post(self::PATH.'/'.$this->uid.'/documents', $documents, ['primaryKey' => $primaryKey], 'text/csv');
+    }
+
     public function updateDocuments(array $documents, ?string $primaryKey = null)
     {
         return $this->http->put(self::PATH.'/'.$this->uid.'/documents', $documents, ['primaryKey' => $primaryKey]);

src/Http/Client.php

@@ -64,7 +64,6 @@ public function __construct(string $url, string $apiKey = null, ClientInterface
         $this->requestFactory = Psr17FactoryDiscovery::findRequestFactory();
         $this->streamFactory = Psr17FactoryDiscovery::findStreamFactory();
         $this->headers = array_filter([
-            'Content-type' => 'application/json',
             'X-Meili-API-Key' => $this->apiKey,
         ]);
     }
@@ -98,18 +97,25 @@ public function get($path, $query = [])
      * @throws CommunicationException
      * @throws FailedJsonEncodingException
      */
-    public function post(string $path, $body = null, array $query = [])
+    public function post(string $path, $body = null, array $query = [], string $content_type = null)
     {
+        if ($content_type) {
+            $this->headers['Content-type'] = $content_type;
+        } else {
+            $this->headers['Content-type'] = 'application/json';
+            $body = $this->jsonEncode($body);
+        }
         $request = $this->requestFactory->createRequest(
             'POST',
             $this->baseUrl.$path.$this->buildQueryString($query)
-        )->withBody($this->streamFactory->createStream($this->jsonEncode($body)));
+            )->withBody($this->streamFactory->createStream($body));
 
         return $this->execute($request);
     }
 
     public function put($path, $body = null, $query = [])
     {
+        $this->headers['Content-type'] = 'application/json';
         $request = $this->requestFactory->createRequest(
             'PUT',
             $this->baseUrl.$path.$this->buildQueryString($query)
@@ -130,6 +136,7 @@ public function put($path, $body = null, $query = [])
      */
     public function patch($path, $body = null, $query = [])
     {
+        $this->headers['Content-type'] = 'application/json';
         $request = $this->requestFactory->createRequest(
             'PATCH',
             $this->baseUrl.$path.$this->buildQueryString($query)

tests/Endpoints/DocumentsTest.php

@@ -63,6 +63,69 @@ public function testAddDocumentWithSpecialChars(): void
         }
     }
 
+    public function testAddDocumentsCsv(): void
+    {
+        $index = $this->client->index('documentCsv');
+
+        $fileCsv = fopen('./tests/datasets/songs.csv', 'r');
+        $documentCsv = fread($fileCsv, filesize('./tests/datasets/songs.csv'));
+        fclose($fileCsv);
+
+        $promise = $index->addDocumentsCsv($documentCsv);
+
+        $this->assertIsValidPromise($promise);
+
+        $update = $index->waitForPendingUpdate($promise['updateId']);
+
+        $this->assertEquals($update['status'], 'processed');
+        $this->assertNotEquals($update['type']['number'], 0);
+
+        $response = $index->getDocuments();
+        $this->assertCount(20, $response);
+    }
+
+    public function testAddDocumentsJson(): void
+    {
+        $index = $this->client->index('documentJson');
+
+        $fileJson = fopen('./tests/datasets/small_movies.json', 'r');
+        $documentJson = fread($fileJson, filesize('./tests/datasets/small_movies.json'));
+        fclose($fileJson);
+
+        $promise = $index->addDocumentsJson($documentJson);
+
+        $this->assertIsValidPromise($promise);
+
+        $update = $index->waitForPendingUpdate($promise['updateId']);
+
+        $this->assertEquals($update['status'], 'processed');
+        $this->assertNotEquals($update['type']['number'], 0);
+
+        $response = $index->getDocuments();
+        $this->assertCount(20, $response);
+    }
+
+    public function testAddDocumentsNdJson(): void
+    {
+        $index = $this->client->index('documentNdJson');
+
+        $fileNdJson = fopen('./tests/datasets/songs.ndjson', 'r');
+        $documentNdJson = fread($fileNdJson, filesize('./tests/datasets/songs.ndjson'));
+        fclose($fileNdJson);
+
+        $promise = $index->addDocumentsNdJson($documentNdJson);
+
+        $this->assertIsValidPromise($promise);
+
+        $update = $index->waitForPendingUpdate($promise['updateId']);
+
+        $this->assertEquals($update['status'], 'processed');
+        $this->assertNotEquals($update['type']['number'], 0);
+
+        $response = $index->getDocuments();
+        $this->assertCount(20, $response);
+    }
+
     public function testCannotAddDocumentWhenJsonEncodingFails(): void
     {
         $this->expectException(FailedJsonEncodingException::class);