From 7f9850f0bddcc8f29b19fc6f3a06971aa57d9598 Mon Sep 17 00:00:00 2001 From: nick Date: Fri, 22 Nov 2024 14:56:04 +0900 Subject: [PATCH] fix: update based on feedback --- node/pkg/common/types/types.go | 4 ++++ node/pkg/websocketfetcher/app.go | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/node/pkg/common/types/types.go b/node/pkg/common/types/types.go index 5141bd5cb..4fa6a3b7e 100644 --- a/node/pkg/common/types/types.go +++ b/node/pkg/common/types/types.go @@ -84,6 +84,10 @@ func (m *LatestFeedDataMap) GetLatestFeedData(feedIds []int32) ([]*FeedData, err } func (m *LatestFeedDataMap) GetLatestFeedDataFromCache(ctx context.Context, feedIds []int32) ([]*FeedData, error) { + if len(feedIds) == 0 { + return nil, nil + } + queryingKeys := make([]string, 0, len(feedIds)) for _, feedId := range feedIds { queryingKeys = append(queryingKeys, keys.FeedData(feedId)) diff --git a/node/pkg/websocketfetcher/app.go b/node/pkg/websocketfetcher/app.go index d5fae5f39..736cb5e0d 100644 --- a/node/pkg/websocketfetcher/app.go +++ b/node/pkg/websocketfetcher/app.go @@ -44,7 +44,7 @@ import ( const ( DefaultStoreInterval = 200 * time.Millisecond DefaultBufferSize = 3000 - warmCacheTTL = 15 * time.Second + warmCacheTTL = time.Minute ) type AppConfig struct {