Method createTPHPicsTask

api/factory.go:286–320

createTPHPicsTask 创建 Telegraph 图片下载任务

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

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

	if params.TelegraphURL == "" {
		return nil, fmt.Errorf("no telegraph URL provided")
	}

	// 提取图片
	pics, phPath, err := ExtractTelegraphImages(f.ctx, params.TelegraphURL)
	if err != nil {
		return nil, fmt.Errorf("failed to extract telegraph images: %w", err)
	}

	if len(pics) == 0 {
		return nil, fmt.Errorf("no images found in telegraph page")
	}

	client := telegraph.NewClient()
	task := tphtask.NewTask(taskID, f.ctx, phPath, pics, stor, req.Path, client, nil)

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

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

// createTransferTask 创建存储间传输任务
func (f *TaskFactory) createTransferTask(taskID string, createdAt time.Time, req *CreateTaskRequest) (*CreateTaskResponse, error) {