txMaxSize configurable

Signed-off-by: Daisuke Kanda <[email protected]>

pkg/relay/ethereum/chain.go

@@ -47,12 +47,12 @@ type Chain struct {
 	ibcHandler *ibchandler.Ibchandler
 	multicall3 *multicall3.Multicall3
 
+	txMaxSize uint64
+
 	ethereumSigner EthereumSigner
 
 	errorRepository ErrorRepository
 
-	txMaxSize uint64
-
 	// cache
 	connectionOpenedConfirmed bool
 	allowLCFunctions          *AllowLCFunctions
@@ -61,6 +61,8 @@ type Chain struct {
 var _ core.Chain = (*Chain)(nil)
 
 func NewChain(config ChainConfig) (*Chain, error) {
+	logger := GetModuleLogger()
+
 	id := big.NewInt(int64(config.EthChainId))
 	client, err := client.NewETHClient(
 		config.RpcAddr,
@@ -107,6 +109,11 @@ func NewChain(config ChainConfig) (*Chain, error) {
 	if err != nil {
 		return nil, fmt.Errorf("failed to create error repository: %v", err)
 	}
+	txMaxSize := config.GetTxMaxSize()
+	if txMaxSize == 0 {
+		txMaxSize = 128 * 1024  // go-ethereum/core/txpool/legacypool/legacypool.go
+		logger.Info(fmt.Sprintf("txMaxSize is zero. set to %v", txMaxSize));
+	}
 
 	return &Chain{
 		config:  config,
@@ -120,7 +127,7 @@ func NewChain(config ChainConfig) (*Chain, error) {
 
 		errorRepository: errorRepository,
 
-		txMaxSize: 1024 * 128, // go-ethereum/core/txpool/legacypool/legacypool.go
+		txMaxSize: txMaxSize,
 
 		allowLCFunctions: alfs,
 	}, nil

pkg/relay/ethereum/tx.go

@@ -748,7 +748,7 @@ func (iter *CallIter) buildMultiTx(ctx context.Context, c *Chain) (*CallIterBuil
 			}
 
 			if c.txMaxSize < multiTx.Size() {
-				return fmt.Errorf("tx exceeds txMaxSize");
+				return fmt.Errorf("tx size exceeds txMaxSize: tx=%v, max=%v", multiTx.Size(), c.txMaxSize)
 			}
 
 			txGasLimit, err := estimateGas(ctx, c, multiTx, 1 == count, logger)

proto/relayer/chains/ethereum/config/config.proto

@@ -40,6 +40,8 @@ message ChainConfig {
   repeated string abi_paths = 17;
 
   string multicall3_address = 18;
+
+  optional uint64 tx_max_size = 19;
 }
 
 message AllowLCFunctionsConfig {