Method GetOutboxByTransactionID

database/lineage.go:382–429

GetOutboxByTransactionID retrieves an outbox entry by its transaction ID.

(ctx context.Context, transactionID string)

// GetOutboxByTransactionID retrieves an outbox entry by its transaction ID.
func (d Datasource) GetOutboxByTransactionID(ctx context.Context, transactionID string) (*model.LineageOutbox, error) {
	row := d.Conn.QueryRowContext(ctx, `
		SELECT id, transaction_id, source_balance_id, destination_balance_id, provider, lineage_type, payload, status, attempts, max_attempts, last_error, created_at, processed_at, locked_until, inflight
		FROM ledgerforge.lineage_outbox
		WHERE transaction_id = $1
	`, transactionID)

	var entry model.LineageOutbox
	var sourceBalanceID, destinationBalanceID, provider, lastError sql.NullString
	var processedAt, lockedUntil sql.NullTime

	err := row.Scan(
		&entry.ID,
		&entry.TransactionID,
		&sourceBalanceID,
		&destinationBalanceID,
		&provider,
		&entry.LineageType,
		&entry.Payload,
		&entry.Status,
		&entry.Attempts,
		&entry.MaxAttempts,
		&lastError,
		&entry.CreatedAt,
		&processedAt,
		&lockedUntil,
		&entry.Inflight,
	)
	if err != nil {
		if err == sql.ErrNoRows {
			return nil, nil
		}
		return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to retrieve outbox entry", err)
	}

	entry.SourceBalanceID = sourceBalanceID.String
	entry.DestinationBalanceID = destinationBalanceID.String
	entry.Provider = provider.String
	entry.LastError = lastError.String
	if processedAt.Valid {
		entry.ProcessedAt = &processedAt.Time
	}
	if lockedUntil.Valid {
		entry.LockedUntil = &lockedUntil.Time
	}

	return &entry, nil
}

// 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.