ami/tl-vikunja
1
0
Fork 0
Code

fix(typesense): add more error logging

Browse Source
This commit is contained in:
kolaente 2023-09-04 10:20:51 +02:00
parent 21a1f02ea3
commit 490d374cfd
No known key found for this signature in database
GPG Key ID: F40E70337AB24C9B
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pkg/models/typesense.go
View File

@ -207,36 +207,45 @@ func ReindexAllTasks() (err error) {
s := db.NewSession() s := db.NewSession()
defer s.Close() defer s.Close()
_, err = s.Where("collection = ?", "tasks").Delete(&TypesenseSync{})
if err != nil {
return fmt.Errorf("could not delete old sync status: %s", err.Error())
}
currentSync := &TypesenseSync{ currentSync := &TypesenseSync{
Collection: "tasks", Collection: "tasks",
SyncStartedAt: time.Now(), SyncStartedAt: time.Now(),
} }
_, err = s.Insert(currentSync) _, err = s.Insert(currentSync)
if err != nil { if err != nil {
return err return fmt.Errorf("could not update last sync: %s", err.Error())
} }
err = s.Find(tasks) err = s.Find(tasks)
if err != nil { if err != nil {
return err return fmt.Errorf("could not get all tasks: %s", err.Error())
} }
err = reindexTasks(s, tasks) err = reindexTasks(s, tasks)
if err != nil { if err != nil {
return err return fmt.Errorf("could not reindex all tasks: %s", err.Error())
} }
currentSync.SyncFinishedAt = time.Now() currentSync.SyncFinishedAt = time.Now()
_, err = s.Where("collection = ?", "tasks"). _, err = s.Where("collection = ?", "tasks").
Cols("sync_finished_at"). Cols("sync_finished_at").
Update(currentSync) Update(currentSync)
if err != nil {
return fmt.Errorf("could update last sync state: %s", err.Error())
}
return return
} }
func reindexTasks(s *xorm.Session, tasks map[int64]*Task) (err error) { func reindexTasks(s *xorm.Session, tasks map[int64]*Task) (err error) {
err = addMoreInfoToTasks(s, tasks, &user.User{ID: 1}) err = addMoreInfoToTasks(s, tasks, &user.User{ID: 1})
if err != nil { if err != nil {
return err return fmt.Errorf("could not fetch more task info: %s", err.Error())
} }
for _, task := range tasks { for _, task := range tasks {
@ -245,7 +254,7 @@ func reindexTasks(s *xorm.Session, tasks map[int64]*Task) (err error) {
comment := &TaskComment{TaskID: task.ID} comment := &TaskComment{TaskID: task.ID}
searchTask.Comments, _, _, err = comment.ReadAll(s, task.CreatedBy, "", -1, -1) searchTask.Comments, _, _, err = comment.ReadAll(s, task.CreatedBy, "", -1, -1)
if err != nil { if err != nil {
return err return fmt.Errorf("could not fetch comments for task %d: %s", task.ID, err.Error())
} }
_, err = typesenseClient.Collection("tasks"). _, err = typesenseClient.Collection("tasks").