start clean up tasks

internal/wranglerasynq/clean_up.go

@@ -0,0 +1,22 @@
+package wranglerasynq
+
+import (
+	"github.com/hibiken/asynq"
+	"receipt-wrangler/api/internal/models"
+)
+
+func StartSystemCleanUpTasks() error {
+	inspector, err := GetAsynqInspector()
+	if err != nil {
+		return err
+	}
+	defer inspector.Close()
+
+	cleanUpQueue := models.SystemCleanUpQueue
+
+	inspector.DeleteAllScheduledTasks(string(cleanUpQueue))
+	refreshTokenTask := asynq.NewTask(RefreshTokenCleanUp, nil)
+	_, err = RegisterTask("@every 24h", refreshTokenTask, cleanUpQueue, 0)
+
+	return err
+}

main.go

@@ -86,6 +86,11 @@ func main() {
 		}
 	}
 
+	err = wranglerasynq.StartSystemCleanUpTasks()
+	if err != nil {
+		logging.LogStd(logging.LOG_LEVEL_FATAL, err.Error())
+	}
+
 	stop := make(chan os.Signal, 1)
 	signal.Notify(stop, os.Interrupt, syscall.SIGTERM)