Class IndexerHub

Hierarchy

IndexerHub

Constructors

constructor

new IndexerHub(useWebSocketPulling?: boolean): IndexerHub
Parameters
- Optional useWebSocketPulling: boolean
Returns IndexerHub
- Defined in src/indexer/IndexerHub.ts:31

Properties

`Private` cs

cs: CriticalSection = ...

`Private` endpoint

endpoint: string = ''

`Private` lastTryTimestamps

lastTryTimestamps: Record<string, number> = {}

messagesDebounceTimer

messagesDebounceTimer: any = null

messagesDebouncer

messagesDebouncer: {
    reject: ((reason?: any) => void);
    request: {
        blockchain: string;
        feedId: null | Uint256;
        fromMessageId: null | string;
        limit: number;
        mailerId: string;
        recipient: null | Uint256;
        sender: null | string;
        toMessageId: null | string;
        type: "DIRECT" | "BROADCAST";
    };
    resolve: ((value: IMessage<any>[]) => void);
}[] = []

`Private` subscriptions

subscriptions: Set<IndexerMessagesSource> = ...

`Readonly` useWebSocketPulling

useWebSocketPulling: boolean

`Private` webSocket

webSocket: null | WebSocket = null

Methods

`Private` init

init(): void
Returns void
- Defined in src/indexer/IndexerHub.ts:128

`Private` initWebSocket

initWebSocket(): void
Returns void
- Defined in src/indexer/IndexerHub.ts:72

loadMessagesCount

loadMessagesCount(recipients: Uint256[], timestamp?: number): Promise<Record<Uint256, Record<string, number>>>
Parameters
- recipients: Uint256[]
- timestamp: number = 0
Returns Promise<Record<Uint256, Record<string, number>>>
- Defined in src/indexer/IndexerHub.ts:311

request

request(url: string, body: any): Promise<any>
Parameters
- url: string
- body: any
Returns Promise<any>
- Defined in src/indexer/IndexerHub.ts:188

requestContent

requestContent(__namedParameters: {
blockchain: string;
msgId: string;
}): Promise<null | IMessageCorruptedContent | IMessageContent>
Parameters
- __namedParameters: {
  blockchain: string;
  msgId: string;
  }
  - blockchain: string
  - msgId: string
Returns Promise<null | IMessageCorruptedContent | IMessageContent>
- Defined in src/indexer/IndexerHub.ts:412

requestKeys

requestKeys(address: string): Promise<Record<string, {
    block: number;
    keyVersion: number;
    publicKey: Uint8Array;
    registrar: number;
    timestamp: number;
}>>
Parameters
- address: string
Returns Promise<Record<string, {
    block: number;
    keyVersion: number;
    publicKey: Uint8Array;
    registrar: number;
    timestamp: number;
}>>
- Defined in src/indexer/IndexerHub.ts:283

requestKeysHistory

requestKeysHistory(addresses: string[]): Promise<Record<string, {
    block: number;
    blockchain: string;
    keyVersion: number;
    publicKey: Uint8Array;
    registrar: number;
    timestamp: number;
}[]>>
Parameters
- addresses: string[]
Returns Promise<Record<string, {
    block: number;
    blockchain: string;
    keyVersion: number;
    publicKey: Uint8Array;
    registrar: number;
    timestamp: number;
}[]>>
- Defined in src/indexer/IndexerHub.ts:266

requestMessages

requestMessages(request: {
    blockchain: string;
    feedId: null | Uint256;
    fromMessageId: null | string;
    limit: number;
    mailerId: string;
    recipient: null | Uint256;
    sender: null | string;
    toMessageId: null | string;
    type: "DIRECT" | "BROADCAST";
}): Promise<IMessage<any>[]>
Parameters
- request: {
      blockchain: string;
      feedId: null | Uint256;
      fromMessageId: null | string;
      limit: number;
      mailerId: string;
      recipient: null | Uint256;
      sender: null | string;
      toMessageId: null | string;
      type: "DIRECT" | "BROADCAST";
  }
  - blockchain: string
  - feedId: null | Uint256
  - fromMessageId: null | string
  - limit: number
  - mailerId: string
  - recipient: null | Uint256
  - sender: null | string
  - toMessageId: null | string
  - type: "DIRECT" | "BROADCAST"
Returns Promise<IMessage<any>[]>
- Defined in src/indexer/IndexerHub.ts:359

requestMultiMessages

requestMultiMessages(requests: {
    blockchain: string;
    feedId: null | Uint256;
    fromMessageId: null | string;
    limit: number;
    mailerId: string;
    recipient: null | Uint256;
    sender: null | string;
    toMessageId: null | string;
    type: "DIRECT" | "BROADCAST";
}[]): Promise<({
    data: IMessage<any>[];
    result: true;
} | {
    error: string;
    result: false;
})[]>
Parameters
- requests: {
      blockchain: string;
      feedId: null | Uint256;
      fromMessageId: null | string;
      limit: number;
      mailerId: string;
      recipient: null | Uint256;
      sender: null | string;
      toMessageId: null | string;
      type: "DIRECT" | "BROADCAST";
  }[]
Returns Promise<({
    data: IMessage<any>[];
    result: true;
} | {
    error: string;
    result: false;
})[]>
- Defined in src/indexer/IndexerHub.ts:318

requestMultipleKeys

requestMultipleKeys(addresses: string[]): Promise<Record<string, Record<string, null | {
    block: number;
    keyVersion: number;
    publicKey: Uint8Array;
    registrar: number;
    timestamp: number;
}>>>
Parameters
- addresses: string[]
Returns Promise<Record<string, Record<string, null | {
    block: number;
    keyVersion: number;
    publicKey: Uint8Array;
    registrar: number;
    timestamp: number;
}>>>
- Defined in src/indexer/IndexerHub.ts:209

retryingOperation

retryingOperation<T>(callback: (() => Promise<T>), fallback: (() => Promise<T>)): Promise<T>
Type Parameters
- T
Parameters
- callback: (() => Promise<T>)
  - - (): Promise<T>
    - Returns Promise<T>
- fallback: (() => Promise<T>)
  - - (): Promise<T>
    - Returns Promise<T>
Returns Promise<T>
- Defined in src/indexer/IndexerHub.ts:134

subscribe(instance: IndexerMessagesSource): void
Parameters
- instance: IndexerMessagesSource
Returns void
- Defined in src/indexer/IndexerHub.ts:40

unsubscribe

unsubscribe(instance: IndexerMessagesSource): void
Parameters
- instance: IndexerMessagesSource
Returns void
- Defined in src/indexer/IndexerHub.ts:59

Class IndexerHub

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

Optional useWebSocketPulling: boolean

Returns IndexerHub

Properties

Private cs

Private endpoint

Private lastTryTimestamps

messagesDebounceTimer

messagesDebouncer

Private subscriptions

Readonly useWebSocketPulling

Private webSocket

Methods

Private init

Returns void

Private initWebSocket

Returns void

loadMessagesCount

Parameters

recipients: Uint256[]

timestamp: number = 0

Returns Promise<Record<Uint256, Record<string, number>>>

request

Parameters

url: string

body: any

Returns Promise<any>

requestContent

Parameters

__namedParameters: { blockchain: string; msgId: string; }

blockchain: string

msgId: string

Returns Promise<null | IMessageCorruptedContent | IMessageContent>

requestKeys

Parameters

address: string

Returns Promise<Record<string, { block: number; keyVersion: number; publicKey: Uint8Array; registrar: number; timestamp: number; }>>

requestKeysHistory

Parameters

addresses: string[]

Returns Promise<Record<string, { block: number; blockchain: string; keyVersion: number; publicKey: Uint8Array; registrar: number; timestamp: number; }[]>>

requestMessages

Parameters

request: { blockchain: string; feedId: null | Uint256; fromMessageId: null | string; limit: number; mailerId: string; recipient: null | Uint256; sender: null | string; toMessageId: null | string; type: "DIRECT" | "BROADCAST"; }

blockchain: string

feedId: null | Uint256

fromMessageId: null | string

limit: number

mailerId: string

recipient: null | Uint256

sender: null | string

toMessageId: null | string

type: "DIRECT" | "BROADCAST"

Returns Promise<IMessage<any>[]>

requestMultiMessages

Parameters

requests: { blockchain: string; feedId: null | Uint256; fromMessageId: null | string; limit: number; mailerId: string; recipient: null | Uint256; sender: null | string; toMessageId: null | string; type: "DIRECT" | "BROADCAST"; }[]

Returns Promise<({ data: IMessage<any>[]; result: true; } | { error: string; result: false; })[]>

requestMultipleKeys

Parameters

addresses: string[]

Returns Promise<Record<string, Record<string, null | { block: number; keyVersion: number; publicKey: Uint8Array; registrar: number; timestamp: number; }>>>

retryingOperation

Type Parameters

T

Parameters

callback: (() => Promise<T>)

Returns Promise<T>

fallback: (() => Promise<T>)

Returns Promise<T>

Returns Promise<T>

subscribe

`Optional` useWebSocketPulling: boolean

`Private` cs

`Private` endpoint

`Private` lastTryTimestamps

`Private` subscriptions

`Readonly` useWebSocketPulling

`Private` webSocket

`Private` init

`Private` initWebSocket

__namedParameters: {
blockchain: string;
msgId: string;
}

Returns Promise<Record<string, {
block: number;
keyVersion: number;
publicKey: Uint8Array;
registrar: number;
timestamp: number;
}>>

Returns Promise<Record<string, {
block: number;
blockchain: string;
keyVersion: number;
publicKey: Uint8Array;
registrar: number;
timestamp: number;
}[]>>

request: {
blockchain: string;
feedId: null | Uint256;
fromMessageId: null | string;
limit: number;
mailerId: string;
recipient: null | Uint256;
sender: null | string;
toMessageId: null | string;
type: "DIRECT" | "BROADCAST";
}

requests: {
blockchain: string;
feedId: null | Uint256;
fromMessageId: null | string;
limit: number;
mailerId: string;
recipient: null | Uint256;
sender: null | string;
toMessageId: null | string;
type: "DIRECT" | "BROADCAST";
}[]

Returns Promise<({
data: IMessage<any>[];
result: true;
} | {
error: string;
result: false;
})[]>

Returns Promise<Record<string, Record<string, null | {
block: number;
keyVersion: number;
publicKey: Uint8Array;
registrar: number;
timestamp: number;
}>>>