EVM RPC

config.example.js

@@ -48,5 +48,12 @@ module.exports = {
         type: 'ERC20'
       }
     }
+  },
+  ARBNode: {
+    chain: 'ARB',
+    host: 'localhost',
+    rpcPort: '8546',
+    protocol: 'http',
+    isEVM: true
   }
 };

docker-compose.yml

@@ -138,6 +138,7 @@ services:
       -b 2
       -g 20000000000
       -p 8545
+      -a 20
 
   rippled:
     networks:

lib/eth/EthRpc.js

@@ -3,13 +3,15 @@ const promptly = require('promptly');
 const ethers = require('ethers');
 const util = require('util');
 const EventEmitter = require('events');
+const chainConfig = require('./chains');
 
 const passwordPromptAsync = util.promisify(promptly.password);
 const setTimeoutAsync = util.promisify(setTimeout);
 
 class EthRPC {
   constructor(config) {
     this.config = config;
+    this.chain = this.config.chain;
     this.web3 = this.getWeb3(this.config);
     this.account = this.config.account;
     this.emitter = new EventEmitter();
@@ -206,7 +208,7 @@ class EthRPC {
    * Estimates the fee.
    * @param {Object} params - The parameters for estimating the fee.
    * @param {Map} params.cache - The cache of block fees.
-   * @param {number} params.defaultEstimate - The RPC estimate of the fee.
+   * @param {number} params.defaultEstimate - The default fee value.
    * @param {number} [params.percentile=25] - The percentile to use for the estimation.
    * @param {Function} params.getFees - The function to get the fees from the blocks.
    * @returns {Promise<number>} The estimated fee.
@@ -266,7 +268,8 @@ class EthRPC {
    * @returns {Promise<number>} The estimated maximum priority fee.
    */
   async estimateMaxPriorityFee({ percentile = 25 }) {
-    const defaultEstimate = parseInt(this.web3.utils.toWei('2.5', 'gwei'));
+    const minimumFee = chainConfig[this.chain] ? chainConfig[this.chain].priorityFee : 2.5;
+    const defaultEstimate = parseInt(this.web3.utils.toWei(String(minimumFee), 'gwei'));
     const getFees = (_txs) => _txs
       .filter((tx) => !!tx.maxPriorityFeePerGas)
       .map((tx) => parseInt(tx.maxPriorityFeePerGas));

lib/eth/chains.js

@@ -0,0 +1,19 @@
+const chainConfig = {
+  ETH: {
+    priorityFee: 1 // in gwei
+  },
+  MATIC: {
+    priorityFee: 30
+  },
+  OP: {
+    priorityFee: 1
+  },
+  ARB: {
+    priorityFee: 0 // transactions are processed FIFO, no priorityFee fee is necessary for Arbitrum transactions
+  },
+  BASE: {
+    priorityFee: 1
+  }
+};
+
+module.exports = chainConfig;

lib/index.js

@@ -6,7 +6,7 @@ const RpcClasses = {
   DOGE: require('./doge/DogeRpc'),
   LTC: require('./ltc/LtcRpc'),
   LNBTC: require('./lnd/LndRpc'),
-  MATIC: require('./matic/MaticRpc'),
+  MATIC: require('./matic/MaticRpc'), // keeping for backwards compatibility 
 };
 
 const TokenClasses = {
@@ -39,9 +39,25 @@ const TokenClasses = {
 };
 
 class CryptoRpcProvider {
+
+  /**
+   * Constructor for CryptoRpcProvider class.
+   * @param {Object} config - The configuration object.
+   * @param {string} config.chain - The chain to connect to.
+   * @param {boolean} config.isEVM - Optional flag indicating if the chain is EVM compatible.
+   * @param {string} config.host - The host address for RPC connection.
+   * @param {number} config.port - The port for RPC connection.
+   * @param {string} config.rpcPort - The port for RPC connection (alternative).
+   * @param {string} config.user - The username for RPC connection.
+   * @param {string} config.rpcUser - The username for RPC connection (alternative).
+   * @param {string} config.pass - The password for RPC connection.
+   * @param {string} config.rpcPass - The password for RPC connection (alternative).
+   * @param {string} config.protocol - The protocol for RPC connection.
+   * @param {Object} config.tokens - Optional tokens configuration.
+   */
   constructor(config) {
     this.chain = config.chain;
-    if (!RpcClasses[this.chain]) {
+    if (!RpcClasses[this.chain] && !config.isEVM) {
       throw new Error('Invalid chain specified');
     }
     this.config = Object.assign({}, config, {
@@ -51,12 +67,13 @@ class CryptoRpcProvider {
       pass: config.pass || config.rpcPass,
       protocol: config.protocol
     });
+    const rpcChain = !config.isEVM ? this.chain : 'ETH';
     this.rpcs = {
-      [this.chain]: new RpcClasses[this.chain](this.config)
+      [this.chain]: new RpcClasses[rpcChain](this.config)
     };
     if (config.tokens) {
       Object.entries(config.tokens).forEach(([token, tokenConfig]) => {
-        const TokenClass = TokenClasses[this.chain][tokenConfig.type];
+        const TokenClass = TokenClasses[rpcChain][tokenConfig.type];
         const configForToken = Object.assign(tokenConfig, this.config);
         this.rpcs[token] = new TokenClass(configForToken);
       });

tests/eth.js

@@ -81,7 +81,7 @@ describe('ETH Tests', function() {
     sinon.spy(ethRPC.web3.eth, 'getBlock');
     let maxFee = await ethRPC.estimateMaxFee({ percentile: 15 });
     assert.isDefined(maxFee); 
-    expect(maxFee).to.be.equal(2654455240);
+    expect(maxFee).to.be.equal(1154455240);
     expect(ethRPC.web3.eth.getBlock.callCount).to.be.lt(10);
     expect(ethRPC.emitter.emit.callCount).to.equal(0);
   });
@@ -91,7 +91,7 @@ describe('ETH Tests', function() {
     const maxPriorityFee = await ethRPC.estimateMaxPriorityFee({});
     assert.isDefined(maxPriorityFee);
     expect(maxPriorityFee).to.be.gt(0);
-    expect(maxPriorityFee).to.be.equal(2500000000);
+    expect(maxPriorityFee).to.be.equal(1000000000);
     expect(ethRPC.blockMaxPriorityFeeCache.set.callCount).to.equal(0);
   });