Merge pull request #135 from fioprotocol/main

Main > Release 1.4.x

.env.example

@@ -5,6 +5,7 @@ FIO_SERVER_URL_ACTION=
 FIO_GET_TABLE_ROWS_OFFSET=
 FIO_HISTORY_HYPERION_OFFSET=
 FIO_TRANSACTION_MAX_RETRIES=
+LOWEST_ORACLE_ID=
 
 FIO_ORACLE_PRIVATE_KEY=
 FIO_ORACLE_ACCOUNT=

README.md

@@ -26,6 +26,7 @@ FIO_SERVER_URL_ACTION=       # URL of FIO API node
 FIO_HISTORY_HYPERION_OFFSET= # The number of actions to get from history when using hyperion version
 FIO_TRANSACTION_MAX_RETRIES= # The number of retries when FIO action call fails
 FIO_GET_TABLE_ROWS_OFFSET=   # Offset for FIO get tables rows action
+LOWEST_ORACLE_ID=            # WARNING! This is REQUIRED! If not set, incorrect wraps could be created, and tokens may be lost! The value of the wrapped oracle ID from the FIO chain table. Oracle items lower than this value should not be used to avoid wrapping already processed items.
 
 FIO_ORACLE_PRIVATE_KEY=      # The FIO private key used for approving unwrap transactions
 FIO_ORACLE_ACCOUNT=          # The FIO account used for approving unwrap transactions

config/config.js

@@ -33,6 +33,7 @@ export default {
     FIO_TRANSACTION_MAX_RETRIES: parseInt(process.env.FIO_TRANSACTION_MAX_RETRIES),
     FIO_GET_TABLE_ROWS_OFFSET: parseInt(process.env.FIO_GET_TABLE_ROWS_OFFSET),
     FIO_HISTORY_HYPERION_OFFSET: process.env.FIO_HISTORY_HYPERION_OFFSET,
+    LOWEST_ORACLE_ID: parseInt(process.env.LOWEST_ORACLE_ID),
   },
   gas: {
     GAS_PRICE_LEVEL: process.env.GAS_PRICE_LEVEL,

controller/api/fio.js

@@ -55,7 +55,7 @@ import MathOp from '../utils/math.js';
 
 const {
   eth: { BLOCKS_RANGE_LIMIT_ETH, BLOCKS_OFFSET_ETH, ETH_CONTRACT, ETH_NFT_CONTRACT },
-  fio: { FIO_TRANSACTION_MAX_RETRIES, FIO_HISTORY_HYPERION_OFFSET },
+  fio: { FIO_TRANSACTION_MAX_RETRIES, FIO_HISTORY_HYPERION_OFFSET, LOWEST_ORACLE_ID },
   infura: { eth, polygon },
   nfts: { NFT_CHAIN_NAME },
   oracleCache,
@@ -255,7 +255,8 @@ class FIOCtrl {
     }
 
     const handleWrapAction = async () => {
-      const lastProcessedFioOracleItemId = getLastProcessedFioOracleItemId();
+      const lastProcessedFioOracleItemId =
+        getLastProcessedFioOracleItemId() || LOWEST_ORACLE_ID;
 
       console.log(`${logPrefix} start oracle from id = ${lastProcessedFioOracleItemId}`);
 
@@ -719,6 +720,8 @@ class FIOCtrl {
                 ? lastDeltasItem.block_num - 1
                 : lastDeltasItem.block_num;
             }
+            // add 1 sec to decrease 429 Too Many requests
+            await sleep(SECOND_IN_MILLISECONDS);
 
             await getFioBurnedDomainsLogsAll(params);
           }