add mark fusion for oneinchv6 parser

KyberNetwork · Dec 18, 2024 · 2cc0e5d · 2cc0e5d
1 parent 92322c5
commit 2cc0e5d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/v2/cmd/backfill/main.go b/v2/cmd/backfill/main.go
@@ -27,7 +27,7 @@ import (
 	promotion1inchv2 "github.com/KyberNetwork/tradelogs/v2/pkg/promotionparser/oneinchv2"
 	"github.com/KyberNetwork/tradelogs/v2/pkg/rpcnode"
 	"github.com/KyberNetwork/tradelogs/v2/pkg/storage/backfill"
-	promoteeStorage "github.com/KyberNetwork/tradelogs/v2/pkg/storage/promotees"
+	promotee_storage "github.com/KyberNetwork/tradelogs/v2/pkg/storage/promotees"
 	"github.com/KyberNetwork/tradelogs/v2/pkg/storage/state"
 	"github.com/KyberNetwork/tradelogs/v2/pkg/storage/tradelogs"
 	bebopStorage "github.com/KyberNetwork/tradelogs/v2/pkg/storage/tradelogs/bebop"
@@ -99,10 +99,10 @@ func run(c *cli.Context) error {
 	manager := tradelogs.NewManager(l, storages)
 
 	//promotee storage
-	promotee_storage := promoteeStorage.New(l, db)
+	promoteeStorage := promotee_storage.New(l, db)
 
 	// mark fusion for oneinchv6
-	markFusion, err := oneinchv6.NewMarkFusion(promotee_storage, l)
+	markFusion, err := oneinchv6.NewMarkFusion(promoteeStorage, l)
 	if err != nil {
 		return fmt.Errorf("cannot init mark fusion: %w", err)
 	}
@@ -161,7 +161,7 @@ func run(c *cli.Context) error {
 	}
 
 	// trade log handler
-	tradeLogHandler := handler.NewTradeLogHandler(l, rpcNode, manager, promotee_storage, parsers, promotionParsers, broadcastTopic, kafkaPublisher)
+	tradeLogHandler := handler.NewTradeLogHandler(l, rpcNode, manager, promoteeStorage, parsers, promotionParsers, broadcastTopic, kafkaPublisher)
 
 	// parse log worker
 	w := worker.NewBackFiller(tradeLogHandler, backfillStorage, stateStorage, l, rpcNode, parsers)

diff --git a/v2/cmd/parse_log/main.go b/v2/cmd/parse_log/main.go
@@ -27,7 +27,7 @@ import (
 	"github.com/KyberNetwork/tradelogs/v2/pkg/promotionparser"
 	promotion1inchv2 "github.com/KyberNetwork/tradelogs/v2/pkg/promotionparser/oneinchv2"
 	"github.com/KyberNetwork/tradelogs/v2/pkg/rpcnode"
-	promoteeStorage "github.com/KyberNetwork/tradelogs/v2/pkg/storage/promotees"
+	promotee_storage "github.com/KyberNetwork/tradelogs/v2/pkg/storage/promotees"
 	"github.com/KyberNetwork/tradelogs/v2/pkg/storage/state"
 	"github.com/KyberNetwork/tradelogs/v2/pkg/storage/tradelogs"
 	bebopStorage "github.com/KyberNetwork/tradelogs/v2/pkg/storage/tradelogs/bebop"
@@ -98,10 +98,10 @@ func run(c *cli.Context) error {
 	})
 
 	//promotee storage
-	promotee_storage := promoteeStorage.New(l, db)
+	promoteeStorage := promotee_storage.New(l, db)
 
 	// mark fusion for oneinchv6
-	markFusion, err := oneinchv6.NewMarkFusion(promotee_storage, l)
+	markFusion, err := oneinchv6.NewMarkFusion(promoteeStorage, l)
 	if err != nil {
 		return fmt.Errorf("cannot init mark fusion: %w", err)
 	}
@@ -157,7 +157,7 @@ func run(c *cli.Context) error {
 	}
 
 	// trade log handler
-	tradeLogHandler := handler.NewTradeLogHandler(l, rpcNode, manager, promotee_storage, parsers, promotionParsers, broadcastTopic, kafkaPublisher)
+	tradeLogHandler := handler.NewTradeLogHandler(l, rpcNode, manager, promoteeStorage, parsers, promotionParsers, broadcastTopic, kafkaPublisher)
 
 	// parse log worker
 	w := worker.NewParseLog(tradeLogHandler, s, l)