feat: Added clear and destroy function for all kind of storages

src/Array/ArrayKeyStorage.php

@@ -14,6 +14,16 @@ class ArrayKeyStorage implements Storage
      */
     private array $storage = [];
 
+    public function destroy(): void
+    {
+        $this->storage = [];
+    }
+
+    public function clear(): void
+    {
+        $this->storage = [];
+    }
+
     public function store(Documents $documents): void
     {
         foreach ($documents as $document) {

src/Array/ArrayStorage.php

@@ -39,10 +39,11 @@
 use Shopware\Storage\Common\Schema\Collection;
 use Shopware\Storage\Common\Schema\FieldType;
 use Shopware\Storage\Common\Schema\SchemaUtil;
+use Shopware\Storage\Common\Storage;
 use Shopware\Storage\Common\StorageContext;
 use Shopware\Storage\Common\Total;
 
-class ArrayStorage extends ArrayKeyStorage implements FilterAware, AggregationAware
+class ArrayStorage implements Storage, FilterAware, AggregationAware
 {
     /**
      * @var array<string, Document>
@@ -54,6 +55,16 @@ public function __construct(
         private readonly Collection $collection
     ) {}
 
+    public function clear(): void
+    {
+        $this->storage = [];
+    }
+
+    public function destroy(): void
+    {
+        $this->storage = [];
+    }
+
     public function setup(): void
     {
         $this->storage = [];

src/Common/Storage.php

@@ -32,7 +32,7 @@ public function store(Documents $documents): void;
      */
     public function setup(): void;
 
-    //    public function clear(): void;
+    public function clear(): void;
 
-    //    public function destroy();
+    public function destroy(): void;
 }

src/DynamoDB/DynamoDBKeyStorage.php

@@ -26,6 +26,11 @@ public function __construct(
         private readonly Collection $collection
     ) {}
 
+    public function destroy(): void
+    {
+        $this->client->deleteTable(['TableName' => $this->collection->name]);
+    }
+
     public function setup(): void
     {
         $table = new CreateTableInput([
@@ -49,6 +54,12 @@ public function setup(): void
         }
     }
 
+    public function clear(): void
+    {
+        $this->destroy();
+        $this->setup();
+    }
+
     public function remove(array $keys): void
     {
         $mapped = [];

src/Meilisearch/MeilisearchStorage.php

@@ -55,6 +55,16 @@ public function __construct(
         private readonly Collection $collection
     ) {}
 
+    public function destroy(): void
+    {
+        $this->client->deleteIndex($this->collection->name);
+    }
+
+    public function clear(): void
+    {
+        $this->index()->deleteAllDocuments();
+    }
+
     public function get(string $key, StorageContext $context): ?Document
     {
         try {

src/MongoDB/MongoDBKeyStorage.php

@@ -19,6 +19,16 @@ public function __construct(
         private readonly Client $client
     ) {}
 
+    public function clear(): void
+    {
+        $this->collection()->deleteMany([]);
+    }
+
+    public function destroy(): void
+    {
+        $this->collection()->drop();
+    }
+
     public function mget(array $keys, StorageContext $context): Documents
     {
         $query['key'] = ['$in' => $keys];

src/MongoDB/MongoDBStorage.php

@@ -60,6 +60,16 @@ public function __construct(
         private readonly Client $client
     ) {}
 
+    public function destroy(): void
+    {
+        $this->collection()->drop();
+    }
+
+    public function clear(): void
+    {
+        $this->collection()->deleteMany([]);
+    }
+
     public function setup(): void {}
 
     public function mget(array $keys, StorageContext $context): Documents

src/MySQL/MySQLKeyStorage.php

@@ -28,6 +28,20 @@ private function table(): string
         return '`' . $this->collection->name . '`';
     }
 
+    public function destroy(): void
+    {
+        $this->connection->executeStatement(
+            sql: 'DROP TABLE IF EXISTS ' . $this->table()
+        );
+    }
+
+    public function clear(): void
+    {
+        $this->connection->executeStatement(
+            sql: 'DELETE FROM ' . $this->table()
+        );
+    }
+
     public function setup(): void
     {
         $table = new Table(name: $this->collection->name);

src/MySQL/MySQLStorage.php

@@ -51,6 +51,20 @@ private static function escape(string $source): string
         return '`' . $source . '`';
     }
 
+    public function destroy(): void
+    {
+        $this->connection->executeStatement(
+            sql: 'DROP TABLE IF EXISTS ' . self::escape($this->collection->name)
+        );
+    }
+
+    public function clear(): void
+    {
+        $this->connection->executeStatement(
+            sql: 'DELETE FROM ' . self::escape($this->collection->name)
+        );
+    }
+
     public function setup(): void
     {
         $table = new Table(name: $this->collection->name);

src/Opensearch/OpensearchStorage.php

@@ -76,6 +76,27 @@ public function __construct(
         private readonly Collection $collection
     ) {}
 
+    public function destroy(): void
+    {
+        if (!$this->exists()) {
+            return;
+        }
+
+        $this->client->indices()->delete(['index' => $this->collection->name]);
+    }
+
+    public function clear(): void
+    {
+        if (!$this->exists()) {
+            return;
+        }
+
+        $this->client->deleteByQuery([
+            'index' => $this->collection->name,
+            'body' => ['query' => ['match_all' => new \stdClass()]],
+        ]);
+    }
+
     public function setup(): void
     {
         $properties = $this->setupProperties($this->collection);

src/Redis/RedisKeyStorage.php

@@ -17,6 +17,16 @@ public function __construct(
         private readonly Hydrator $hydrator
     ) {}
 
+    public function clear(): void
+    {
+        $this->client->flushDB();
+    }
+
+    public function destroy(): void
+    {
+        $this->client->flushDB();
+    }
+
     public function setup(): void {}
 
     public function remove(array $keys): void

tests/Meilisearch/MeilisearchLiveStorage.php

@@ -20,6 +20,18 @@ public function __construct(
         private readonly Client $client
     ) {}
 
+    public function destroy(): void
+    {
+        $this->storage->destroy();
+        $this->wait();
+    }
+
+    public function clear(): void
+    {
+        $this->storage->clear();
+        $this->wait();
+    }
+
     public function mget(array $keys, StorageContext $context): Documents
     {
         return $this->storage->mget($keys, $context);

tests/Meilisearch/MeilisearchTestTrait.php

@@ -3,9 +3,6 @@
 namespace Shopware\StorageTests\Meilisearch;
 
 use Meilisearch\Client;
-use Meilisearch\Contracts\TasksQuery;
-use Meilisearch\Endpoints\Indexes;
-use Meilisearch\Exceptions\ApiException;
 use Shopware\Storage\Common\Aggregation\AggregationCaster;
 use Shopware\Storage\Common\Document\Hydrator;
 use Shopware\Storage\Meilisearch\MeilisearchStorage;
@@ -15,31 +12,25 @@ trait MeilisearchTestTrait
 {
     private static ?Client $client = null;
 
-    private function exists(): bool
+    public static function setUpBeforeClass(): void
     {
-        try {
-            $this->getClient()->getIndex(TestSchema::getCollection()->name);
-        } catch (ApiException) {
-            return false;
-        }
-
-        return true;
+        parent::setUpBeforeClass();
+        self::createStorage()->setup();
     }
 
     protected function setUp(): void
     {
         parent::setUp();
+        $this->getStorage()->clear();
+    }
 
-        if ($this->exists()) {
-            $this->index()->deleteAllDocuments();
-            $this->wait();
-            return;
-        }
-
-        $this->getStorage()->setup();
+    public static function tearDownAfterClass(): void
+    {
+        self::createStorage()->destroy();
+        parent::tearDownAfterClass();
     }
 
-    private function getClient(): Client
+    private static function getClient(): Client
     {
         if (self::$client === null) {
             self::$client = new Client(
@@ -51,37 +42,16 @@ private function getClient(): Client
         return self::$client;
     }
 
-    public function createStorage(): MeilisearchLiveStorage
+    private static function createStorage(): MeilisearchLiveStorage
     {
         return new MeilisearchLiveStorage(
             storage: new MeilisearchStorage(
                 caster: new AggregationCaster(),
                 hydrator: new Hydrator(),
-                client: $this->getClient(),
+                client: self::getClient(),
                 collection: TestSchema::getCollection()
             ),
-            client: $this->getClient(),
+            client: self::getClient(),
         );
     }
-
-    private function index(): Indexes
-    {
-        return $this->getClient()->index(TestSchema::getCollection()->name);
-    }
-
-    private function wait(): void
-    {
-        $tasks = new TasksQuery();
-        $tasks->setStatuses(['enqueued', 'processing']);
-
-        $tasks = $this->getClient()->getTasks($tasks);
-
-        $ids = array_map(fn($task) => $task['uid'], $tasks->getResults());
-
-        if (count($ids) === 0) {
-            return;
-        }
-
-        $this->getClient()->waitForTasks($ids);
-    }
 }

tests/MongoDB/MongoDBAggregateStorageTest.php

@@ -30,13 +30,14 @@ private function getClient(): Client
     protected function setUp(): void
     {
         parent::setUp();
-        $this->getClient()->dropDatabase('test');
+        $this->getStorage()->destroy();
+        $this->getStorage()->setup();
     }
 
     protected function tearDown(): void
     {
         parent::tearDown();
-        $this->getClient()->dropDatabase('test');
+        $this->getStorage()->destroy();
     }
 
     public function getStorage(): AggregationAware&Storage

tests/MongoDB/MongoDBFilterStorageTest.php

@@ -30,13 +30,14 @@ private function getClient(): Client
     protected function setUp(): void
     {
         parent::setUp();
-        $this->getClient()->dropDatabase('test');
+        $this->getStorage()->destroy();
+        $this->getStorage()->setup();
     }
 
     protected function tearDown(): void
     {
         parent::tearDown();
-        $this->getClient()->dropDatabase('test');
+        $this->getStorage()->destroy();
     }
 
     public function getStorage(): FilterAware&Storage

tests/MySQL/MySQLKeyValueStorageTest.php

@@ -21,8 +21,7 @@ protected function setUp(): void
     {
         parent::setUp();
 
-        $this->getConnection()
-            ->executeStatement('DROP TABLE IF EXISTS `' . TestSchema::getCollection()->name . '`');
+        $this->getStorage()->destroy();
 
         $this->getStorage()->setup();
     }
@@ -31,8 +30,7 @@ protected function tearDown(): void
     {
         parent::tearDown();
 
-        $this->getConnection()
-            ->executeStatement('DROP TABLE IF EXISTS `' . TestSchema::getCollection()->name . '`');
+        $this->getStorage()->destroy();
     }
 
     public function getStorage(): Storage

tests/MySQL/MySQLTestTrait.php

@@ -19,7 +19,7 @@ protected function setUp(): void
     {
         parent::setUp();
 
-        self::getConnection()->executeStatement('DROP TABLE IF EXISTS ' . TestSchema::getCollection()->name);
+        $this->getStorage()->destroy();
 
         $this->getStorage()->setup();
     }