Method createTaskSpecFromRequest

internal/extension/host_api_tasks.go:664–700

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

}

func (h *HostAPIHandler) createTaskSpecFromRequest(
	ctx context.Context,
	req apicontract.CreateTaskRequest,
) (taskpkg.CreateTask, error) {
	scope := req.Scope.Normalize()
	if err := scope.Validate("create_task.scope"); err != nil {
		return taskpkg.CreateTask{}, invalidParamsRPCError(err)
	}
	workspaceID, err := h.resolveTaskWorkspaceBinding(ctx, scope, strings.TrimSpace(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),
		Metadata:           cloneRawMessage(req.Metadata),
	}
	if err := spec.Validate("create_task"); err != nil {
		return taskpkg.CreateTask{}, invalidParamsRPCError(err)
	}
	return spec, nil
}

func taskPatchFromRequest(req apicontract.UpdateTaskRequest) (taskpkg.Patch, error) {
	if req.NetworkChannel != nil {