fix: update function signatures
continuous-integration/drone/pr Build is passing Details

This commit is contained in:
kolaente 2024-01-16 12:47:53 +01:00
parent f5a1f70893
commit 1163655f49
Signed by: konrad
GPG Key ID: F40E70337AB24C9B
3 changed files with 11 additions and 8 deletions

View File

@ -17,6 +17,7 @@
package models package models
import ( import (
"context"
"encoding/json" "encoding/json"
"strconv" "strconv"
"time" "time"
@ -526,7 +527,7 @@ func (s *RemoveTaskFromTypesense) Handle(msg *message.Message) (err error) {
_, err = typesenseClient. _, err = typesenseClient.
Collection("tasks"). Collection("tasks").
Document(strconv.FormatInt(event.Task.ID, 10)). Document(strconv.FormatInt(event.Task.ID, 10)).
Delete() Delete(context.Background())
return err return err
} }
@ -558,7 +559,7 @@ func (l *AddTaskToTypesense) Handle(msg *message.Message) (err error) {
_, err = typesenseClient.Collection("tasks"). _, err = typesenseClient.Collection("tasks").
Documents(). Documents().
Create(ttask) Create(context.Background(), ttask)
return return
} }

View File

@ -17,6 +17,7 @@
package models package models
import ( import (
"context"
"strconv" "strconv"
"strings" "strings"
"time" "time"
@ -411,7 +412,7 @@ func (t *typesenseTaskSearcher) Search(opts *taskSearchOptions) (tasks []*Task,
result, err := typesenseClient.Collection("tasks"). result, err := typesenseClient.Collection("tasks").
Documents(). Documents().
Search(params) Search(context.Background(), params)
if err != nil { if err != nil {
return return
} }

View File

@ -17,6 +17,7 @@
package models package models
import ( import (
"context"
"fmt" "fmt"
"time" "time"
@ -195,9 +196,9 @@ func CreateTypesenseCollections() error {
} }
// delete any collection which might exist // delete any collection which might exist
_, _ = typesenseClient.Collection("tasks").Delete() _, _ = typesenseClient.Collection("tasks").Delete(context.Background())
_, err := typesenseClient.Collections().Create(taskSchema) _, err := typesenseClient.Collections().Create(context.Background(), taskSchema)
return err return err
} }
@ -304,7 +305,7 @@ func reindexTasks(s *xorm.Session, tasks map[int64]*Task) (err error) {
_, err = typesenseClient.Collection("tasks"). _, err = typesenseClient.Collection("tasks").
Documents(). Documents().
Import(typesenseTasks, &api.ImportDocumentsParams{ Import(context.Background(), typesenseTasks, &api.ImportDocumentsParams{
Action: pointer.String("upsert"), Action: pointer.String("upsert"),
BatchSize: pointer.Int(100), BatchSize: pointer.Int(100),
}) })
@ -381,14 +382,14 @@ func indexDummyTask() (err error) {
_, err = typesenseClient.Collection("tasks"). _, err = typesenseClient.Collection("tasks").
Documents(). Documents().
Create(dummyTask) Create(context.Background(), dummyTask)
if err != nil { if err != nil {
return return
} }
_, err = typesenseClient.Collection("tasks"). _, err = typesenseClient.Collection("tasks").
Document(dummyTask.ID). Document(dummyTask.ID).
Delete() Delete(context.Background())
return return
} }