add task to check channel for clips

Zibbp · Nov 6, 2024 · 407378b · 407378b
1 parent 5e2bf96
commit 407378b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/internal/task/task.go b/internal/task/task.go
@@ -45,6 +45,13 @@ func (s *Service) StartTask(ctx context.Context, task string) error {
 		}
 		log.Info().Str("task_id", fmt.Sprintf("%d", task.Job.ID)).Msgf("task created")
 
+	case "check_clips":
+		task, err := s.RiverClient.Client.Insert(ctx, tasks_periodic.TaskCheckChannelForNewClipsArgs{}, nil)
+		if err != nil {
+			return fmt.Errorf("error inserting task: %v", err)
+		}
+		log.Info().Str("task_id", fmt.Sprintf("%d", task.Job.ID)).Msgf("task created")
+
 	case "get_jwks":
 		task, err := s.RiverClient.Client.Insert(ctx, tasks_periodic.FetchJWKSArgs{}, nil)
 		if err != nil {

diff --git a/internal/transport/http/task.go b/internal/transport/http/task.go
@@ -12,7 +12,7 @@ type TaskService interface {
 }
 
 type StartTaskRequest struct {
-	Task string `json:"task" validate:"required,oneof=check_live check_vod get_jwks storage_migration prune_videos save_chapters update_stream_vod_ids"`
+	Task string `json:"task" validate:"required,oneof=check_live check_vod check_clips get_jwks storage_migration prune_videos save_chapters update_stream_vod_ids"`
 }
 
 // StartTask godoc