Function TestGetMonitorByID_Success

database/balance_test.go:1222–1253

(t *testing.T)

}

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

	ds := Datasource{Conn: db}

	query := `
		SELECT monitor_id, balance_id, field, operator, value, precision, precise_value, description, call_back_url, created_at
		FROM ledgerforge.balance_monitors WHERE monitor_id = $1
	`

	mock.ExpectQuery(regexp.QuoteMeta(query)).
		WithArgs("mon_123").
		WillReturnRows(sqlmock.NewRows([]string{
			"monitor_id", "balance_id", "field", "operator", "value", "precision", "precise_value", "description", "call_back_url", "created_at",
		}).AddRow(
			"mon_123", "bln_123", "balance", "<", 1000.0, 100, int64(100000), "Low balance alert", "https://example.com/webhook", time.Now(),
		))

	monitor, err := ds.GetMonitorByID("mon_123")
	assert.NoError(t, err)
	assert.NotNil(t, monitor)
	assert.Equal(t, "mon_123", monitor.MonitorID)
	assert.Equal(t, "bln_123", monitor.BalanceID)
	assert.Equal(t, "balance", monitor.Condition.Field)
	assert.Equal(t, "<", monitor.Condition.Operator)
	assert.Equal(t, float64(1000), monitor.Condition.Value)

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

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