Class MessageIndexer

Message Indexer Service

Provides advanced indexer operations including:

Paginated message fetching (afterRound, beforeRound)
Transaction waiting with exponential backoff
Public key discovery with metadata

Index

Constructors

Methods

fetchMessages fetchNewerMessages fetchOlderMessages findPublicKey getLatestRound transactionExists waitForTransaction

Constructors

constructor

new MessageIndexer(config: MessageIndexerConfig): MessageIndexer
Parameters
- config: MessageIndexerConfig
Returns MessageIndexer
- Defined in src/services/MessageIndexer.ts:76

Methods

fetchMessages

fetchMessages(
    chatAccount: ChatAccount,
    participantAddress: string,
    options?: PaginationOptions,
): Promise<Message[]>
Fetches messages with a participant using pagination
Parameters
- chatAccount: ChatAccount
  The current user's chat account
- participantAddress: string
  Address of the conversation participant
- options: PaginationOptions = {}
  Pagination options
Returns Promise<Message[]>
- Defined in src/services/MessageIndexer.ts:92

fetchNewerMessages

fetchNewerMessages(
    chatAccount: ChatAccount,
    participantAddress: string,
    afterRound: number,
    limit?: number,
): Promise<Message[]>
Fetches newer messages (after a certain round)

Useful for syncing new messages.
Parameters
- chatAccount: ChatAccount
  The current user's chat account
- participantAddress: string
  Address of the conversation participant
- afterRound: number
  Minimum round (exclusive)
- limit: number = 50
  Number of messages to fetch
Returns Promise<Message[]>
- Defined in src/services/MessageIndexer.ts:157

fetchOlderMessages

fetchOlderMessages(
    chatAccount: ChatAccount,
    participantAddress: string,
    beforeRound: number,
    limit?: number,
): Promise<Message[]>
Fetches older messages (before a certain round)

Useful for "load more" functionality.
Parameters
- chatAccount: ChatAccount
  The current user's chat account
- participantAddress: string
  Address of the conversation participant
- beforeRound: number
  Maximum round (exclusive)
- limit: number = 20
  Number of messages to fetch
Returns Promise<Message[]>
- Defined in src/services/MessageIndexer.ts:135

findPublicKey

findPublicKey(address: string, searchDepth?: number): Promise<DiscoveredKey>
Discovers a user's encryption public key

Returns full metadata about where the key was discovered.
Parameters
- address: string
  Algorand address to discover key for
- searchDepth: number = 200
  Maximum transactions to search (default: 200)
Returns Promise<DiscoveredKey>
- Defined in src/services/MessageIndexer.ts:227

getLatestRound

getLatestRound(): Promise<number>
Gets the latest round from the indexer

Returns Promise<number>
- Defined in src/services/MessageIndexer.ts:290

transactionExists

transactionExists(txid: string): Promise<boolean>
Checks if a transaction exists in the indexer
Parameters
- txid: string
  Transaction ID to check
Returns Promise<boolean>
- Defined in src/services/MessageIndexer.ts:278

waitForTransaction

waitForTransaction(
txid: string,
options?: WaitForTransactionOptions,
): Promise<boolean>
Waits for a transaction to be indexed

Uses exponential backoff with jitter for efficient polling.
Parameters
- txid: string
  Transaction ID to wait for
- options: WaitForTransactionOptions = {}
  Wait options
Returns Promise<boolean>
true if found, false if timeout
- Defined in src/services/MessageIndexer.ts:178