feat: multilingual search

database/migrations/2023_06_30_134549_change_search_table_language_column.php

@@ -0,0 +1,27 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     */
+    public function up(): void
+    {
+        //
+        Schema::table('cms_search', function (Blueprint $table) {
+            $table->string('language', 64)->change();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        //
+    }
+};

resources/views/mail/indexer/file-index-error.blade.php

@@ -1,5 +1,5 @@
 @component('mail::message')
 
-<p>Document {{ document }} op server {{ server }} geeft de volgende fout: {{ error }}</p>
+<p>Document {{ $document }} op server {{ $server }} geeft de volgende fout: {{ $error }}</p>
 
 @endcomponent

routes/api.php

@@ -10,7 +10,6 @@
 use NotFound\Framework\Http\Controllers\SettingsController;
 use NotFound\Framework\Http\Controllers\Support\SupportController;
 use NotFound\Framework\Http\Controllers\UserPreferencesController;
-use Siteboss\Routes\SiteRoutes;
 use Spatie\Honeypot\ProtectAgainstSpam;
 
 // ContentBlock
@@ -24,6 +23,7 @@
 | is assigned the "api" middleware group. Enjoy building your API!
 |
 */
+
 Route::prefix(config('siteboss.api_prefix'))->group(function () {
     // Unauthenticated routes
     Route::prefix('api')->group(function () {

src/Models/Indexes/SolrIndex.php

@@ -130,13 +130,12 @@ public function testSolrConnection()
         return false;
     }
 
-    public function addOrUpdateItem(string $url, string $title, string $contents, string $type, int $lang, int $siteId, array $customValues, int $priority): bool
+    public function addOrUpdateItem(string $url, string $title, string $contents, string $type, string $lang, int $siteId, array $customValues, int $priority): bool
     {
         $curl = $this->solrHandler();
-
         $doc = [
-            'title' => $title,
-            'content' => html_entity_decode(trim(preg_replace('/\s+/', ' ', strip_tags($contents)))),
+            sprintf('title_%s', $lang) => $title,
+            sprintf('content_%s', $lang) => html_entity_decode(trim(preg_replace('/\s+/', ' ', preg_replace('#<[^>]+>#', ' ', $contents)))),
             'type' => $type,
             'url' => $url,
             'priority' => $priority,
@@ -157,6 +156,11 @@ public function addOrUpdateItem(string $url, string $title, string $contents, st
         curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($payload));
 
         $result = curl_exec($curl);
+
+        if (curl_errno($curl) === 6) {
+            exit('[ERROR] Could not resolve solr host: '.$this->getSolrBaseUrl());
+        }
+
         $json = json_decode($result);
         if ($json && isset($json->responseHeader) && $json->responseHeader->status == 0) {
             return true;
@@ -192,7 +196,7 @@ public function removeItem($url)
         return false;
     }
 
-    public function addOrUpdateFile(string $url, string $title, string $file, string $type, int $lang, int $siteId, array $customValues, int $priority): string
+    public function addOrUpdateFile(string $url, string $title, string $file, string $type, string $lang, int $siteId, array $customValues, int $priority): string
     {
         // find out of document exists
         $result = 0;
@@ -202,9 +206,10 @@ public function addOrUpdateFile(string $url, string $title, string $file, string
             $curl = $this->solrHandler();
 
             $endpoint = sprintf(
-                '%s/update/extract?literal.url=%s&literal.title=%s&literal.type=%s&literal.site=%s&literal.language=%d&commit=true',
+                '%s/update/extract?literal.url=%s&literal.title_%s=%s&literal.type=%s&literal.site=%s&literal.language=%d&commit=true',
                 $this->getSolrBaseUrl(),
                 urlencode($url),
+                $lang,
                 urlencode($title),
                 $type,
                 $siteId,
@@ -268,22 +273,25 @@ private function mailQueryError($query, $result)
         }
     }
 
-    public function selectItems($query, $filter = null, $start = null, $rows = null, $extraColumns = [], $highlightLength = 50)
+    public function selectItems($query, $lang = 'nl', $filter = null, $start = null, $rows = null, $extraColumns = [], $highlightLength = 50, $sortField = null, $sortDirection = 'desc')
     {
         $curl = $this->solrHandler();
         $url = sprintf(
-            '%s/select?q=title:%s%%20content:%s&spellcheck.q=%s&wt=%s&hl=%s&q.op=%s&hl.fl=%s&fl=%s&spellcheck=true&hl.fragsize=%d&hl.maxAnalyzedChars=%d',
+            '%s/select?q=title_%s:%s%%20content_%s:%s&spellcheck.q=%s&wt=%s&hl=%s&q.op=%s&hl.fl=%s&fl=%s&spellcheck=true&hl.fragsize=%d&hl.maxAnalyzedChars=%d&spellcheck.dictionary=spellcheck_%s',
             $this->getSolrBaseUrl(),
+            $lang,
+            rawurlencode($query), // make sure + between search terms is preserved
+            $lang,
             rawurlencode($query), // make sure + between search terms is preserved
             rawurlencode($query), // make sure + between search terms is preserved
-            rawurlencode($query), // make sure + between search terms is preserved            rawurlencode($query), // make sure + between search terms is preserved
             $this->wt,
             $this->hl,
             $this->selectOperator,
-            $this->hlfl,
+            sprintf('%s_%s', $this->hlfl, $lang),
             urlencode($this->fl),
             $this->hlfragsize,
             $this->hlmaxAnalyzedChars,
+            $lang
         );
         if ($filter) {
             $url .= '&fq='.$filter;
@@ -295,12 +303,11 @@ public function selectItems($query, $filter = null, $start = null, $rows = null,
         if ($rows && is_int($rows)) {
             $url .= '&rows='.$rows;
         }
-
         if (count($extraColumns) > 0) {
         }
 
-        if ($this->sort) {
-            $url .= '&sort='.urlencode($this->sort);
+        if ($sortField) {
+            $url .= '&sort='.urlencode($sortField.' '.$sortDirection);
         }
 
         curl_setopt($curl, CURLOPT_URL, $url);
@@ -359,18 +366,52 @@ public function buildSuggester()
         $url = sprintf('%s&suggest.build=true', $this->suggestUrl());
 
         curl_setopt($curl, CURLOPT_URL, $url);
-
         $result = curl_exec($curl);
         $json = json_decode($result);
         $searchResults = new SolrItem($json, null);
 
         return $searchResults;
     }
 
+    private function getConfig()
+    {
+        $curl = $this->solrHandler();
+        $url = sprintf('%s/config/searchComponent?componentName=suggest', $this->getSolrBaseUrl());
+        curl_setopt($curl, CURLOPT_URL, $url);
+        curl_setopt($curl, CURLOPT_POST, false);
+
+        $result = curl_exec($curl);
+        $json = json_decode($result);
+
+        return $json;
+    }
+
+    private function allSuggesters()
+    {
+        $json = $this->getConfig();
+        $suggesters = [];
+        if (
+            $json && isset($json->responseHeader)
+            && $json->responseHeader->status == 0
+            && isset($json->config->searchComponent->suggest->suggester)
+        ) {
+            $list = $json->config->searchComponent->suggest->suggester;
+            foreach ($list as $s) {
+                $suggesters[] = $s->name;
+            }
+        }
+
+        return $suggesters;
+    }
+
     private function explodeSuggesters(): string
     {
         $suggesterString = '';
-        foreach ($this->suggester as $s) {
+        $suggesters = $this->suggester;
+        if (count($suggesters) == 0) {
+            $suggesters = $this->allSuggesters();
+        }
+        foreach ($suggesters as $s) {
             $suggesterString .= sprintf('&suggest.dictionary=%s', $s);
         }
 

src/Models/Indexes/SolrItem.php

@@ -41,7 +41,7 @@ public function __construct($solr, $q, $collate = false, private int $highlightL
         $this->fl = explode(' ', $fl);
         $this->results = isset($solr->response->docs) ? $solr->response->docs : null;
         $this->highlights = isset($solr->highlighting) ? $solr->highlighting : null;
-        $this->spellcheck = $solr->spellcheck ?? null;
+        $this->spellcheck = isset($solr->spellcheck) ? $solr->spellcheck : null;
         $this->suggest = isset($solr->suggest) ? $solr->suggest : null;
         $this->number = isset($solr->response->numFound) ? $solr->response->numFound : 0;
 
@@ -84,7 +84,8 @@ public function resultList()
                     if ($column == 'url') {
                         $resultArray[$column] = $this->parseUrl($result->{$column});
                     } else {
-                        $resultArray[$column] = isset($result->{$column}[0]) ? $result->{$column}[0] : '';
+                        $columnName = preg_replace('/(_[a-zA-Z]{2}$)/', '', $column);
+                        $resultArray[$columnName] = isset($result->{$column}) ? $result->{$column} : '';
                     }
                 }
 
@@ -186,12 +187,12 @@ public function spellcheckList()
             foreach ($this->spellcheck->suggestions as $suggestion) {
                 if (isset($suggestion->startOffset)) {
                     $suggest = substr($query, 0, $suggestion->startOffset).'<em>'.$suggestion->suggestion[0].'</em>'.substr($query, $suggestion->endOffset);
-                    $suggest = preg_replace('/^([a-zA-Z])+:/', '', $suggest); // remove search field if necessary
+                    $suggestTerm = preg_replace('/^([a-zA-Z])+(_[a-zA-Z]{2})?:/', '', $suggest); // remove search field if necessary
 
                     $suggest_url = substr($query, 0, $suggestion->startOffset).$suggestion->suggestion[0].substr($query, $suggestion->endOffset);
-                    $suggest_url = preg_replace('/^([a-zA-Z])+:/', '', $suggest_url); // remove search field if necessary
+                    $suggest_url = preg_replace('/^([a-zA-Z])+(_[a-zA-Z]{2})?:/', '', $suggest_url); // remove search field if necessary
 
-                    $items[] = (object) ['link' => '?q='.rawurlencode(urldecode($suggest_url)), 'text' => urldecode($suggest)];
+                    $items[] = (object) ['link' => '?q='.rawurlencode(urldecode($suggest_url)), 'text' => urldecode($suggestTerm)];
                 }
             }
         }

src/Services/Indexer/AbstractIndexService.php

@@ -18,7 +18,7 @@ abstract public function finishUpdate(): object;
 
     abstract public function urlNeedsUpdate(string $url, $updated): bool;
 
-    abstract public function upsertUrl(string $url, string $title, string $contents, string $type, int $lang, array $customValues = []): object;
+    abstract public function upsertUrl(string $url, string $title, string $contents, string $type, string $lang, array $customValues = []): object;
 
-    abstract public function upsertFile(string $url, string $title, string $file, string $type, int $lang, array $customValues): object;
+    abstract public function upsertFile(string $url, string $title, string $file, string $type, string $lang, array $customValues): object;
 }