diff --git a/internal/cmd/market/communicator.go b/internal/cmd/market/communicator.go index b98de47..2a6cb92 100644 --- a/internal/cmd/market/communicator.go +++ b/internal/cmd/market/communicator.go @@ -64,5 +64,4 @@ func (c *communicator) newPayloadWithID(id string, data interface{}) *payload { when: time.Now(), what: data, } - } diff --git a/internal/cmd/market/market.go b/internal/cmd/market/market.go index 526a2d2..6ced66b 100644 --- a/internal/cmd/market/market.go +++ b/internal/cmd/market/market.go @@ -102,9 +102,8 @@ func NewMarket(configFilePath *string) (*MarketStruct, error) { for { time.Sleep(time.Minute) // the duration must be the time period that the watcher is watching on. - duration := time.Minute * 5 ticker := "BTCUSDT" - if synced := Market.IsSynced(ticker, duration); !synced { + if synced := Market.IsSynced(ticker, time.Minute*5); !synced { Market.notifier.notify(fmt.Sprintf("%s is out of sync for %s", ticker, duration.String())) } }