Function watchForChannelReply

e2e/slack-api.ts:185–225

(args: {
  channel: string;
  sinceTs: string;
  intervalMs: number;
  timeoutMs: number;
  onSample: (sample: {
    elapsedMs: number;
    text: string | undefined;
    message: SlackMessage | undefined;
  }) => Promise<void> | void;
})

 * channel directly (DMs / slash commands) rather than threaded.
 */
export async function watchForChannelReply(args: {
  channel: string;
  sinceTs: string;
  intervalMs: number;
  timeoutMs: number;
  onSample: (sample: {
    elapsedMs: number;
    text: string | undefined;
    message: SlackMessage | undefined;
  }) => Promise<void> | void;
}): Promise<{
  finalText: string | undefined;
  finalMessage: SlackMessage | undefined;
}> {
  const start = Date.now();
  let lastMessage: SlackMessage | undefined;
  let stable = 0;
  let lastLen = -1;
  while (Date.now() - start < args.timeoutMs) {
    const history = await channelHistory(args.channel, 5);
    lastMessage = history.find(
      (m) => m.user === BOT_USER_ID && Number(m.ts) > Number(args.sinceTs),
    );
    const text = lastMessage?.text;
    await args.onSample({
      elapsedMs: Date.now() - start,
      text,
      message: lastMessage,
    });
    const len = text?.length ?? 0;
    if (len === lastLen && len > 0) {
      stable++;
      if (stable >= 3) break;
    } else {
      stable = 0;
      lastLen = len;
    }
    await new Promise((r) => setTimeout(r, args.intervalMs));
  }
  return { finalText: lastMessage?.text, finalMessage: lastMessage };
}

/**
 * Bracket-balance check.