Function watchForNextReply

e2e/slack-api.ts:139–179

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

 * doesn't keep reporting the first (parent) reply.
 */
export async function watchForNextReply(args: {
  channel: string;
  parentTs: string;
  seenCount: number;
  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 target: SlackMessage | undefined;
  let stable = 0;
  let lastLen = -1;
  while (Date.now() - start < args.timeoutMs) {
    const replies = await threadReplies(args.channel, args.parentTs);
    const bot = replies.filter((m) => m.user === BOT_USER_ID);
    target = bot.length > args.seenCount ? bot[bot.length - 1] : undefined;
    const text = target?.text;
    await args.onSample({
      elapsedMs: Date.now() - start,
      text,
      message: target,
    });
    const len = text?.length ?? 0;
    if (target && len === lastLen && len > 0) {
      stable++;
      if (stable >= 3) break;
    } else {
      stable = 0;
      lastLen = len;
    }
    await new Promise((r) => setTimeout(r, args.intervalMs));
  }
  return { finalText: target?.text, finalMessage: target };
}

/**
 * Looser sibling of watchForReply for cases where the reply is in the