Method HasPendingCreditOutbox

database/lineage.go:433–445

HasPendingCreditOutbox checks if there are pending credit outbox entries for a given balance. This is used to detect race conditions where a debit is being processed before credits are complete.

(ctx context.Context, balanceID string)

// HasPendingCreditOutbox checks if there are pending credit outbox entries for a given balance.
// This is used to detect race conditions where a debit is being processed before credits are complete.
func (d Datasource) HasPendingCreditOutbox(ctx context.Context, balanceID string) (bool, error) {
	var count int
	err := d.Conn.QueryRowContext(ctx, `
		SELECT COUNT(*) FROM ledgerforge.lineage_outbox
		WHERE destination_balance_id = $1
		  AND lineage_type IN ('credit', 'both')
		  AND status IN ('pending', 'processing')
	`, balanceID).Scan(&count)
	if err != nil {
		return false, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to check pending credit outbox", err)
	}
	return count > 0, nil
}