Fixed opening an existing index

anthony-ozdemir · May 31, 2023 · 254412f · 254412f
1 parent 35550c9
commit 254412f
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/internal/task_handlers/indexers/basic_indexer.go b/internal/task_handlers/indexers/basic_indexer.go
@@ -15,12 +15,17 @@ type BasicIndexer struct {
 }
 
 func (b *BasicIndexer) Initialize(config config.TaskHandlerOptions, baseFolder string, outputLimit int64) error {
-	// Configure default indexing mapping
-	indexMapping := bleve.NewIndexMapping()
-	index, err := bleve.New(baseFolder, indexMapping)
 
+	// Try to open an existing index
+	index, err := bleve.Open(baseFolder)
+
+	// If the index doesn't exist, create a new one
 	if err != nil {
-		return err
+		indexMapping := bleve.NewIndexMapping()
+		index, err = bleve.New(baseFolder, indexMapping)
+		if err != nil {
+			return err
+		}
 	}
 
 	b.index = index