Method RejectPendingCore

internal/agent/hitl_api.go:210–237

RejectPendingCore is the HTTP-free core of HITL reject: optional expected-agent-email match (mirrors the legacy URL guard), then RejectPending + publish. Shared by the legacy handler and the v1 layer.

(ctx context.Context, userID, messageID, expectedAgentEmail, reason string)

// expected-agent-email match (mirrors the legacy URL guard), then
// RejectPending + publish. Shared by the legacy handler and the v1 layer.
func (a *API) RejectPendingCore(ctx context.Context, userID, messageID, expectedAgentEmail, reason string) (*identity.Message, *OutboundError) {
	if expectedAgentEmail != "" {
		preview, err := a.store.GetOutboundMessageForUser(ctx, messageID, userID)
		if err != nil {
			return nil, &OutboundError{http.StatusNotFound, "not_found", "message not found"}
		}
		agent, err := a.store.GetAgentByID(ctx, preview.AgentID)
		if err != nil || agent.Email != expectedAgentEmail {
			return nil, &OutboundError{http.StatusNotFound, "not_found", "message not found"}
		}
	}
	rejected, err := a.store.RejectPending(ctx, messageID, userID, reason)
	if err != nil {
		switch {
		case errors.Is(err, identity.ErrMessageNotFound):
			return nil, &OutboundError{http.StatusNotFound, "not_found", "message not found"}
		case errors.Is(err, identity.ErrNotPendingApproval):
			return nil, &OutboundError{http.StatusConflict, "message_not_pending", "message is not pending approval"}
		default:
			log.Printf("[api] reject: %v", err)
			return nil, &OutboundError{http.StatusInternalServerError, "internal_error", "failed to reject message"}
		}
	}
	log.Printf("[mail:%s] dir=outbound type=%s status=%s agent=%s rejected_by=user:%s reason=%q",
		rejected.ID, rejected.Type, rejected.Status, rejected.AgentID, userID, reason)
	a.publishRejected(ctx, a.buildRejectedEvent(userID, rejected, reason), rejected.ID)
	return rejected, nil
}

// ApproveInboundReviewCore releases a held INBOUND message to its agent's inbox
// (status pending_review → review_approved, now readable) and fires