Merge pull request #118 from apisearch-io/feature/added-delete-items-by-query

Added delete-items-by-query method in repository

Author: mmoreram

Repository/HttpRepository.php

@@ -131,6 +131,30 @@ public function updateItems(
         self::throwTransportableExceptionIfNeeded($response);
     }
 
+    /**
+     * Delete items by query
+     *
+     * @param Query $query
+     */
+    public function deleteItemsByQuery(Query $query)
+    {
+        $response = $this
+            ->httpClient
+            ->get(
+                sprintf(
+                    '/%s/indices/%s/items/by-query',
+                    $this->getAppUUID()->composeUUID(),
+                    $this->getIndexUUID()->composeUUID()
+                ),
+                'delete',
+                [],
+                $query->toArray(),
+                Http::getApisearchHeaders($this)
+            );
+
+        self::throwTransportableExceptionIfNeeded($response);
+    }
+
     /**
      * Search across the index types.
      *

Repository/InMemoryRepository.php

@@ -97,6 +97,16 @@ public function updateItems(
         throw new LogicException('Update endpoint cannot be tested against memory implementation, but only in final implementation');
     }
 
+    /**
+     * Delete items by query
+     *
+     * @param Query $query
+     */
+    public function deleteItemsByQuery(Query $query)
+    {
+        throw new LogicException('Update endpoint cannot be tested against memory implementation, but only in final implementation');
+    }
+
     /**
      * Get items.
      *

Repository/MockRepository.php

@@ -72,6 +72,16 @@ public function updateItems(
         $this->throwMockException();
     }
 
+    /**
+     * Delete items by query
+     *
+     * @param Query $query
+     */
+    public function deleteItemsByQuery(Query $query)
+    {
+        $this->throwMockException();
+    }
+
     /**
      * Throw exception.
      *

Repository/Repository.php

@@ -199,4 +199,11 @@ abstract public function updateItems(
         Query $query,
         Changes $changes
     );
+
+    /**
+     * Delete items by query
+     *
+     * @param Query $query
+     */
+    abstract public function deleteItemsByQuery(Query $query);
 }

Repository/TransformableRepository.php

@@ -184,6 +184,18 @@ public function updateItems(
             );
     }
 
+    /**
+     * Delete items by query
+     *
+     * @param Query $query
+     */
+    public function deleteItemsByQuery(Query $query)
+    {
+        $this
+            ->repository
+            ->deleteItemsByQuery($query);
+    }
+
     /**
      * Generate item document by a simple object.
      *