Add OpenSearch integration tests

Author: stevebauman

.github/workflows/run-tests.yml

@@ -8,6 +8,16 @@ on:
 jobs:
   test:
     runs-on: ${{ matrix.os }}
+    services:
+      opensearch:
+        image: opensearchproject/opensearch:2.13.0
+        env:
+          discovery.type: single-node
+          plugins.security.disabled: true
+          OPENSEARCH_JAVA_OPTS: -Xms512m -Xmx512m
+        ports:
+          - 9200:9200
+
     strategy:
       fail-fast: true
       matrix:
@@ -29,5 +39,21 @@ jobs:
       - name: Install dependencies
         run: composer update --prefer-dist --no-interaction
 
+      - name: Wait for OpenSearch
+        run: |
+          for attempt in {1..60}; do
+            if curl --fail --silent http://127.0.0.1:9200 > /dev/null; then
+              exit 0
+            fi
+
+            sleep 1
+          done
+
+          echo "OpenSearch did not become available in time."
+          docker logs "${{ job.services.opensearch.id }}"
+          exit 1
+
       - name: Execute tests
-        run: vendor/bin/pest --ci
+        run: vendor/bin/pest tests/Integration tests/Unit --ci
+        env:
+          OPENSEARCH_HOST: http://127.0.0.1:9200

tests/Integration/OpenSearchAdapterTest.php

@@ -0,0 +1,75 @@
+<?php
+
+use DirectoryTree\OpenSearchAdapter\Documents\Document;
+use DirectoryTree\OpenSearchAdapter\Documents\DocumentManager;
+use DirectoryTree\OpenSearchAdapter\Indices\Alias;
+use DirectoryTree\OpenSearchAdapter\Indices\IndexBlueprint;
+use DirectoryTree\OpenSearchAdapter\Indices\IndexManager;
+use DirectoryTree\OpenSearchAdapter\Search\SearchRequest;
+use OpenSearch\Client;
+use OpenSearch\GuzzleClientFactory;
+
+it('manages indices documents aliases and searches against opensearch', function (): void {
+    $client = openSearchClient();
+    $indexManager = new IndexManager($client);
+    $documentManager = new DocumentManager($client);
+
+    $indexName = sprintf('adapter_integration_%s', bin2hex(random_bytes(4)));
+    $aliasName = $indexName.'_alias';
+
+    try {
+        $indexManager->create(new IndexBlueprint($indexName));
+
+        expect($indexManager->exists($indexName))->toBeTrue();
+
+        $documentManager->index($indexName, [
+            new Document('1', ['title' => 'Laravel OpenSearch adapter', 'status' => 'published']),
+            new Document('2', ['title' => 'Draft document', 'status' => 'draft']),
+        ], refresh: true);
+
+        $response = $documentManager->search($indexName, new SearchRequest([
+            'match' => [
+                'title' => 'Laravel',
+            ],
+        ]));
+
+        expect($response->total())->toBe(1)
+            ->and($response->hits()[0]->document()->id())->toBe('1')
+            ->and($response->hits()[0]->document()->content('status'))->toBe('published');
+
+        $indexManager->putAlias($indexName, new Alias($aliasName, [
+            'term' => ['status' => 'published'],
+        ]));
+
+        $aliases = $indexManager->getAliases($indexName);
+
+        expect($aliases)->toHaveKey($aliasName)
+            ->and($aliases[$aliasName]->filter())->toBe(['term' => ['status' => 'published']]);
+
+        $indexManager->deleteAlias($indexName, $aliasName);
+
+        expect($indexManager->getAliases($indexName))->not->toHaveKey($aliasName);
+
+        $documentManager->delete($indexName, ['1'], refresh: true);
+
+        expect($documentManager->search($indexName, new SearchRequest([
+            'match' => [
+                'title' => 'Laravel',
+            ],
+        ]))->total())->toBe(0);
+    } finally {
+        if ($indexManager->exists($indexName)) {
+            $indexManager->drop($indexName);
+        }
+    }
+});
+
+/**
+ * Create an OpenSearch client for integration tests.
+ */
+function openSearchClient(): Client
+{
+    return (new GuzzleClientFactory)->create([
+        'base_uri' => getenv('OPENSEARCH_HOST') ?: 'http://127.0.0.1:9200',
+    ]);
+}

tests/Pest.php

@@ -2,4 +2,4 @@
 
 use PHPUnit\Framework\TestCase;
 
-uses(TestCase::class)->in('Unit');
+uses(TestCase::class)->in('Integration', 'Unit');