ami/tl-vikunja
1
0
Fork 0
Code

fix(typesense): use emplace instead of upsert to update documents

Browse Source 
(cherry picked from commit 3f1d0f390bddd05992f7ad1170ddfbda0bb3aec7)
This commit is contained in:
kolaente 2024-09-20 07:54:23 +02:00
parent 25c8476883
commit 4cbed7c2ed
No known key found for this signature in database
GPG Key ID: F40E70337AB24C9B
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/models/typesense.go
View File

@ -199,8 +199,6 @@ func CreateTypesenseCollections() error {
} }
func ReindexAllTasks() (err error) { func ReindexAllTasks() (err error) {
tasks := make(map[int64]*Task)
s := db.NewSession() s := db.NewSession()
defer s.Close() defer s.Close()
@ -218,6 +216,7 @@ func ReindexAllTasks() (err error) {
return fmt.Errorf("could not update last sync: %s", err.Error()) return fmt.Errorf("could not update last sync: %s", err.Error())
} }
tasks := make(map[int64]*Task)
err = s.Find(tasks) err = s.Find(tasks)
if err != nil { if err != nil {
return fmt.Errorf("could not get all tasks: %s", err.Error()) return fmt.Errorf("could not get all tasks: %s", err.Error())
@ -321,7 +320,7 @@ func reindexTasksInTypesense(s *xorm.Session, tasks map[int64]*Task) (err error)
_, err = typesenseClient.Collection("tasks"). _, err = typesenseClient.Collection("tasks").
Documents(). Documents().
Import(context.Background(), typesenseTasks, &api.ImportDocumentsParams{ Import(context.Background(), typesenseTasks, &api.ImportDocumentsParams{
Action: pointer.String("upsert"), Action: pointer.String("emplace"),
BatchSize: pointer.Int(100), BatchSize: pointer.Int(100),
}) })
if err != nil { if err != nil {