Method createAria2Task

api/factory.go:141–181

createAria2Task 创建 Aria2 任务

(taskID string, createdAt time.Time, req *CreateTaskRequest, stor storage.Storage)

// createAria2Task 创建 Aria2 任务
func (f *TaskFactory) createAria2Task(taskID string, createdAt time.Time, req *CreateTaskRequest, stor storage.Storage) (*CreateTaskResponse, error) {
	var params Aria2Params
	if err := json.Unmarshal(req.Params, &params); err != nil {
		return nil, fmt.Errorf("invalid params: %w", err)
	}

	if len(params.URLs) == 0 {
		return nil, fmt.Errorf("no URLs provided")
	}

	// 检查 Aria2 是否启用
	cfg := config.C().Aria2
	if !cfg.Enable {
		return nil, fmt.Errorf("aria2 is not enabled")
	}

	aria2Client, err := aria2.NewClient(cfg.Url, cfg.Secret)
	if err != nil {
		return nil, fmt.Errorf("failed to create aria2 client: %w", err)
	}

	// 添加下载任务到 Aria2
	gid, err := aria2Client.AddURI(f.ctx, params.URLs, nil)
	if err != nil {
		return nil, fmt.Errorf("failed to add aria2 task: %w", err)
	}

	task := aria2dl.NewTask(taskID, f.ctx, gid, params.URLs, aria2Client, stor, req.Path, nil)

	err = f.registerAndEnqueueTask(task, tasktype.TaskTypeAria2, req.Storage, req.Path, req.Webhook)
	if err != nil {
		return nil, err
	}

	return &CreateTaskResponse{
		TaskID:    taskID,
		Type:      tasktype.TaskTypeAria2,
		Status:    TaskStatusQueued,
		CreatedAt: createdAt,
	}, nil
}

// createParsedTask 创建解析任务
func (f *TaskFactory) createParsedTask(taskID string, createdAt time.Time, req *CreateTaskRequest, stor storage.Storage) (*CreateTaskResponse, error) {