Function recordTransactionInTx

database/transaction.go:84–109

recordTransactionInTx inserts a transaction record within an existing database transaction. This is a helper function used by RecordTransactionWithBalances for atomic operations.

(ctx context.Context, tx *sql.Tx, txn *model.Transaction)

// recordTransactionInTx inserts a transaction record within an existing database transaction.
// This is a helper function used by RecordTransactionWithBalances for atomic operations.
func recordTransactionInTx(ctx context.Context, tx *sql.Tx, txn *model.Transaction) error {
	ctx, span := otel.Tracer("transaction.database").Start(ctx, "recordTransactionInTx")
	defer span.End()

	metaDataJSON, err := json.Marshal(txn.MetaData)
	if err != nil {
		span.RecordError(err)
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to marshal metadata", err)
	}

	_, err = tx.ExecContext(ctx,
		`INSERT INTO ledgerforge.transactions(transaction_id, parent_transaction, source, reference, amount, precise_amount, precision, rate, currency, destination, description, status, created_at, meta_data, scheduled_for, hash, effective_date)
		 VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17)`,
		txn.TransactionID, txn.ParentTransaction, txn.Source, txn.Reference, txn.AmountString, txn.PreciseAmount.String(), txn.Precision, txn.Rate, txn.Currency, txn.Destination, txn.Description, txn.Status, txn.CreatedAt, metaDataJSON, txn.ScheduledFor, txn.Hash, txn.EffectiveDate,
	)
	if err != nil {
		span.RecordError(err)
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to record transaction", err)
	}

	span.AddEvent("Transaction recorded in transaction", trace.WithAttributes(
		attribute.String("transaction.id", txn.TransactionID),
	))

	return nil
}

// recordTransactionsInTx inserts multiple transaction records within an existing database
// transaction using PostgreSQL's COPY protocol to reduce SQL parsing and roundtrips.