Method publishTaskIntent

internal/task/manager.go:860–900

(ctx context.Context, id string, actor ActorContext)

}

func (m *Service) publishTaskIntent(ctx context.Context, id string, actor ActorContext) (*Task, error) {
	record, err := m.store.GetTask(ctx, id)
	if err != nil {
		return nil, err
	}
	if record.Status.Normalize() != TaskStatusDraft {
		return nil, fmt.Errorf(
			"%w: task %q cannot publish from %q",
			ErrInvalidStatusTransition,
			record.ID,
			record.Status,
		)
	}

	candidate := record
	candidate.Status = TaskStatusPending
	if err := m.ensureTaskExecutable(ctx, candidate); err != nil {
		return nil, err
	}

	record.Status = TaskStatusPending
	record.UpdatedAt = m.now().UTC()
	record.ClosedAt = time.Time{}
	if err := m.store.UpdateTask(ctx, record); err != nil {
		return nil, err
	}

	reconciled, err := m.reconcileTaskCascade(ctx, record.ID)
	if err != nil {
		return nil, err
	}
	if err := m.recordTaskEvent(ctx, reconciled.ID, "", taskEventPublished, actor, publishedTaskPayload{
		PreviousStatus: TaskStatusDraft,
		Status:         reconciled.Status,
		ApprovalState:  reconciled.ApprovalState,
	}); err != nil {
		return nil, err
	}

	return &reconciled, nil
}

func (m *Service) transitionTaskApproval(
	ctx context.Context,