Skip to content

Commit ba23a83

Browse files
author
nach
committedMar 14, 2021
fix maxRetries hardcode to use env variable
1 parent 7e487d2 commit ba23a83

File tree

3 files changed

+3
-2
lines changed

3 files changed

+3
-2
lines changed
 

‎config.ts

+1
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ export class Config {
2222
host: process.env.rpc_host ? process.env.rpc_host : '0.0.0.0',
2323
port: process.env.rpc_port ? process.env.rpc_port : '8332',
2424
limit: Number.parseInt(process.env.rpc_limit ? process.env.rpc_limit : "150"),
25+
rpcMaxRetries: Number.parseInt(process.env.rpc_max_retries ? process.env.rpc_max_retries : "2"),
2526
rpcRetryDelayMs: Number.parseInt(process.env.rpc_retry_delay ? process.env.rpc_retry_delay : "1000"),
2627
rpcTimeoutMs: Number.parseInt(process.env.rpc_timeout ? process.env.rpc_timeout : "30000"),
2728
skipInitialSyncCheck: process.env.skip_intial_sync_check ? ['1', 'true'].includes(process.env.skip_intial_sync_check) : false,

‎index.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ new RpcClient({ useGrpc: Boolean(Config.grpc.url) });
1717

1818
// init promise based resources
1919
const sp = require("synchronized-promise");
20-
let getBlockchainInfoSync: () => BlockchainInfoResult = sp(RpcClient.getBlockchainInfo);
20+
let getBlockchainInfoSync: () => BlockchainInfoResult = sp(RpcClient.getBlockchainInfo,{timeouts:Config.rpc.rpcTimeoutMs});
2121
let setNetworkSync: (network: string) => void = sp(Info.setNetwork);
2222
let queryInitSync: () => void = sp(Query.init);
2323
let chain = getBlockchainInfoSync().chain;

‎rpc.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ export class RpcClient {
2323
}
2424
} else {
2525
rpc = new _rpcClient(connectionString, { maxRetries: 0 });
26-
rpc_retry = new _rpcClient(connectionString, { maxRetries: 2, timeoutMs: Config.rpc.rpcTimeoutMs, retryDelayMs: Config.rpc.rpcRetryDelayMs });
26+
rpc_retry = new _rpcClient(connectionString, { maxRetries: Config.rpc.rpcMaxRetries, timeoutMs: Config.rpc.rpcTimeoutMs, retryDelayMs: Config.rpc.rpcRetryDelayMs });
2727
}
2828
}
2929

0 commit comments

Comments
 (0)
Please sign in to comment.