timeout request

src/components/Indexer/ChainIndexer.ts

@@ -1,5 +1,5 @@
 import EventEmitter from 'node:events'
-import { FallbackProvider, Log, Signer } from 'ethers'
+import { JsonRpcProvider, Log, Signer } from 'ethers'
 import { SupportedNetwork } from '../../@types/blockchain.js'
 import { LOG_LEVELS_STR } from '../../utils/logging/Logger.js'
 import { isDefined, sleep } from '../../utils/util.js'
@@ -163,8 +163,8 @@ export class ChainIndexer {
       `Initial details for chain ${this.blockchain.getSupportedChain()}: RPCS start block: ${this.rpcDetails.startBlock}, Contract deployment block: ${contractDeploymentBlock}, Crawling start block: ${crawlingStartBlock}`
     )
 
-    const provider = await this.blockchain.getProvider()
-    const signer = await this.blockchain.getSigner()
+    let provider = await this.blockchain.getProvider()
+    let signer = await this.blockchain.getSigner()
     const interval = getCrawlingInterval()
     let chunkSize = this.rpcDetails.chunkSize || 1
     let successfulRetrievalCount = 0
@@ -298,7 +298,13 @@ export class ChainIndexer {
           INDEXER_LOGGER.error(
             `Error in indexing loop for chain ${this.blockchain.getSupportedChain()}: ${error.message}`
           )
+          // Reset the provider so ethers recreates it fresh on next iteration.
+          // JsonRpcProvider permanently marks configs as _lastFatalError after
+          // any RPC failure — without reset, all subsequent calls throw immediately.
+          this.blockchain.resetProvider()
           await sleep(interval)
+          provider = await this.blockchain.getProvider()
+          signer = await this.blockchain.getSigner()
         } finally {
           lockProcessing = false
         }
@@ -435,7 +441,7 @@ export class ChainIndexer {
    * Uses FIFO (First-In, First-Out) order via shift()
    */
   private async processReindexQueue(
-    provider: FallbackProvider,
+    provider: JsonRpcProvider,
     signer: Signer
   ): Promise<void> {
     while (this.reindexQueue.length > 0) {

src/components/Indexer/index.ts

@@ -218,7 +218,7 @@ export class OceanIndexer {
     interval: number = 5000 // in milliseconds, default 2 secs
   ): Promise<boolean> {
     try {
-      const retryInterval = Math.max(blockchain.getKnownRPCs().length * 3000, interval) // give 2 secs per each one
+      const retryInterval = Math.max(3000, interval)
       const result = await this.startCrawler(blockchain)
       const dbActive = this.getDatabase()
       if (!dbActive || !(await isReachableConnection(dbActive.getConfig().url))) {

src/components/Indexer/processor.ts

@@ -1,4 +1,4 @@
-import { ethers, Signer, FallbackProvider, Interface, getAddress } from 'ethers'
+import { ethers, Signer, JsonRpcProvider, Interface, getAddress } from 'ethers'
 import { BlocksEvents, ProcessingEvents } from '../../@types/blockchain.js'
 import { EVENTS } from '../../utils/constants.js'
 import { getConfiguration } from '../../utils/config.js'
@@ -58,7 +58,7 @@ function getEventProcessor(eventType: string, chainId: number): BaseEventProcess
 export const processChunkLogs = async (
   logs: readonly ethers.Log[],
   signer: Signer,
-  provider: FallbackProvider,
+  provider: JsonRpcProvider,
   chainId: number
 ): Promise<BlocksEvents> => {
   const storeEvents: BlocksEvents = {}
@@ -185,7 +185,7 @@ export const processChunkLogs = async (
 export const processBlocks = async (
   blockLogs: ethers.Log[],
   signer: Signer,
-  provider: FallbackProvider,
+  provider: JsonRpcProvider,
   network: number,
   lastIndexedBlock: number,
   count: number

src/components/Indexer/processors/BaseProcessor.ts

@@ -9,7 +9,7 @@ import {
   hexlify,
   getBytes,
   toUtf8String,
-  FallbackProvider
+  JsonRpcProvider
 } from 'ethers'
 import { Readable } from 'winston-transport'
 import { DecryptDDOCommand, NonceCommand } from '../../../@types/commands.js'
@@ -83,7 +83,7 @@ export abstract class BaseEventProcessor {
   }
 
   protected async getEventData(
-    provider: FallbackProvider,
+    provider: JsonRpcProvider,
     transactionHash: string,
     abi: any,
     eventType: string
@@ -487,7 +487,7 @@ export abstract class BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider,
+    provider: JsonRpcProvider,
     eventName?: string
   ): Promise<any>
 }

src/components/Indexer/processors/DispenserActivatedEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider, ZeroAddress } from 'ethers'
+import { ethers, Signer, JsonRpcProvider, ZeroAddress } from 'ethers'
 import { EVENTS } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -20,7 +20,7 @@ export class DispenserActivatedEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     const decodedEventData = await this.getEventData(
       provider,

src/components/Indexer/processors/DispenserCreatedEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager, PriceType } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider, ZeroAddress } from 'ethers'
+import { ethers, Signer, JsonRpcProvider, ZeroAddress } from 'ethers'
 import { EVENTS } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -20,7 +20,7 @@ export class DispenserCreatedEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     const decodedEventData = await this.getEventData(
       provider,

src/components/Indexer/processors/DispenserDeactivatedEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider, ZeroAddress } from 'ethers'
+import { ethers, Signer, JsonRpcProvider, ZeroAddress } from 'ethers'
 import { EVENTS } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -20,7 +20,7 @@ export class DispenserDeactivatedEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     const decodedEventData = await this.getEventData(
       provider,

src/components/Indexer/processors/ExchangeActivatedEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider, ZeroAddress } from 'ethers'
+import { ethers, Signer, JsonRpcProvider, ZeroAddress } from 'ethers'
 import { EVENTS } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -20,7 +20,7 @@ export class ExchangeActivatedEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     try {
       if (!(await isValidFreContract(event.address, chainId, signer))) {

src/components/Indexer/processors/ExchangeCreatedEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider, ZeroAddress } from 'ethers'
+import { ethers, Signer, JsonRpcProvider, ZeroAddress } from 'ethers'
 import { EVENTS } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -20,7 +20,7 @@ export class ExchangeCreatedEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     try {
       if (!(await isValidFreContract(event.address, chainId, signer))) {

src/components/Indexer/processors/ExchangeDeactivatedEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider, ZeroAddress } from 'ethers'
+import { ethers, Signer, JsonRpcProvider, ZeroAddress } from 'ethers'
 import { EVENTS } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -20,7 +20,7 @@ export class ExchangeDeactivatedEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     if (!(await isValidFreContract(event.address, chainId, signer))) {
       INDEXER_LOGGER.error(

src/components/Indexer/processors/ExchangeRateChangedEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider, ZeroAddress } from 'ethers'
+import { ethers, Signer, JsonRpcProvider, ZeroAddress } from 'ethers'
 import { EVENTS } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -20,7 +20,7 @@ export class ExchangeRateChangedEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     try {
       if (!(await isValidFreContract(event.address, chainId, signer))) {

src/components/Indexer/processors/MetadataEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager, DDO, VersionedDDO } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider, getAddress } from 'ethers'
+import { ethers, Signer, JsonRpcProvider, getAddress } from 'ethers'
 import {
   ENVIRONMENT_VARIABLES,
   EVENTS,
@@ -23,7 +23,7 @@ export class MetadataEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider,
+    provider: JsonRpcProvider,
     eventName: string
   ): Promise<any> {
     let did = 'did:op'

src/components/Indexer/processors/MetadataStateEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider } from 'ethers'
+import { ethers, Signer, JsonRpcProvider } from 'ethers'
 import { EVENTS, MetadataStates } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -13,7 +13,7 @@ export class MetadataStateEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     _signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     INDEXER_LOGGER.logMessage(`Processing metadata state event...`, true)
     const decodedEventData = await this.getEventData(

src/components/Indexer/processors/OrderReusedEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider } from 'ethers'
+import { ethers, Signer, JsonRpcProvider } from 'ethers'
 import { EVENTS } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -18,7 +18,7 @@ export class OrderReusedEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     const decodedEventData = await this.getEventData(
       provider,

src/components/Indexer/processors/OrderStartedEventProcessor.ts

@@ -1,5 +1,5 @@
 import { DDOManager } from '@oceanprotocol/ddo-js'
-import { ethers, Signer, FallbackProvider } from 'ethers'
+import { ethers, Signer, JsonRpcProvider } from 'ethers'
 import { EVENTS } from '../../../utils/constants.js'
 import { getDatabase } from '../../../utils/database.js'
 import { INDEXER_LOGGER } from '../../../utils/logging/common.js'
@@ -13,7 +13,7 @@ export class OrderStartedEventProcessor extends BaseEventProcessor {
     event: ethers.Log,
     chainId: number,
     signer: Signer,
-    provider: FallbackProvider
+    provider: JsonRpcProvider
   ): Promise<any> {
     const decodedEventData = await this.getEventData(
       provider,

src/components/Indexer/utils.ts

@@ -1,4 +1,4 @@
-import { Signer, ethers, getAddress, FallbackProvider } from 'ethers'
+import { Signer, ethers, getAddress, JsonRpcProvider } from 'ethers'
 import ERC721Factory from '@oceanprotocol/contracts/artifacts/contracts/ERC721Factory.sol/ERC721Factory.json' with { type: 'json' }
 import ERC721Template from '@oceanprotocol/contracts/artifacts/contracts/templates/ERC721Template.sol/ERC721Template.json' with { type: 'json' }
 import { EVENT_HASHES, isDefined } from '../../utils/index.js'
@@ -61,15 +61,13 @@
   return deployedBlock
 }
 
-export const getNetworkHeight = async (provider: FallbackProvider) => {
-  const networkHeight = await provider.getBlockNumber()
-
-  return networkHeight
+export const getNetworkHeight = async (provider: JsonRpcProvider): Promise<number> => {
+  return provider.getBlockNumber()
 }
 
 export const retrieveChunkEvents = async (
   signer: Signer,
-  provider: FallbackProvider,
+  provider: JsonRpcProvider,
   network: number,
   lastIndexedBlock: number,
   count: number

src/components/KeyManager/index.ts

@@ -1,5 +1,5 @@
 import type { PeerId } from '@libp2p/interface'
-import { Signer, Wallet, FallbackProvider } from 'ethers'
+import { Signer, Wallet, JsonRpcProvider } from 'ethers'
 import { IKeyProvider } from '../../@types/KeyManager.js'
 import { OceanNodeConfig } from '../../@types/OceanNode.js'
 import { RawPrivateKeyProvider } from './providers/RawPrivateKeyProvider.js'
@@ -96,7 +96,7 @@ export class KeyManager {
    * @param provider - The JSON-RPC provider to connect the signer to
    * @returns An ethers Signer instance
    */
-  async getEvmSigner(provider: FallbackProvider, chainId?: number): Promise<Signer> {
+  async getEvmSigner(provider: JsonRpcProvider, chainId?: number): Promise<Signer> {
     // Create a cache key based on chainId and provider URL
     // TO DO
     if (!chainId) {

src/components/core/utils/feesHandler.ts

@@ -1,6 +1,6 @@
 import type { ComputeResourcesPricingInfo } from '../../../@types/C2D/C2D.js'
 import {
-  FallbackProvider,
+  JsonRpcProvider,
   ethers,
   Interface,
   BigNumberish,
@@ -134,7 +134,7 @@ export async function createProviderFee(
 export async function verifyProviderFees(
   txId: string,
   userAddress: string,
-  provider: FallbackProvider,
+  provider: JsonRpcProvider,
   service: Service
 ): Promise<ProviderFeeValidation> {
   /* given a transaction, check if there is a valid provider fee event

src/components/core/utils/validateOrders.ts

@@ -1,4 +1,4 @@
-import { Contract, Interface, TransactionReceipt, Signer, FallbackProvider } from 'ethers'
+import { Contract, Interface, TransactionReceipt, Signer, JsonRpcProvider } from 'ethers'
 import { fetchEventFromTransaction } from '../../../utils/util.js'
 import ERC20Template from '@oceanprotocol/contracts/artifacts/contracts/templates/ERC20TemplateEnterprise.sol/ERC20TemplateEnterprise.json' with { type: 'json' }
 import ERC721Template from '@oceanprotocol/contracts/artifacts/contracts/templates/ERC721Template.sol/ERC721Template.json' with { type: 'json' }
@@ -14,7 +14,7 @@ const sleep = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms))
 
 export async function fetchTransactionReceipt(
   txId: string,
-  provider: FallbackProvider,
+  provider: JsonRpcProvider,
   retries: number = 2
 ): Promise<TransactionReceipt> {
   while (retries > 0) {
@@ -39,7 +39,7 @@ export async function fetchTransactionReceipt(
 export async function validateOrderTransaction(
   txId: string,
   userAddress: string,
-  provider: FallbackProvider,
+  provider: JsonRpcProvider,
   dataNftAddress: string,
   datatokenAddress: string,
   serviceIndex: number,