fix(auditing): increase timeout for meili index creation (#113)

auditing/meilisearch.go

@@ -1,6 +1,7 @@
 package auditing
 
 import (
+	"context"
 	"errors"
 	"fmt"
 	"os"
@@ -28,7 +29,15 @@ type meiliAuditing struct {
 	index     *meilisearch.Index
 }
 
-const meiliIndexNameTimeSuffixSchema = "\\d\\d\\d\\d-\\d\\d(-\\d\\d(_\\d\\d)?)?"
+var (
+	errAuditingIndexCreationDeadlineUnsufficient = errors.New("auditing index creation timed out, because meilisearch took too long. Consider increasing the timeout to prevent failing requests")
+)
+
+const (
+	meiliIndexNameTimeSuffixSchema = "\\d\\d\\d\\d-\\d\\d(-\\d\\d(_\\d\\d)?)?"
+	meiliIndexCreationWaitTimeout  = 30 * time.Second
+	meiliIndexCreationWaitInterval = 50 * time.Millisecond
+)
 
 func New(c Config) (Auditing, error) {
 	if c.Component == "" {
@@ -355,7 +364,13 @@ func (a *meiliAuditing) getLatestIndex() (*meilisearch.Index, error) {
 	if err != nil {
 		return nil, fmt.Errorf("failed to request create index (%s): %w", indexUid, err)
 	}
-	_, err = a.client.WaitForTask(creationTask.TaskUID)
+
+	waitCtx, cancelFunc := context.WithTimeoutCause(context.Background(), meiliIndexCreationWaitTimeout, errAuditingIndexCreationDeadlineUnsufficient)
+	defer cancelFunc()
+	_, err = a.client.WaitForTask(creationTask.TaskUID, meilisearch.WaitParams{
+		Context:  waitCtx,
+		Interval: meiliIndexCreationWaitInterval,
+	})
 	if err != nil {
 		return nil, fmt.Errorf("failed to execute create index (%s): %w", indexUid, err)
 	}