fix: after review

Author: MrHDOLEK

.github/workflows/job-tests.yml

@@ -133,6 +133,7 @@ jobs:
         env:
           PGSQL_DATABASE_URL: pgsql://postgres:postgres@127.0.0.1:${{ job.services.postgres.ports['5432'] }}/postgres?serverVersion=18&charset=utf8
           MYSQL_DATABASE_URL: mysql://mysql:mysql@127.0.0.1:${{ job.services.mysql.ports['3306'] }}/mysql
+          ELASTICSEARCH_URL: http://127.0.0.1:${{ job.services.elasticsearch.ports['9200'] }}
           SQLITE_DATABASE_URL: "sqlite:///:memory:"
           AZURITE_HOST: "localhost"
           AZURITE_BLOB_PORT: "10000"
@@ -158,7 +159,6 @@ jobs:
         env:
           PGSQL_DATABASE_URL: pgsql://postgres:postgres@127.0.0.1:${{ job.services.postgres.ports['5432'] }}/postgres?serverVersion=18&charset=utf8
           MYSQL_DATABASE_URL: mysql://mysql:mysql@127.0.0.1:${{ job.services.mysql.ports['3306'] }}/mysql
-          ELASTICSEARCH_URL: http://127.0.0.1:${{ job.services.elasticsearch.ports['9200'] }}
           SQLITE_DATABASE_URL: "sqlite:///:memory:"
           AZURITE_HOST: "localhost"
           AZURITE_BLOB_PORT: "10000"

src/adapter/etl-adapter-seal/src/Flow/ETL/Adapter/Seal/SealExtractor.php

@@ -13,7 +13,6 @@
 use Flow\ETL\Rows;
 use Generator;
 
-use function count;
 use function Flow\ETL\DSL\array_to_rows;
 
 final class SealExtractor implements Extractor
@@ -49,12 +48,14 @@ public function extract(FlowContext $context): Generator
             $search->offset($offset);
 
             $documents = [];
+            $count = 0;
 
             foreach ($search->getResult() as $document) {
                 $documents[] = $document;
+                $count++;
             }
 
-            if ($documents === []) {
+            if ($count === 0) {
                 return;
             }
 
@@ -64,7 +65,7 @@ public function extract(FlowContext $context): Generator
                 return;
             }
 
-            if (count($documents) < $this->pageSize) {
+            if ($count < $this->pageSize) {
                 return;
             }
 

src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Context/SealContext.php

@@ -10,8 +10,6 @@
 use CmsIg\Seal\EngineInterface;
 use CmsIg\Seal\Schema\Schema;
 
-use function array_keys;
-
 final class SealContext
 {
     /**
@@ -42,7 +40,7 @@ public function engine(Schema $schema): EngineInterface
     {
         $engine = new Engine($this->adapter, $schema);
 
-        foreach (array_keys($schema->indexes) as $index) {
+        foreach ($schema->indexes as $index => $_value) {
             if ($engine->existIndex($index)) {
                 $engine->dropIndex($index, ['return_slow_promise_result' => true])?->wait();
             }