Method registerAndEnqueueTask

api/factory.go:70–86

(task core.Executable, taskType tasktype.TaskType, storageName, path, webhook string)

}

func (f *TaskFactory) registerAndEnqueueTask(task core.Executable, taskType tasktype.TaskType, storageName, path, webhook string) error {
	taskID := task.TaskID()
	info := RegisterTask(taskID, string(taskType), storageName, path, task.Title(), webhook)

	// Inject the progress sink into the context so the task's Emit calls update
	// the API store (and fire the webhook on terminal states) without the task
	// knowing about the API.
	taskCtx := taskevent.WithSink(f.ctx, info)

	err := core.AddTask(taskCtx, task)
	if err != nil {
		DeleteTask(taskID)
		return fmt.Errorf("failed to add task: %w", err)
	}

	return nil
}

// createDirectLinksTask 创建直链下载任务
func (f *TaskFactory) createDirectLinksTask(taskID string, createdAt time.Time, req *CreateTaskRequest, stor storage.Storage) (*CreateTaskResponse, error) {