Feat: (Health check) Check alt_ip if web domain is not accessible

src/lib/nodes/abstract.node.ts

@@ -29,6 +29,10 @@ export abstract class Node<C = unknown> {
    */
   wsPort = '36668'
 
+  /**
+   * Node alternative IP
+   */
+  alt_ip?: string
   /**
    * Node base URL
    */
@@ -56,10 +60,22 @@ export abstract class Node<C = unknown> {
   hasSupportedProtocol = true
 
   // Healthcheck related params
+  /**
+   * Indicates whether a node with alternative IP is available
+   */
+  altIpAvailable = false
+  /**
+   * Indicates whether a node with main URL is available
+   */
+  mainUrlAvailable = true
   /**
    * Indicates whether node is available.
    */
   online = true
+  /**
+   * Indicates whether prefer a node with alternative IP or not
+   */
+  preferAltIp = false
   /**
    * Node ping estimation
    */
@@ -97,13 +113,16 @@ export abstract class Node<C = unknown> {
   healthcheckInProgress = false
 
   constructor(
-    url: string,
+    endpoint: { alt_ip?: string; url: string },
     type: NodeType,
     kind: NodeKind,
     label: TNodeLabel,
     version = '',
     minNodeVersion = ''
   ) {
+    const { alt_ip, url } = endpoint
+
+    this.alt_ip = alt_ip
     this.url = url
     this.type = type
     this.label = label
@@ -134,8 +153,21 @@ export abstract class Node<C = unknown> {
         this.height = health.height
         this.ping = health.ping
         this.online = true
+
+        if (this.preferAltIp) {
+          this.altIpAvailable = true
+        } else {
+          this.mainUrlAvailable = true
+        }
       } catch {
-        this.online = false
+        if (this.preferAltIp) {
+          this.altIpAvailable = false
+          this.preferAltIp = false
+          this.online = false
+        } else if (this.mainUrlAvailable) {
+          this.mainUrlAvailable = false
+          this.preferAltIp = true
+        }
       } finally {
         this.healthcheckInProgress = false
       }
@@ -164,6 +196,7 @@ export abstract class Node<C = unknown> {
 
   getStatus() {
     return {
+      alt_ip: this.alt_ip,
       url: this.url,
       port: this.port,
       hostname: this.hostname,

src/lib/nodes/adm/AdmClient.ts

@@ -16,7 +16,7 @@ import { Client } from '../abstract.client'
  * is not available at the moment.
  */
 export class AdmClient extends Client<AdmNode> {
-  constructor(endpoints: string[] = [], minNodeVersion = '0.0.0') {
+  constructor(endpoints: { alt_ip?: string; url: string }[] = [], minNodeVersion = '0.0.0') {
     super('adm', 'node', NODE_LABELS.AdmNode)
     this.nodes = endpoints.map((endpoint) => new AdmNode(endpoint, minNodeVersion))
     this.minNodeVersion = minNodeVersion
@@ -75,7 +75,9 @@ export class AdmClient extends Client<AdmNode> {
     return this.getNode().timeDelta
   }
 
-  async sendChatTransaction(transaction: RegisterChatMessageTransaction): Promise<CreateNewChatMessageResponseDto> {
+  async sendChatTransaction(
+    transaction: RegisterChatMessageTransaction
+  ): Promise<CreateNewChatMessageResponseDto> {
     return this.post('/api/chats/process', () => ({ transaction }))
   }
 }

src/lib/nodes/adm/AdmNode.ts

@@ -18,6 +18,7 @@ export type Payload =
       (ctx: AdmNode): Record<string, any>
     }
 export type RequestConfig<P extends Payload> = {
+  baseURL?: string
   url: string
   method?: string
   payload?: P
@@ -28,8 +29,8 @@ export type RequestConfig<P extends Payload> = {
  * to the node and verify is status (online/offline, version, ping, etc.)
  */
 export class AdmNode extends Node<AxiosInstance> {
-  constructor(url: string, minNodeVersion = '0.0.0') {
-    super(url, 'adm', 'node', NODE_LABELS.AdmNode, '', minNodeVersion)
+  constructor(endpoint: { alt_ip?: string; url: string }, minNodeVersion = '0.0.0') {
+    super(endpoint, 'adm', 'node', NODE_LABELS.AdmNode, '', minNodeVersion)
 
     this.wsPort = '36668' // default wsPort
     this.wsProtocol = this.protocol === 'https:' ? 'wss:' : 'ws:'
@@ -52,6 +53,7 @@ export class AdmNode extends Node<AxiosInstance> {
     const { url, method = 'get', payload } = cfg
 
     const config: AxiosRequestConfig = {
+      baseURL: this.preferAltIp ? this.alt_ip : this.url,
       url,
       method: method.toLowerCase(),
       [method === 'get' ? 'params' : 'data']:
@@ -72,7 +74,6 @@ export class AdmNode extends Node<AxiosInstance> {
         // According to https://github.com/axios/axios#handling-errors this means, that request was sent,
         // but server could not respond.
         if (!error.response && error.request) {
-          this.online = false
           throw new NodeOfflineError()
         }
         throw error

src/lib/nodes/adm/index.ts

@@ -2,7 +2,10 @@ import config from '@/config'
 import { NodeInfo } from '@/types/wallets'
 import { AdmClient } from './AdmClient'
 
-const endpoints = (config.adm.nodes.list as NodeInfo[]).map((endpoint) => endpoint.url)
+const endpoints = (config.adm.nodes.list as NodeInfo[]).map((endpoint) => ({
+  alt_ip: endpoint.alt_ip,
+  url: endpoint.url
+}))
 export const adm = new AdmClient(endpoints, config.adm.nodes.minVersion)
 
 export default adm

src/lib/nodes/btc-indexer/BtcIndexer.ts

@@ -8,8 +8,8 @@ import { NODE_LABELS } from '@/lib/nodes/constants'
  * to the node and verify is status (online/offline, version, ping, etc.)
  */
 export class BtcIndexer extends Node<AxiosInstance> {
-  constructor(url: string) {
-    super(url, 'btc', 'service', NODE_LABELS.BtcIndexer)
+  constructor(endpoint: { alt_ip?: string; url: string }) {
+    super(endpoint, 'btc', 'service', NODE_LABELS.BtcIndexer)
   }
 
   protected buildClient(): AxiosInstance {
@@ -40,6 +40,7 @@ export class BtcIndexer extends Node<AxiosInstance> {
     return this.client
       .request({
         ...requestConfig,
+        baseURL: this.preferAltIp ? this.alt_ip : this.url,
         url: path,
         method,
         params: method === 'GET' ? params : undefined,

src/lib/nodes/btc-indexer/BtcIndexerClient.ts

@@ -17,7 +17,7 @@ import { GetUnspentsParams } from './types/api/get-unspents/get-unspents-params'
  * is not available at the moment.
  */
 export class BtcIndexerClient extends Client<BtcIndexer> {
-  constructor(endpoints: string[] = [], minNodeVersion = '0.0.0') {
+  constructor(endpoints: { alt_ip?: string; url: string }[] = [], minNodeVersion = '0.0.0') {
     super('btc', 'service', NODE_LABELS.BtcIndexer)
     this.nodes = endpoints.map((endpoint) => new BtcIndexer(endpoint))
     this.minNodeVersion = minNodeVersion

src/lib/nodes/btc-indexer/index.ts

@@ -2,7 +2,10 @@ import config from '@/config'
 import { NodeInfo } from '@/types/wallets'
 import { BtcIndexerClient } from './BtcIndexerClient'
 
-const endpoints = (config.btc.services.btcIndexer.list as NodeInfo[]).map((endpoint) => endpoint.url)
+const endpoints = (config.btc.services.btcIndexer.list as NodeInfo[]).map((endpoint) => ({
+  alt_ip: endpoint.alt_ip,
+  url: endpoint.url
+}))
 export const btcIndexer = new BtcIndexerClient(endpoints)
 
 export default btcIndexer

src/lib/nodes/btc/BtcClient.ts

@@ -12,7 +12,7 @@ import { RpcRequest } from './types/api/common'
  * is not available at the moment.
  */
 export class BtcClient extends Client<BtcNode> {
-  constructor(endpoints: string[] = [], minNodeVersion = '0.0.0') {
+  constructor(endpoints: { alt_ip?: string; url: string }[] = [], minNodeVersion = '0.0.0') {
     super('btc', 'node', NODE_LABELS.BtcNode)
     this.nodes = endpoints.map((endpoint) => new BtcNode(endpoint))
     this.minNodeVersion = minNodeVersion

src/lib/nodes/btc/BtcNode.ts

@@ -12,8 +12,8 @@ import { BlockchainInfo } from './types/api/blockchain-info'
  * to the node and verify is status (online/offline, version, ping, etc.)
  */
 export class BtcNode extends Node<AxiosInstance> {
-  constructor(url: string) {
-    super(url, 'btc', 'node', NODE_LABELS.BtcNode)
+  constructor(endpoint: { alt_ip?: string; url: string }) {
+    super(endpoint, 'btc', 'node', NODE_LABELS.BtcNode)
   }
 
   protected buildClient(): AxiosInstance {
@@ -53,6 +53,7 @@ export class BtcNode extends Node<AxiosInstance> {
     return this.client
       .request<RpcResponse<Result>>({
         ...requestConfig,
+        baseURL: this.preferAltIp ? this.alt_ip : this.url,
         method: 'POST',
         data: params
       })

src/lib/nodes/btc/index.ts

@@ -2,7 +2,10 @@ import config from '@/config'
 import { NodeInfo } from '@/types/wallets'
 import { BtcClient } from './BtcClient'
 
-const endpoints = (config.btc.nodes.list as NodeInfo[]).map((endpoint) => endpoint.url)
+const endpoints = (config.btc.nodes.list as NodeInfo[]).map((endpoint) => ({
+  alt_ip: endpoint.alt_ip,
+  url: endpoint.url
+}))
 export const btc = new BtcClient(endpoints)
 
 export default btc

src/lib/nodes/btc/types/api/common.ts

@@ -23,6 +23,7 @@ type Method =
   | 'getaddressbalance'
 
 export type RpcRequest<P = any, M extends Method | string = string> = {
+  baseURL?: string
   method: M
   params?: P
 }

src/lib/nodes/dash/DashClient.ts

@@ -9,7 +9,7 @@ import { Balance } from './types/api/balance'
 import { Transaction } from './types/api/transaction'
 
 export class DashClient extends Client<DashNode> {
-  constructor(endpoints: string[] = [], minNodeVersion = '0.0.0') {
+  constructor(endpoints: { alt_ip?: string; url: string }[] = [], minNodeVersion = '0.0.0') {
     super('dash', 'node', NODE_LABELS.DashNode)
     this.nodes = endpoints.map((endpoint) => new DashNode(endpoint))
     this.minNodeVersion = minNodeVersion

src/lib/nodes/dash/DashNode.ts

@@ -11,8 +11,8 @@ import { BlockchainInfo } from './types/api/blockchain-info'
  * to the node and verify is status (online/offline, version, ping, etc.)
  */
 export class DashNode extends Node<AxiosInstance> {
-  constructor(url: string) {
-    super(url, 'dash', 'node', NODE_LABELS.DashNode)
+  constructor(endpoint: { alt_ip?: string; url: string }) {
+    super(endpoint, 'dash', 'node', NODE_LABELS.DashNode)
   }
 
   protected buildClient(): AxiosInstance {
@@ -51,6 +51,7 @@ export class DashNode extends Node<AxiosInstance> {
     return this.client
       .request<RpcResponse<Result>>({
         ...requestConfig,
+        baseURL: this.preferAltIp ? this.alt_ip : this.url,
         url: '/',
         method: 'POST',
         data: params
@@ -73,6 +74,7 @@ export class DashNode extends Node<AxiosInstance> {
     return this.client
       .request<RpcResponse<Result>[]>({
         ...requestConfig,
+        baseURL: this.preferAltIp ? this.alt_ip : this.url,
         url: '/',
         method: 'POST',
         data: params

src/lib/nodes/dash/index.ts

@@ -2,7 +2,10 @@ import config from '@/config'
 import { NodeInfo } from '@/types/wallets'
 import { DashClient } from './DashClient'
 
-const endpoints = (config.dash.nodes.list as NodeInfo[]).map((endpoint) => endpoint.url)
+const endpoints = (config.dash.nodes.list as NodeInfo[]).map((endpoint) => ({
+  alt_ip: endpoint.alt_ip,
+  url: endpoint.url
+}))
 export const dash = new DashClient(endpoints)
 
 export default dash

src/lib/nodes/dash/types/api/common.ts

@@ -23,6 +23,7 @@ type Method =
   | 'getaddressbalance'
 
 export type RpcRequest<P = any, M extends Method | string = string> = {
+  baseURL?: string
   method: M
   params?: P
 }

src/lib/nodes/doge-indexer/DogeIndexer.ts

@@ -8,8 +8,8 @@ import { NODE_LABELS } from '@/lib/nodes/constants'
  * to the node and verify is status (online/offline, version, ping, etc.)
  */
 export class DogeIndexer extends Node<AxiosInstance> {
-  constructor(url: string) {
-    super(url, 'doge', 'service', NODE_LABELS.DogeIndexer)
+  constructor(endpoint: { alt_ip?: string; url: string }) {
+    super(endpoint, 'doge', 'service', NODE_LABELS.DogeIndexer)
   }
 
   protected buildClient(): AxiosInstance {
@@ -18,9 +18,7 @@ export class DogeIndexer extends Node<AxiosInstance> {
 
   protected async checkHealth() {
     const time = Date.now()
-    const height = await this.client
-      .get('/api/status')
-      .then((res) => res.data.info.blocks)
+    const height = await this.client.get('/api/status').then((res) => res.data.info.blocks)
 
     return {
       height,
@@ -40,6 +38,7 @@ export class DogeIndexer extends Node<AxiosInstance> {
     return this.client
       .request({
         ...requestConfig,
+        baseURL: this.preferAltIp ? this.alt_ip : this.url,
         url: path,
         method,
         params: method === 'GET' ? params : undefined,

src/lib/nodes/doge-indexer/DogeIndexerClient.ts

@@ -12,7 +12,7 @@ import { EstimatedFee, GetEstimatedFeeParams } from './types/api/estimated-fee'
 import { Balance } from './types/api/balance'
 
 export class DogeIndexerClient extends Client<DogeIndexer> {
-  constructor(endpoints: string[] = [], minNodeVersion = '0.0.0') {
+  constructor(endpoints: { alt_ip?: string; url: string }[] = [], minNodeVersion = '0.0.0') {
     super('doge', 'service', NODE_LABELS.DogeIndexer)
     this.nodes = endpoints.map((endpoint) => new DogeIndexer(endpoint))
     this.minNodeVersion = minNodeVersion

src/lib/nodes/doge-indexer/index.ts

@@ -2,7 +2,10 @@ import config from '@/config'
 import { NodeInfo } from '@/types/wallets'
 import { DogeIndexerClient } from './DogeIndexerClient'
 
-const endpoints = (config.doge.nodes.list as NodeInfo[]).map((endpoint) => endpoint.url)
+const endpoints = (config.doge.nodes.list as NodeInfo[]).map((endpoint) => ({
+  alt_ip: endpoint.alt_ip,
+  url: endpoint.url
+}))
 export const dogeIndexer = new DogeIndexerClient(endpoints)
 
 export default dogeIndexer

src/lib/nodes/doge/DogeClient.ts

@@ -5,7 +5,7 @@ import { DogeNode } from './DogeNode'
 import { Client } from '../abstract.client'
 
 export class DogeClient extends Client<DogeNode> {
-  constructor(endpoints: string[] = [], minNodeVersion = '0.0.0') {
+  constructor(endpoints: { alt_ip?: string; url: string }[] = [], minNodeVersion = '0.0.0') {
     super('doge', 'node', NODE_LABELS.DogeNode)
     this.nodes = endpoints.map((endpoint) => new DogeNode(endpoint))
     this.minNodeVersion = minNodeVersion

src/lib/nodes/doge/DogeNode.ts

@@ -12,8 +12,8 @@ import { BlockchainInfo } from './types/api/blockchain-info'
  * to the node and verify is status (online/offline, version, ping, etc.)
  */
 export class DogeNode extends Node<AxiosInstance> {
-  constructor(url: string) {
-    super(url, 'doge', 'node', NODE_LABELS.DogeNode)
+  constructor(endpoint: { alt_ip?: string; url: string }) {
+    super(endpoint, 'doge', 'node', NODE_LABELS.DogeNode)
   }
 
   protected buildClient(): AxiosInstance {
@@ -55,6 +55,7 @@ export class DogeNode extends Node<AxiosInstance> {
     return this.client
       .request<RpcResponse<Response>>({
         ...requestConfig,
+        baseURL: this.preferAltIp ? this.alt_ip : this.url,
         url: '/',
         method: 'POST',
         data: params

src/lib/nodes/doge/index.ts

@@ -2,7 +2,10 @@ import config from '@/config'
 import { NodeInfo } from '@/types/wallets'
 import { DogeClient } from './DogeClient'
 
-const endpoints = (config.doge.nodes.list as NodeInfo[]).map((endpoint) => endpoint.url)
+const endpoints = (config.doge.nodes.list as NodeInfo[]).map((endpoint) => ({
+  alt_ip: endpoint.alt_ip,
+  url: endpoint.url
+}))
 export const doge = new DogeClient(endpoints)
 
 export default doge