refactor: add log for zksync dexes (#42)

(cherry picked from commit bcf7f05)

Author: piavgh

pkg/source/muteswitch/pool_tracker.go

@@ -26,7 +26,9 @@ func NewPoolTracker(
 }
 
 func (d *PoolTracker) GetNewPoolState(ctx context.Context, p entity.Pool) (entity.Pool, error) {
-	logger.Infof("[MuteSwitch] Start getting new state of pool %v", p.Address)
+	logger.WithFields(logger.Fields{
+		"address": p.Address,
+	}).Infof("[%s] Start getting new state of pool", p.Type)
 
 	var (
 		reserve Reserves
@@ -62,7 +64,9 @@ func (d *PoolTracker) GetNewPoolState(ctx context.Context, p entity.Pool) (entit
 	p.SwapFee = float64(pairFee.Int64()) / bps
 	p.Timestamp = reserve.BlockTimestampLast.Int64()
 
-	logger.Infof("[MuteSwitch] Finish getting new state of pool %v", p.Address)
+	logger.WithFields(logger.Fields{
+		"address": p.Address,
+	}).Infof("[%s] Finish getting new state of pool", p.Type)
 
 	return p, nil
 }

pkg/source/syncswap/pool_tracker.go

@@ -4,12 +4,14 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"math/big"
+	"time"
+
 	"github.com/KyberNetwork/ethrpc"
-	"github.com/KyberNetwork/kyberswap-dex-lib/pkg/entity"
 	"github.com/KyberNetwork/logger"
 	"github.com/ethereum/go-ethereum/common"
-	"math/big"
-	"time"
+
+	"github.com/KyberNetwork/kyberswap-dex-lib/pkg/entity"
 )
 
 type PoolTracker struct {
@@ -44,8 +46,7 @@ func (d *PoolTracker) GetNewPoolState(ctx context.Context, p entity.Pool) (entit
 func (d *PoolTracker) getClassicPoolState(ctx context.Context, p entity.Pool) (entity.Pool, error) {
 	logger.WithFields(logger.Fields{
 		"address": p.Address,
-		"type":    p.Type,
-	}).Infof("[Syncswap] Start getting new state of pool")
+	}).Infof("[%s] Start getting new state of pool", p.Type)
 
 	var (
 		swapFee0To1, swapFee1To0 *big.Int
@@ -121,17 +122,15 @@ func (d *PoolTracker) getClassicPoolState(ctx context.Context, p entity.Pool) (e
 
 	logger.WithFields(logger.Fields{
 		"address": p.Address,
-		"type":    p.Type,
-	}).Infof("[Syncswap] Finish getting new state of pool")
+	}).Infof("[%s] Finish getting new state of pool", p.Type)
 
 	return p, nil
 }
 
 func (d *PoolTracker) getStablePoolState(ctx context.Context, p entity.Pool) (entity.Pool, error) {
 	logger.WithFields(logger.Fields{
 		"address": p.Address,
-		"type":    p.Type,
-	}).Infof("[Syncswap] Start getting new state of pool")
+	}).Infof("[%s] Start getting new state of pool", p.Type)
 
 	var (
 		swapFee0To1, swapFee1To0                             *big.Int
@@ -224,8 +223,7 @@ func (d *PoolTracker) getStablePoolState(ctx context.Context, p entity.Pool) (en
 
 	logger.WithFields(logger.Fields{
 		"address": p.Address,
-		"type":    p.Type,
-	}).Infof("[Syncswap] Finish getting new state of pool")
+	}).Infof("[%s] Finish getting new state of pool", p.Type)
 
 	return p, nil
 }

pkg/source/velodrome/pool_tracker.go

@@ -28,7 +28,7 @@ func NewPoolTracker(
 
 func (d *PoolTracker) GetNewPoolState(ctx context.Context, p entity.Pool) (entity.Pool, error) {
 	logger.WithFields(logger.Fields{
-		"poolAddress": p.Address,
+		"address": p.Address,
 	}).Infof("[%s] Start getting new state of pool", p.Type)
 
 	var (
@@ -87,6 +87,10 @@ func (d *PoolTracker) GetNewPoolState(ctx context.Context, p entity.Pool) (entit
 	p.SwapFee = float64(swapFee) / bps
 	p.Timestamp = reserve.BlockTimestampLast.Int64()
 
+	logger.WithFields(logger.Fields{
+		"address": p.Address,
+	}).Infof("[%s] Finish getting new state of pool", p.Type)
+
 	return p, nil
 }