wip

KyberNetwork · Nov 15, 2023 · 3ade4ab · 3ade4ab
1 parent dd4dfcc
commit 3ade4ab
Show file tree

Hide file tree

Showing 29 changed files with 42 additions and 42 deletions.
diff --git a/pkg/source/rollup-finance/abis.go b/pkg/source/rollup-finance/abis.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"bytes"

diff --git a/pkg/source/rollup-finance/chainlink_flags.go b/pkg/source/rollup-finance/chainlink_flags.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 type ChainlinkFlags struct {
 	Flags map[string]bool `json:"flags"`

diff --git a/pkg/source/rollup-finance/chainlink_flags_reader.go b/pkg/source/rollup-finance/chainlink_flags_reader.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -20,7 +20,7 @@ func NewChainlinkFlagsReader(ethrpcClient *ethrpc.Client) *ChainlinkFlagsReader
 		abi:          chainlinkABI,
 		ethrpcClient: ethrpcClient,
 		log: logger.WithFields(logger.Fields{
-			"liquiditySource": DexTypeGmx,
+			"liquiditySource": DexTypeRollupFinance,
 			"reader":          "ChainlinkFlagsReader",
 		}),
 	}

diff --git a/pkg/source/rollup-finance/config.go b/pkg/source/rollup-finance/config.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 type Config struct {
 	DexID                   string `json:"-"`

diff --git a/pkg/source/rollup-finance/constants.go b/pkg/source/rollup-finance/constants.go
@@ -1,8 +1,8 @@
-package gmx
+package rollupfinance
 
 import "math/big"
 
-const DexTypeGmx = "gmx"
+const DexTypeRollupFinance = "rollup-finance"
 
 const flagArbitrumSeqOffline = "0xa438451d6458044c3c8cd2f6f31c91ac882a6d91"
 

diff --git a/pkg/source/rollup-finance/embed.go b/pkg/source/rollup-finance/embed.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import _ "embed"
 

diff --git a/pkg/source/rollup-finance/errors.go b/pkg/source/rollup-finance/errors.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import "errors"
 

diff --git a/pkg/source/rollup-finance/fast_price_feed_v1.go b/pkg/source/rollup-finance/fast_price_feed_v1.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"math/big"

diff --git a/pkg/source/rollup-finance/fast_price_feed_v1_reader.go b/pkg/source/rollup-finance/fast_price_feed_v1_reader.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -21,7 +21,7 @@ func NewFastPriceFeedV1Reader(ethrpcClient *ethrpc.Client) *FastPriceFeedV1Reade
 		abi:          fastPriceFeedV1ABI,
 		ethrpcClient: ethrpcClient,
 		log: logger.WithFields(logger.Fields{
-			"liquiditySource": DexTypeGmx,
+			"liquiditySource": DexTypeRollupFinance,
 			"reader":          "FastPriceFeedV1Reader",
 		}),
 	}

diff --git a/pkg/source/rollup-finance/fast_price_feed_v2.go b/pkg/source/rollup-finance/fast_price_feed_v2.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"math/big"

diff --git a/pkg/source/rollup-finance/fast_price_feed_v2_reader.go b/pkg/source/rollup-finance/fast_price_feed_v2_reader.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -21,7 +21,7 @@ func NewFastPriceFeedV2Reader(ethrpcClient *ethrpc.Client) *FastPriceFeedV2Reade
 		abi:          fastPriceFeedV2ABI,
 		ethrpcClient: ethrpcClient,
 		log: logger.WithFields(logger.Fields{
-			"liquiditySource": DexTypeGmx,
+			"liquiditySource": DexTypeRollupFinance,
 			"reader":          "FastPriceFeedV2Reader",
 		}),
 	}

diff --git a/pkg/source/rollup-finance/helper.go b/pkg/source/rollup-finance/helper.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"github.com/KyberNetwork/ethrpc"

diff --git a/pkg/source/rollup-finance/iface.go b/pkg/source/rollup-finance/iface.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"

diff --git a/pkg/source/rollup-finance/pancake_pair.go b/pkg/source/rollup-finance/pancake_pair.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import "math/big"
 

diff --git a/pkg/source/rollup-finance/pancake_pair_reader.go b/pkg/source/rollup-finance/pancake_pair_reader.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -20,7 +20,7 @@ func NewPancakePairReader(ethrpcClient *ethrpc.Client) *PancakePairReader {
 		abi:          pancakePairABI,
 		ethrpcClient: ethrpcClient,
 		log: logger.WithFields(logger.Fields{
-			"liquiditySource": DexTypeGmx,
+			"liquiditySource": DexTypeRollupFinance,
 			"reader":          "PancakePairReader",
 		}),
 	}

diff --git a/pkg/source/rollup-finance/pool_simulator.go b/pkg/source/rollup-finance/pool_simulator.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"encoding/json"

diff --git a/pkg/source/rollup-finance/pool_tracker.go b/pkg/source/rollup-finance/pool_tracker.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -34,7 +34,7 @@ func (d *PoolTracker) GetNewPoolState(
 	_ pool.GetNewPoolStateParams,
 ) (entity.Pool, error) {
 	log := logger.WithFields(logger.Fields{
-		"liquiditySource": DexTypeGmx,
+		"liquiditySource": DexTypeRollupFinance,
 		"poolAddress":     p.Address,
 	})
 	log.Info("Start getting new state of pool")

diff --git a/pkg/source/rollup-finance/pools_list_updater.go b/pkg/source/rollup-finance/pools_list_updater.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -30,7 +30,7 @@ func NewPoolsListUpdater(
 
 func (d *PoolsListUpdater) GetNewPools(ctx context.Context, metadataBytes []byte) ([]entity.Pool, []byte, error) {
 	log := logger.WithFields(logger.Fields{
-		"liquiditySource": DexTypeGmx,
+		"liquiditySource": DexTypeRollupFinance,
 		"kind":            "getNewPools",
 	})
 	if d.hasInitialized {
@@ -65,7 +65,7 @@ func (d *PoolsListUpdater) GetNewPools(ctx context.Context, metadataBytes []byte
 	pool := entity.Pool{
 		Address:   d.config.VaultAddress,
 		Exchange:  d.config.DexID,
-		Type:      DexTypeGmx,
+		Type:      DexTypeRollupFinance,
 		Tokens:    poolTokens,
 		Reserves:  reserves,
 		Extra:     string(extraBytes),

diff --git a/pkg/source/rollup-finance/price_feed.go b/pkg/source/rollup-finance/price_feed.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"math/big"

diff --git a/pkg/source/rollup-finance/price_feed_reader.go b/pkg/source/rollup-finance/price_feed_reader.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -20,7 +20,7 @@ func NewPriceFeedReader(ethrpcClient *ethrpc.Client) *PriceFeedReader {
 		abi:          priceFeedABI,
 		ethrpcClient: ethrpcClient,
 		log: logger.WithFields(logger.Fields{
-			"liquiditySource": DexTypeGmx,
+			"liquiditySource": DexTypeRollupFinance,
 			"reader":          "PriceFeedReader",
 		}),
 	}

diff --git a/pkg/source/rollup-finance/types.go b/pkg/source/rollup-finance/types.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 type VaultAddress struct {
 	Vault string `json:"vault"`

diff --git a/pkg/source/rollup-finance/usdr.go b/pkg/source/rollup-finance/usdr.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"math/big"

diff --git a/pkg/source/rollup-finance/usdr_reader.go b/pkg/source/rollup-finance/usdr_reader.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -20,7 +20,7 @@ func NewUSDRReader(ethrpcClient *ethrpc.Client) *USDRReader {
 		abi:          erc20ABI,
 		ethrpcClient: ethrpcClient,
 		log: logger.WithFields(logger.Fields{
-			"liquiditySource": DexTypeGmx,
+			"liquiditySource": DexTypeRollupFinance,
 			"reader":          "USDRReader",
 		}),
 	}

diff --git a/pkg/source/rollup-finance/vault.go b/pkg/source/rollup-finance/vault.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"math/big"

diff --git a/pkg/source/rollup-finance/vault_price_feed.go b/pkg/source/rollup-finance/vault_price_feed.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"encoding/json"

diff --git a/pkg/source/rollup-finance/vault_price_feed_reader.go b/pkg/source/rollup-finance/vault_price_feed_reader.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -22,7 +22,7 @@ func NewVaultPriceFeedReader(ethrpcClient *ethrpc.Client) *VaultPriceFeedReader
 		abi:          vaultPriceFeedABI,
 		ethrpcClient: ethrpcClient,
 		log: logger.WithFields(logger.Fields{
-			"liquiditySource": DexTypeGmx,
+			"liquiditySource": DexTypeRollupFinance,
 			"reader":          "VaultPriceFeedReader",
 		}),
 	}

diff --git a/pkg/source/rollup-finance/vault_reader.go b/pkg/source/rollup-finance/vault_reader.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -22,7 +22,7 @@ func NewVaultReader(ethrpcClient *ethrpc.Client) *VaultReader {
 		abi:          vaultABI,
 		ethrpcClient: ethrpcClient,
 		log: logger.WithFields(logger.Fields{
-			"liquiditySource": DexTypeGmx,
+			"liquiditySource": DexTypeRollupFinance,
 			"reader":          "VaultReader",
 		}),
 	}

diff --git a/pkg/source/rollup-finance/vault_scanner.go b/pkg/source/rollup-finance/vault_scanner.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"context"
@@ -39,7 +39,7 @@ func NewVaultScanner(
 		chainlinkFlagsReader:  NewChainlinkFlagsReader(ethrpcClient),
 		pancakePairReader:     NewPancakePairReader(ethrpcClient),
 		log: logger.WithFields(logger.Fields{
-			"liquiditySource": DexTypeGmx,
+			"liquiditySource": DexTypeRollupFinance,
 			"scanner":         "VaultScanner",
 		}),
 	}

diff --git a/pkg/source/rollup-finance/vault_utils.go b/pkg/source/rollup-finance/vault_utils.go
@@ -1,4 +1,4 @@
-package gmx
+package rollupfinance
 
 import (
 	"math/big"