Method fetchChunkedAuxEvents

desktop/src/shared/api/relayClientSession.ts:201–226

(
    channelId: string,
    eventIds: string[],
    buildFilter: (
      channelId: string,
      eventIds: string[],
    ) => RelaySubscriptionFilter,
  )

  }

  private async fetchChunkedAuxEvents(
    channelId: string,
    eventIds: string[],
    buildFilter: (
      channelId: string,
      eventIds: string[],
    ) => RelaySubscriptionFilter,
  ): Promise<RelayEvent[]> {
    if (eventIds.length === 0) {
      return [];
    }

    await this.ensureConnected();

    const chunks: string[][] = [];
    for (let i = 0; i < eventIds.length; i += AUX_BACKFILL_CHUNK_SIZE) {
      chunks.push(eventIds.slice(i, i + AUX_BACKFILL_CHUNK_SIZE));
    }

    const batches: RelayEvent[][] = [];
    for (const ids of chunks) {
      batches.push(await this.requestHistory(buildFilter(channelId, ids)));
    }

    return batches.flat();
  }

  private async fetchHistory(filter: RelaySubscriptionFilter) {
    await this.ensureConnected();