From e40838b809c8977a25a73a718481483a21437321 Mon Sep 17 00:00:00 2001 From: ohager Date: Wed, 8 Nov 2023 15:16:33 -0300 Subject: [PATCH] chore: transparent node connection --- docs/classes/ChainWalker.html | 50 +++++++++++----------- docs/interfaces/ChainWalkerConfig.html | 16 +++---- docs/interfaces/ChainWalkerContext.html | 4 +- docs/types/BeforeQuitHandler.html | 2 +- docs/types/BlockHandler.html | 2 +- docs/types/PendingTransactionsHandler.html | 2 +- docs/types/TransactionHandler.html | 2 +- examples/walk.ts | 2 +- package.json | 2 +- src/chainWalker.ts | 21 ++++++--- 10 files changed, 56 insertions(+), 47 deletions(-) diff --git a/docs/classes/ChainWalker.html b/docs/classes/ChainWalker.html index e2d1d90..1d6a97a 100644 --- a/docs/classes/ChainWalker.html +++ b/docs/classes/ChainWalker.html @@ -36,7 +36,7 @@

Hierarchy

+
  • Defined in chainWalker.ts:156
    • @@ -92,59 +92,59 @@

    Parameters

    config: ChainWalkerConfig

    Returns ChainWalker

    +
  • Defined in chainWalker.ts:172

    • Properties

    Private beforeQuitHandler

    beforeQuitHandler: BeforeQuitHandler = ...
    +
  • Defined in chainWalker.ts:168

    • Private blockHandler

    blockHandler: BlockHandler
    +
  • Defined in chainWalker.ts:163

    • Private cache

    cache: Cache
    +
  • Defined in chainWalker.ts:161

    • Private config

    config: ChainWalkerConfig = DefaultConfig
    +
  • Defined in chainWalker.ts:157

    • Private ledger

    ledger: MockLedger | Api
    +
  • Defined in chainWalker.ts:158

    • Private logger

    logger: BaseLogger
    +
  • Defined in chainWalker.ts:169

    • Private pendingTransactionsHandler

    pendingTransactionsHandler: PendingTransactionsHandler
    +
  • Defined in chainWalker.ts:167

    • Private scheduler

    scheduler: null | ToadScheduler = null
    +
  • Defined in chainWalker.ts:159

    • Private stopRequested

    stopRequested: boolean = false
    +
  • Defined in chainWalker.ts:170

    • Private transactionHandler

    transactionHandler: TransactionHandler
    +
  • Defined in chainWalker.ts:165

    • Accessors

    @@ -156,7 +156,7 @@

    ledgerClientReturns Api

    the internal ledger client

    +
  • Defined in chainWalker.ts:189

    • Methods

    @@ -166,7 +166,7 @@

    Private

  • Returns void

    • +
  • Defined in chainWalker.ts:357

    • Private fetchBlock

    Returns Promise<null | Block>

    +
  • Defined in chainWalker.ts:369

    • Private fetchCurrentBlockHeight

    +
  • Defined in chainWalker.ts:505

    • listen

    +
  • Defined in chainWalker.ts:297

    • Private listenForQuit

    +
  • Defined in chainWalker.ts:483

    • onBeforeQuit

    Returns ChainWalker

    +
  • Defined in chainWalker.ts:228

    • onBlock

    Returns ChainWalker

    +
  • Defined in chainWalker.ts:198

    • onPendingTransactions

    Returns ChainWalker

    +
  • Defined in chainWalker.ts:220

    • onTransaction

    Returns ChainWalker

    +
  • Defined in chainWalker.ts:208

    • Private process

    +
  • Defined in chainWalker.ts:380

    • stop

    +
  • Defined in chainWalker.ts:343

    • walk

    +
  • Defined in chainWalker.ts:251
    • diff --git a/docs/interfaces/ChainWalkerConfig.html b/docs/interfaces/ChainWalkerConfig.html index dcf6b83..fc134ea 100644 --- a/docs/interfaces/ChainWalkerConfig.html +++ b/docs/interfaces/ChainWalkerConfig.html @@ -23,7 +23,7 @@

    Hierarchy

    • ChainWalkerConfig
    +
  • Defined in chainWalker.ts:67
    • @@ -59,7 +59,7 @@

    Default

    0
    +
  • Defined in chainWalker.ts:120

    • Optional cachePath

    cachePath?: string
    @@ -68,7 +68,7 @@

    OptionalDefault

    ./chainwalker.cache.json (current working directory)

    +
  • Defined in chainWalker.ts:98

    • Optional intervalSeconds

    intervalSeconds?: number
    @@ -80,7 +80,7 @@

    Default

    5
    +
  • Defined in chainWalker.ts:85

    • Optional maxRetries

    maxRetries?: number
    @@ -91,7 +91,7 @@

    Default

    3
    +
  • Defined in chainWalker.ts:92

    • Optional mockLedger

    mockLedger?: MockLedger
    @@ -99,7 +99,7 @@

    Optional

    +
  • Defined in chainWalker.ts:104

    • nodeHost

    nodeHost: string
    @@ -109,7 +109,7 @@

    nodeHosthttp://localhost:8125

    +
  • Defined in chainWalker.ts:74

    • Optional verbose

    verbose?: boolean
    @@ -119,7 +119,7 @@

    Default

    false
    +
  • Defined in chainWalker.ts:79
    • diff --git a/docs/interfaces/ChainWalkerContext.html b/docs/interfaces/ChainWalkerContext.html index 8d70da5..125c809 100644 --- a/docs/interfaces/ChainWalkerContext.html +++ b/docs/interfaces/ChainWalkerContext.html @@ -23,7 +23,7 @@

    Hierarchy

    • ChainWalkerContext
    +
  • Defined in chainWalker.ts:23
    • @@ -39,7 +39,7 @@

    Properties

    ledgerClient

    ledgerClient: Api
    +
  • Defined in chainWalker.ts:24
    • diff --git a/docs/types/BeforeQuitHandler.html b/docs/types/BeforeQuitHandler.html index d250668..cf4bcfa 100644 --- a/docs/types/BeforeQuitHandler.html +++ b/docs/types/BeforeQuitHandler.html @@ -33,7 +33,7 @@

    Parameters

    ctx: ChainWalkerContext

    Returns Promise<void> | void

    +
  • Defined in chainWalker.ts:60
    • diff --git a/docs/types/BlockHandler.html b/docs/types/BlockHandler.html index 79a7086..9cb4405 100644 --- a/docs/types/BlockHandler.html +++ b/docs/types/BlockHandler.html @@ -36,7 +36,7 @@
    block: ctx: ChainWalkerContext

    Returns Promise<void> | void

    +
  • Defined in chainWalker.ts:33
    • diff --git a/docs/types/PendingTransactionsHandler.html b/docs/types/PendingTransactionsHandler.html index ea0a0e0..951f795 100644 --- a/docs/types/PendingTransactionsHandler.html +++ b/docs/types/PendingTransactionsHandler.html @@ -36,7 +36,7 @@
    tx: ctx: ChainWalkerContext

    Returns Promise<void> | void

    +
  • Defined in chainWalker.ts:50
    • diff --git a/docs/types/TransactionHandler.html b/docs/types/TransactionHandler.html index 9ea3f36..b128822 100644 --- a/docs/types/TransactionHandler.html +++ b/docs/types/TransactionHandler.html @@ -34,7 +34,7 @@
    tx: ctx: ChainWalkerContext

    Returns Promise<void> | void

    +
  • Defined in chainWalker.ts:41
    • diff --git a/examples/walk.ts b/examples/walk.ts index fb74c84..5e9fd81 100644 --- a/examples/walk.ts +++ b/examples/walk.ts @@ -8,7 +8,7 @@ let movedSigna = Amount.Zero(); const walker = new ChainWalker({ nodeHost: "http://localhost:6876", - verbose: false, + verbose: true, cachePath: "./example.catchUpBlockchain.cache.json", }) .onBlock(() => { diff --git a/package.json b/package.json index e509801..ac9e247 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "signum-chain-walker", - "version": "1.0.5", + "version": "1.0.6", "description": "", "main": "dist/index.js", "private": false, diff --git a/src/chainWalker.ts b/src/chainWalker.ts index 53e454e..773fdab 100644 --- a/src/chainWalker.ts +++ b/src/chainWalker.ts @@ -507,12 +507,21 @@ export class ChainWalker { this.logger.trace( `Trying to reach node under ${this.config.nodeHost} ...` ); - const { height } = await pRetry(() => - this.ledger.block.getBlockByHeight( - // @ts-ignore - undefined, - false - ) + const { height } = await pRetry( + () => + this.ledger.block.getBlockByHeight( + // @ts-ignore + undefined, + false + ), + { + onFailedAttempt: (error) => { + this.logger.warn( + `Cannot reach Node - trying again (${error.retriesLeft} retries left)` + ); + }, + retries: 5, + } ); return height - (this.config.blockOffset || 0); } catch (e: any) {