Method executeTaskBoundary

internal/task/manager.go:669–732

(
	ctx context.Context,
	id string,
	req ExecutionRequest,
	action ExecutionAction,
	actor ActorContext,
)

}

func (m *Service) executeTaskBoundary(
	ctx context.Context,
	id string,
	req ExecutionRequest,
	action ExecutionAction,
	actor ActorContext,
) (*Execution, error) {
	if err := requireWriteAuthority(actor); err != nil {
		return nil, err
	}
	trimmedID := strings.TrimSpace(id)
	if trimmedID == "" {
		return nil, fmt.Errorf("%w: task id is required", ErrValidation)
	}
	normalizedReq, err := normalizeTaskExecutionRequest(req)
	if err != nil {
		return nil, err
	}
	if err := m.validateNetworkChannel("task_execution.network_channel", normalizedReq.NetworkChannel); err != nil {
		return nil, err
	}
	idempotencyKey := taskExecutionIdempotencyKey(trimmedID, action, normalizedReq.IdempotencyKey)
	if existing, ok, err := m.taskExecutionFromIdempotency(ctx, trimmedID, idempotencyKey, action, actor); err != nil {
		return nil, err
	} else if ok {
		return existing, nil
	}

	approvalTask, err := m.prepareTaskExecutionBoundary(ctx, trimmedID, action, actor)
	if err != nil {
		return nil, err
	}

	if execution, ok, err := m.approvalAutoEnqueueExecution(
		ctx,
		approvalTask,
		normalizedReq,
		idempotencyKey,
		actor,
	); err != nil {
		return nil, err
	} else if ok {
		return execution, nil
	}

	run, err := m.EnqueueRun(ctx, EnqueueRun{
		TaskID:         trimmedID,
		IdempotencyKey: idempotencyKey,
		NetworkChannel: normalizedReq.NetworkChannel,
		Metadata:       normalizedReq.Metadata,
	}, actor)
	if err != nil {
		return nil, err
	}
	taskRecord, err := m.store.GetTask(ctx, run.TaskID)
	if err != nil {
		return nil, err
	}