diff --git a/internal/data/market/main.go b/internal/data/market/main.go index 5e1e9c3..86333cf 100644 --- a/internal/data/market/main.go +++ b/internal/data/market/main.go @@ -33,9 +33,18 @@ func NewMarketData() *MarketData { } _ = ms.StartFutureWsMarkPrice() _ = ms.StartSpotWsMarkPrice() - - // Initialize Alpha token cache - go ms.refreshAlphaTokenCache() - + + // Initialize Alpha token cache and refresh every hour + go ms.alphaCacheRefreshLoop() + return ms } + +func (ms *MarketData) alphaCacheRefreshLoop() { + ms.refreshAlphaTokenCache() + ticker := time.NewTicker(time.Hour) + defer ticker.Stop() + for range ticker.C { + ms.refreshAlphaTokenCache() + } +}