get address parser

KyberNetwork · Oct 3, 2024 · 29af997 · 29af997
1 parent bd151cd
commit 29af997
Show file tree

Hide file tree

Showing 12 changed files with 42 additions and 1 deletion.
diff --git a/cmd/tradelogs/main.go b/cmd/tradelogs/main.go
@@ -116,7 +116,7 @@ func run(c *cli.Context) error {
 		kyberswaprfq.MustNewParser(),
 		hashflowv3.MustNewParser(),
 		oneinchv6.MustNewParser(traceCalls),
-		uniswapxv1.MustNewParser(traceCalls),
+		// uniswapxv1.MustNewParser(traceCalls),
 		uniswapx.MustNewParser(traceCalls),
 		bebop.MustNewParser(traceCalls),
 		zxrfqv3.MustNewParserWithDeployer(traceCalls, ethClients[0], common.HexToAddress(parser.Deployer0xV3)),

diff --git a/pkg/parser/bebop/parser.go b/pkg/parser/bebop/parser.go
@@ -432,3 +432,7 @@ func getAggregateOrderInfo(order AggregateOrder) *big.Int {
 	}
 	return quoteTakerAmount
 }
+
+func (p *Parser) Address() string {
+	return parser.AddrBebop
+}
diff --git a/pkg/parser/hashflow_v3/parser.go b/pkg/parser/hashflow_v3/parser.go
@@ -131,3 +131,7 @@ func (p *Parser) LogFromExchange(log ethereumTypes.Log) bool {
 	return len(log.Topics) > 0 &&
 		strings.EqualFold(log.Topics[0].String(), p.eventHash)
 }
+
+func (p *Parser) Address() string {
+	return ""
+}
diff --git a/pkg/parser/kyberswap/parser.go b/pkg/parser/kyberswap/parser.go
@@ -89,3 +89,7 @@ func (p *Parser) LogFromExchange(log ethereumTypes.Log) bool {
 		len(log.Topics) > 0 &&
 		strings.EqualFold(log.Topics[0].String(), p.eventHash)
 }
+
+func (p *Parser) Address() string {
+	return parser.AddrKyberswap
+}
diff --git a/pkg/parser/kyberswap_rfq/parser.go b/pkg/parser/kyberswap_rfq/parser.go
@@ -134,3 +134,7 @@ func (p *Parser) LogFromExchange(log ethereumTypes.Log) bool {
 		len(log.Topics) > 0 &&
 		strings.EqualFold(log.Topics[0].String(), p.eventHash)
 }
+
+func (p *Parser) Address() string {
+	return parser.AddrKyberswapRFQ
+}
diff --git a/pkg/parser/oneinchv6/parser.go b/pkg/parser/oneinchv6/parser.go
@@ -262,3 +262,7 @@ func (p *Parser) LogFromExchange(log ethereumTypes.Log) bool {
 		len(log.Topics) > 0 &&
 		strings.EqualFold(log.Topics[0].String(), p.eventHash)
 }
+
+func (p *Parser) Address() string {
+	return parser.Addr1InchV6
+}
diff --git a/pkg/parser/pancakeswap/parser.go b/pkg/parser/pancakeswap/parser.go
@@ -291,3 +291,7 @@ func (p *Parser) LogFromExchange(log ethereumTypes.Log) bool {
 		len(log.Topics) > 0 &&
 		strings.EqualFold(log.Topics[0].String(), p.eventHash)
 }
+
+func (p *Parser) Address() string {
+	return parser.AddrPancakewap
+}
diff --git a/pkg/parser/paraswap/parser.go b/pkg/parser/paraswap/parser.go
@@ -132,3 +132,7 @@ func (p *Parser) LogFromExchange(log ethereumTypes.Log) bool {
 		len(log.Topics) > 0 &&
 		strings.EqualFold(log.Topics[0].String(), p.eventHash)
 }
+
+func (p *Parser) Address() string {
+	return parser.AddrParaswap
+}
diff --git a/pkg/parser/parser.go b/pkg/parser/parser.go
@@ -52,4 +52,5 @@ type Parser interface {
 	UseTraceCall() bool
 	ParseWithCallFrame(callFrame types.CallFrame, log ethereumTypes.Log, blockTime uint64) (storage.TradeLog, error)
 	LogFromExchange(log ethereumTypes.Log) bool
+	Address() string
 }
diff --git a/pkg/parser/uniswapx/parser.go b/pkg/parser/uniswapx/parser.go
@@ -344,3 +344,7 @@ func (p *Parser) LogFromExchange(log ethereumTypes.Log) bool {
 		len(log.Topics) > 0 &&
 		strings.EqualFold(log.Topics[0].String(), p.eventHash)
 }
+
+func (p *Parser) Address() string {
+	return parser.AddrUniswapX
+}
diff --git a/pkg/parser/zxotc/parser.go b/pkg/parser/zxotc/parser.go
@@ -131,3 +131,7 @@ func (p *Parser) LogFromExchange(log ethereumTypes.Log) bool {
 		len(log.Topics) > 0 &&
 		strings.EqualFold(log.Topics[0].String(), p.eventHash)
 }
+
+func (p *Parser) Address() string {
+	return parser.Addr0x
+}
diff --git a/pkg/parser/zxrfqv3/parser.go b/pkg/parser/zxrfqv3/parser.go
@@ -356,3 +356,7 @@ func (p *Parser) LogFromExchange(log ethereumTypes.Log) bool {
 	return p.contractABIs.containAddress(log.Address) &&
 		len(log.Topics) == 0
 }
+
+func (p *Parser) Address() string {
+	return ""
+}