Function execute

desktop/src/testing/e2eBridge.ts:3864–3938

()

  config: E2eConfig | undefined,
): Promise<RelayEvent[]> {
  const execute = async () => {
    const cap = Math.min(args.limitRows ?? 50, 200);
    const identity = getIdentity(config);

    if (!identity) {
      // Mock store: server-assembled channel window over the mock event store,
      // mirroring the relay path's shape so callers (parseChannelWindowResponse)
      // parse both modes identically. Top-level timeline rows in relay order,
      // then exactly one kind-39006 bounds event.
      const events = getMockMessageStore(args.channelId);
      const candidates = events
        .filter(
          (event) => TIMELINE_KINDS.has(event.kind) && isMockTopLevelRow(event),
        )
        .sort(
          (left, right) =>
            right.created_at - left.created_at ||
            left.id.localeCompare(right.id),
        );
      // Honor the composite (until, before_id) cursor exactly like the relay's
      // keyset: keep only rows strictly older than the cursor under the
      // (created_at DESC, id ASC) order — older created_at, or the same second
      // with a strictly greater id.
      const cursor = args.cursor;
      const afterCursor = cursor
        ? candidates.filter(
            (event) =>
              event.created_at < cursor.created_at ||
              (event.created_at === cursor.created_at &&
                event.id > cursor.event_id),
          )
        : candidates;
      const rows = afterCursor.slice(0, cap);
      // Exhaustion probe mirrors the relay's limit+1: more rows past the cursor
      // than the page cap means another page exists. next_cursor is the last
      // retained row.
      const hasMore = afterCursor.length > cap;
      const lastRow = rows[rows.length - 1];
      const nextCursor =
        hasMore && lastRow
          ? { created_at: lastRow.created_at, id: lastRow.id }
          : null;
      const aux = buildMockChannelWindowAux(events, rows);
      const summaries = rows.flatMap((row) => {
        const summary = buildMockChannelThreadSummary(
          args.channelId,
          row,
          events,
        );
        return summary ? [summary] : [];
      });
      return [
        ...rows,
        ...aux,
        ...summaries,
        buildMockChannelWindowBounds(args, hasMore, nextCursor),
      ];
    }