rf: move abi cache to abi util

Author: =

internal/common/abi.go

@@ -11,6 +11,21 @@ import (
 
 var contractApi string = "https://contract.thirdweb.com"
 
+func GetABIForContractWithCache(chainId string, contract string, abiCache map[string]*abi.ABI) *abi.ABI {
+	abi, ok := abiCache[contract]
+	if !ok {
+		abiResult, err := GetABIForContract(chainId, contract)
+		if err != nil {
+			abiCache[contract] = nil
+			return nil
+		} else {
+			abiCache[contract] = abiResult
+			abi = abiResult
+		}
+	}
+	return abi
+}
+
 func GetABIForContract(chainId string, contract string) (*abi.ABI, error) {
 	url := fmt.Sprintf("%s/abi/%s/%s", contractApi, chainId, contract)
 

internal/common/log.go

@@ -42,22 +42,11 @@ type DecodedLog struct {
 
 func DecodeLogs(chainId string, logs []Log) []*DecodedLog {
 	decodedLogs := make([]*DecodedLog, len(logs))
-	abis := make(map[string]*abi.ABI)
+	abiCache := make(map[string]*abi.ABI)
 
 	decodeLogFunc := func(eventLog *Log) *DecodedLog {
 		decodedLog := DecodedLog{Log: *eventLog}
-		abi, ok := abis[eventLog.Address]
-		if !ok {
-			abiResult, err := GetABIForContract(chainId, eventLog.Address)
-			if err != nil {
-				abis[eventLog.Address] = nil
-				return &decodedLog
-			} else {
-				abis[eventLog.Address] = abiResult
-			}
-			abi = abiResult
-		}
-
+		abi := GetABIForContractWithCache(chainId, eventLog.Address, abiCache)
 		if abi == nil {
 			return &decodedLog
 		}

internal/common/transaction.go

@@ -55,22 +55,10 @@ type DecodedTransaction struct {
 
 func DecodeTransactions(chainId string, txs []Transaction) []*DecodedTransaction {
 	decodedTxs := make([]*DecodedTransaction, len(txs))
-	abis := make(map[string]*abi.ABI)
-
+	abiCache := make(map[string]*abi.ABI)
 	decodeTxFunc := func(transaction *Transaction) *DecodedTransaction {
 		decodedTransaction := DecodedTransaction{Transaction: *transaction}
-		abi, ok := abis[transaction.ToAddress]
-		if !ok {
-			abiResult, err := GetABIForContract(chainId, transaction.ToAddress)
-			if err != nil {
-				abis[transaction.ToAddress] = nil
-				return &decodedTransaction
-			} else {
-				abis[transaction.ToAddress] = abiResult
-			}
-			abi = abiResult
-		}
-
+		abi := GetABIForContractWithCache(chainId, transaction.ToAddress, abiCache)
 		if abi == nil {
 			return &decodedTransaction
 		}