Method createTransferTask

api/factory.go:323–382

createTransferTask 创建存储间传输任务

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

// createTransferTask 创建存储间传输任务
func (f *TaskFactory) createTransferTask(taskID string, createdAt time.Time, req *CreateTaskRequest) (*CreateTaskResponse, error) {
	var params TransferParams
	if err := json.Unmarshal(req.Params, &params); err != nil {
		return nil, fmt.Errorf("invalid params: %w", err)
	}

	// 验证源存储和目标存储
	sourceStor, ok := storage.Storages[params.SourceStorage]
	if !ok {
		return nil, fmt.Errorf("source storage not found: %s", params.SourceStorage)
	}

	targetStor, ok := storage.Storages[params.TargetStorage]
	if !ok {
		return nil, fmt.Errorf("target storage not found: %s", params.TargetStorage)
	}

	// 检查源存储是否可读
	sourceReadable, ok := sourceStor.(storage.StorageReadable)
	if !ok {
		return nil, fmt.Errorf("source storage does not support reading: %s", params.SourceStorage)
	}

	// 检查源存储是否可列
	sourceListable, ok := sourceStor.(storage.StorageListable)
	if !ok {
		return nil, fmt.Errorf("source storage does not support listing: %s", params.SourceStorage)
	}

	// 列出源文件
	files, err := sourceListable.ListFiles(f.ctx, params.SourcePath)
	if err != nil {
		return nil, fmt.Errorf("failed to list source files: %w", err)
	}

	if len(files) == 0 {
		return nil, fmt.Errorf("no files found at source path: %s", params.SourcePath)
	}

	// 创建传输元素
	elems := make([]transfer.TaskElement, 0, len(files))
	for _, file := range files {
		elem := transfer.NewTaskElement(sourceReadable, file, targetStor, params.TargetPath)
		elems = append(elems, *elem)
	}

	task := transfer.NewTransferTask(taskID, f.ctx, elems, nil, true)

	err = f.registerAndEnqueueTask(task, tasktype.TaskTypeTransfer, params.TargetStorage, params.TargetPath, req.Webhook)
	if err != nil {
		return nil, err
	}

	return &CreateTaskResponse{
		TaskID:    taskID,
		Type:      tasktype.TaskTypeTransfer,
		Status:    TaskStatusQueued,
		CreatedAt: createdAt,