Method publishApproved

internal/agent/api.go:380–397

publishApproved fires email.review_approved via the outbox (PublishBestEffortTx — POST-side-effect: SES has already accepted the approved send) AND the legacy goroutine.

(ctx context.Context, e webhookpub.Event, sentMsg *identity.Message)

// (PublishBestEffortTx — POST-side-effect: SES has already accepted
// the approved send) AND the legacy goroutine.
func (a *API) publishApproved(ctx context.Context, e webhookpub.Event, sentMsg *identity.Message) {
	var outboxWrote bool
	if a.outbox != nil && sentMsg != nil {
		e.ID = webhookpub.DeterministicEventID(sentMsg.ID, e.Type)
		err := a.store.WithTx(ctx, func(tx pgx.Tx) error {
			outboxWrote = a.outbox.PublishBestEffortTx(ctx, tx, e)
			return nil
		})
		if err != nil {
			log.Printf("[api] outbox tx for %s err: %v", e.Type, err)
			outboxWrote = false
		}
	}
	a.emit().OutboxEventsPublished(e.Type)
	if a.shouldFireLegacy(outboxWrote) {
		a.publishAsync(e)
	}
}

// publishRejected fires email.review_rejected via the outbox (PublishTx —
// pre-side-effect: rejection is a row update, no SES involvement) AND