Complete unit tests

Author: GromNaN

src/Scout/ScoutEngine.php

@@ -42,6 +42,7 @@
 use function is_iterable;
 use function is_string;
 use function iterator_to_array;
+use function method_exists;
 use function preg_quote;
 use function sleep;
 use function sprintf;
@@ -188,20 +189,28 @@ protected function performSearch(Builder $builder, ?int $offset = null): array
             return $result instanceof CursorInterface ? $result->toArray() : $result;
         }
 
-        $compound = [];
-
-        // Query String
+        $compound = [
+            'must' => [
+                [
+                    'text' => [
+                        'query' => $builder->query,
+                        'path' => ['wildcard' => '*'],
+                        'fuzzy' => ['maxEdits' => 2],
+                    ],
+                ],
+            ],
+        ];
 
         foreach ($builder->wheres as $field => $value) {
-            $compound['filter']['equals'][] = ['path' => $field, 'value' => $value];
+            $compound['filter'][] = ['equals' => ['path' => $field, 'value' => $value]];
         }
 
         foreach ($builder->whereIns as $field => $value) {
-            $compound['filter']['in'][] = ['path' => $field, 'value' => $value];
+            $compound['filter'][] = ['in' => ['path' => $field, 'value' => $value]];
         }
 
         foreach ($builder->whereNotIns as $field => $value) {
-            $compound['mustNot']['in'][] = ['path' => $field, 'value' => $value];
+            $compound['mustNot'][] = ['in' => ['path' => $field, 'value' => $value]];
         }
 
         $pipeline = [
@@ -236,27 +245,6 @@ protected function performSearch(Builder $builder, ?int $offset = null): array
         return $collection->aggregate($pipeline, $options)->toArray();
     }
 
-    /**
-     * Get the filter array for the query.
-     *
-     * @return string
-     */
-    protected function filters(Builder $builder): array
-    {
-        $filters = $builder->wheres;
-
-        // https://www.mongodb.com/docs/atlas/atlas-search/in/
-        foreach ($builder->whereIns as $field => $values) {
-            $filters['in'][] = ['path' => $field, 'value' => $values];
-        }
-
-        foreach ($builder->whereNotIns as $field => $values) {
-            $filters['in'][] = ['path' => $field, 'value' => $values];
-        }
-
-        return $filters;
-    }
-
     /**
      * Pluck and return the primary keys of the given results.
      *
@@ -494,6 +482,26 @@ private function performSearchIndexOperation(Closure $closure): void
         }
     }
 
+    private function getMapping(Model $model): array
+    {
+        $mapping = self::DEFAULT_DEFINITION;
+
+        if (method_exists($model, 'searchableMapping')) {
+            $mapping = $model->searchableMapping();
+        }
+
+        if ($this->usesSoftDelete($model)) {
+            // This field is a boolean represented with the integers 0 and 1
+            $mapping['fields']['__soft_deleted'] = [
+                'type' => 'number',
+                'representation' => 'int64',
+                'indexDoubles' => false,
+            ];
+        }
+
+        return $mapping;
+    }
+
     /**
      * Wait for the callback to return true, use it for asynchronous
      * Atlas Search index management operations.

tests/Models/SearchableModel.php

@@ -27,11 +27,19 @@ public function indexableAs(): string
         return 'table_indexable';
     }
 
+    /**
+     * Overriding the `getScoutKey` method to ensure the custom key is used for indexing
+     * and searching the model.
+     */
     public function getScoutKey(): string
     {
         return $this->getAttribute($this->getScoutKeyName()) ?: 'key_' . $this->getKey();
     }
 
+    /**
+     * This method must be overridden when the `getScoutKey` method is also overridden,
+     * to support model serialization for async indexation jobs.
+     */
     public function getScoutKeyName(): string
     {
         return 'scout_key';