Function TestGetTransactionByRef_Success

database/transactions_test.go:823–861

(t *testing.T)

}

func TestGetTransactionByRef_Success(t *testing.T) {
	db, mock, err := sqlmock.New()
	assert.NoError(t, err)
	defer func() { _ = db.Close() }()

	ds := Datasource{Conn: db}
	ctx := context.Background()

	metaData := map[string]interface{}{"key": "value"}
	metaDataJSON, _ := json.Marshal(metaData)

	query := `
		SELECT transaction_id, source, reference, amount, precise_amount, currency, destination, description, status, created_at, meta_data, parent_transaction
		FROM ledgerforge.transactions
		WHERE reference = $1
	`

	mock.ExpectQuery(regexp.QuoteMeta(query)).
		WithArgs("ref_123").
		WillReturnRows(sqlmock.NewRows([]string{
			"transaction_id", "source", "reference", "amount", "precise_amount", "currency",
			"destination", "description", "status", "created_at", "meta_data", "parent_transaction",
		}).AddRow(
			"txn_123", "bln_source", "ref_123", 1000.0, "100000", "USD",
			"bln_dest", "Test transaction", "APPLIED", time.Now(), metaDataJSON, "",
		))

	txn, err := ds.GetTransactionByRef(ctx, "ref_123")
	assert.NoError(t, err)
	assert.Equal(t, "txn_123", txn.TransactionID)
	assert.Equal(t, "ref_123", txn.Reference)
	assert.Equal(t, "bln_source", txn.Source)
	assert.Equal(t, "bln_dest", txn.Destination)
	assert.Equal(t, "APPLIED", txn.Status)
	assert.Equal(t, "100000", txn.PreciseAmount.String())

	err = mock.ExpectationsWereMet()
	assert.NoError(t, err)
}

func TestGetTransactionByRef_NotFound(t *testing.T) {
	db, mock, err := sqlmock.New()