fix: add missing latestFeedDataMap declaration

Bisonai · Aug 13, 2024 · 8b54e9f · 8b54e9f
1 parent 8a5c8b5
commit 8b54e9f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/node/pkg/websocketfetcher/app.go b/node/pkg/websocketfetcher/app.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"os"
+	"sync"
 	"time"
 
 	"bisonai.com/orakl/node/pkg/chain/websocketchainreader"
@@ -144,13 +145,16 @@ func (a *App) Init(ctx context.Context, opts ...AppOption) error {
 		StoreInterval: DefaultStoreInterval,
 		LatestFeedDataMap: &types.LatestFeedDataMap{
 			FeedDataMap: make(map[int32]*types.FeedData),
+			Mu:          sync.RWMutex{},
 		},
 	}
 
 	for _, opt := range opts {
 		opt(appConfig)
 	}
 
+	a.latestFeedDataMap = appConfig.LatestFeedDataMap
+
 	if err := a.initializeCex(ctx, *appConfig); err != nil {
 		return err
 	}