Function TestFetchTransactions_Error

database/balance_test.go:2007–2038

(t *testing.T)

}

func TestFetchTransactions_Error(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).
		WillReturnError(sql.ErrConnDone)

	rows, err := fetchTransactions(ctx, tx, balanceID, startTime, targetTime)
	assert.Error(t, err)
	assert.Nil(t, rows)
	apiErr, ok := err.(apierror.APIError)
	assert.True(t, ok)
	assert.Equal(t, apierror.ErrInternalServer, apiErr.Code)
}

func TestApplyTransaction_Debit(t *testing.T) {
	balanceID := "bln_test123"