Implement multi search

lunarphp · Oct 21, 2024 · 0b2594e · 0b2594e
1 parent 637f857
commit 0b2594e
Showing 1 changed file with 23 additions and 11 deletions.
diff --git a/src/Engines/TypesenseEngine.php b/src/Engines/TypesenseEngine.php
@@ -4,6 +4,8 @@
 
 use Illuminate\Pagination\LengthAwarePaginator;
 use Illuminate\Support\Facades\Log;
+use Laravel\Scout\EngineManager;
+use Laravel\Scout\Scout;
 use Lunar\Search\Data\SearchFacet;
 use Lunar\Search\Data\SearchHit;
 use Lunar\Search\Data\SearchResults;
@@ -69,23 +71,33 @@ protected function buildSearchOptions(array $options, string $query, $useFacetFi
             $options['filter_by'] = $filters->join(' && ');
         }
 
-        return $options;
+        return [
+            'collection' => 'voltimum_products',
+            ...$options
+        ];
     }
 
     public function get(): SearchResults
     {
         try {
-            $preResults = $this->getRawResults(function (Documents $documents, string $query, array $options) {
-                return $documents->search(
-                    $this->buildSearchOptions($options, $query, useFacetFilters: false)
-                );
-            });
-
             $paginator = $this->getRawResults(function (Documents $documents, string $query, array $options) {
-                return $documents->search(
-                    $this->buildSearchOptions($options, $query),
-                );
+                $engine = app(EngineManager::class)->engine('typesense');
+
+                $searchRequests = [
+                    'searches' => [
+                        $this->buildSearchOptions($options, $query),
+                        $this->buildSearchOptions($options, $query, useFacetFilters: false)
+                    ]
+                ];
+
+                $response = $engine->getMultiSearch()->perform($searchRequests);
+
+                return [
+                    ...$response['results'][0],
+                    'unfaceted_response' => $response['results'][1],
+                ];
             });
+
         } catch (\GuzzleHttp\Exception\ConnectException|ServiceUnavailable  $e) {
             Log::error($e->getMessage());
             $paginator = new LengthAwarePaginator(
@@ -142,7 +154,7 @@ public function get(): SearchResults
 //        }
 
 
-        $facets = collect($preResults['facet_counts'] ?? [])->map(
+        $facets = collect($paginator['unfaceted_response']['facet_counts'] ?? [])->map(
             fn ($facet) => SearchFacet::from([
                 'label' => $this->getFacetConfig($facet['field_name'])['label'] ?? '',
                 'field' => $facet['field_name'],