From bc0e95f174a7b0a4a2505c1fc85ac10f8d434c8b Mon Sep 17 00:00:00 2001 From: Vladyslav Burzakovskyy Date: Fri, 20 Dec 2019 14:20:17 +0100 Subject: [PATCH] websocket: make allFiatRates parameter string a constant --- server/websocket.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/server/websocket.go b/server/websocket.go index 437faddf..51fceab4 100644 --- a/server/websocket.go +++ b/server/websocket.go @@ -23,6 +23,9 @@ const upgradeFailed = "Upgrade failed: " const outChannelSize = 500 const defaultTimeout = 60 * time.Second +// allRates is a special "currency" parameter that means all available currencies +const allFiatRates = "!ALL!" + var ( // ErrorMethodNotAllowed is returned when client tries to upgrade method other than GET ErrorMethodNotAllowed = errors.New("Method not allowed") @@ -699,7 +702,7 @@ func (s *WebsocketServer) subscribeFiatRates(c *websocketChannel, currency strin defer s.fiatRatesSubscriptionsLock.Unlock() if currency == "" { - currency = "!ALL!" + currency = allFiatRates } as, ok := s.fiatRatesSubscriptions[currency] if !ok { @@ -822,7 +825,7 @@ func (s *WebsocketServer) OnNewFiatRatesTicker(ticker *db.CurrencyRatesTicker) { for currency, rate := range ticker.Rates { s.broadcastTicker(currency, map[string]float64{currency: rate}) } - s.broadcastTicker("!ALL!", ticker.Rates) + s.broadcastTicker(allFiatRates, ticker.Rates) } func (s *WebsocketServer) getCurrentFiatRates(currency string) (interface{}, error) {