Merge pull request #31 from NicolasBarbey/main

fix indexes update

Author: NicolasBarbey

Config/module.xml

@@ -13,7 +13,7 @@
         <language>en_US</language>
         <language>fr_FR</language>
     </languages>
-    <version>3.0.2</version>
+    <version>3.0.3</version>
     <authors>
         <author>
             <name>Nicolas Barbey</name>

Engine/PropelEngine.php

@@ -6,6 +6,7 @@
 use TeamTNT\TNTSearch\Support\Collection;
 use TntSearch\Connector\PropelConnector;
 use TntSearch\Index\TntSearchIndexInterface;
+use \PDO;
 
 class PropelEngine extends SqliteEngine
 {
@@ -20,6 +21,16 @@ public function createConnector(array $config): PropelConnector
         return new PropelConnector;
     }
 
+    public function loadConfig(array $config)
+    {
+        parent::loadConfig($config);
+
+        if (!$this->dbh) {
+            $connector = $this->createConnector($this->config);
+            $this->dbh = $connector->connect($this->config);
+        }
+    }
+
     public function saveWordlist(Collection $stems)
     {
         $terms = [];
@@ -61,7 +72,7 @@ public function saveWordlist(Collection $stems)
                     $this->updateWordlistStmt->bindValue(':hits', $term['hits']);
                     $this->updateWordlistStmt->bindValue(':keyword', $key);
                     $this->updateWordlistStmt->execute();
-                    if (!$this->inMemory) {
+                    if (!$this->inMemory || !array_key_exists($key, $this->inMemoryTerms)) {
                         $this->selectWordlistStmt->bindValue(':keyword', $key);
                         $this->selectWordlistStmt->execute();
                         $res = $this->selectWordlistStmt->fetch(PDO::FETCH_ASSOC);

Service/Support/TntSearch.php

@@ -74,7 +74,7 @@ public function getIndex(): TntIndexer
         $connector = $indexer->createConnector($this->config);
         $this->dbh = $connector->connect($this->config);
 
-        $indexer->setIndex($this->index);
+        $indexer->setIndex($this->engine->index);
         $indexer->setStemmer($this->stemmer);
         $indexer->setTokenizer($this->tokenizer);
         $indexer->loadConfig($this->config);