Method createTaskSpecFromRequest

internal/api/core/tasks.go:2094–2128

(
	ctx context.Context,
	req contract.CreateTaskRequest,
)

}

func (h *BaseHandlers) createTaskSpecFromRequest(
	ctx context.Context,
	req contract.CreateTaskRequest,
) (taskpkg.CreateTask, error) {
	scope := req.Scope.Normalize()
	workspaceID, err := h.resolveTaskWorkspaceBinding(ctx, scope, req.Workspace, "create_task")
	if err != nil {
		return taskpkg.CreateTask{}, err
	}
	if err := validateTaskChannel("create_task.network_channel", req.NetworkChannel); err != nil {
		return taskpkg.CreateTask{}, err
	}

	spec := taskpkg.CreateTask{
		ID:                 strings.TrimSpace(req.ID),
		Identifier:         strings.TrimSpace(req.Identifier),
		Scope:              scope,
		WorkspaceID:        workspaceID,
		NetworkChannel:     strings.TrimSpace(req.NetworkChannel),
		Title:              strings.TrimSpace(req.Title),
		Description:        strings.TrimSpace(req.Description),
		Priority:           req.Priority.Normalize(),
		MaxAttempts:        req.MaxAttempts,
		AutoEnqueueOnReady: req.AutoEnqueueOnReady,
		Draft:              req.Draft,
		ApprovalPolicy:     req.ApprovalPolicy.Normalize(),
		Owner:              cloneOwnership(req.Owner),
		WakeCreator:        cloneBoolPtr(req.WakeCreator),
		Metadata:           cloneRawMessage(req.Metadata),
	}
	if err := spec.Validate("create_task"); err != nil {
		return taskpkg.CreateTask{}, err
	}
	return spec, nil
}

func (h *BaseHandlers) createChildTaskSpecFromRequest(
	ctx context.Context,