Function TestFetchTransactions_Success

database/balance_test.go:1975–2005

(t *testing.T)

}

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

	ctx := context.Background()
	balanceID := "bln_test123"
	startTime := time.Now().Add(-24 * time.Hour)
	targetTime := time.Now()

	mock.ExpectBegin()
	tx, err := db.Begin()
	assert.NoError(t, err)

	mock.ExpectQuery(regexp.QuoteMeta(`SELECT precise_amount, source, destination, created_at,
               COALESCE(effective_date, created_at) as effective_date
        FROM ledgerforge.transactions
        WHERE (source = $1 OR destination = $1)
        AND COALESCE(effective_date, created_at) > $2
        AND COALESCE(effective_date, created_at) <= $3
        AND status = 'APPLIED'
        ORDER BY COALESCE(effective_date, created_at) ASC`)).
		WithArgs(balanceID, startTime, targetTime).
		WillReturnRows(sqlmock.NewRows([]string{"precise_amount", "source", "destination", "created_at", "effective_date"}).
			AddRow("1000", balanceID, "dest123", time.Now(), time.Now()))

	rows, err := fetchTransactions(ctx, tx, balanceID, startTime, targetTime)
	assert.NoError(t, err)
	assert.NotNil(t, rows)
	_ = rows.Close()
}

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