Function handleReply

pmcaptcha/pmcaptcha.ts:1044–1109

(client: TelegramClient, userId: number, input: string, incomingMsgId: number)

  const state = states.get(userId);
  if (!state || !isStateCurrent(state)) return;

  if (!input.trim()) return;

  if (incomingMsgId) state.msgIds.push(incomingMsgId);

  if (!state.answer) {
    log(LogLevel.WARN, `handleReply: empty answer for user ${userId}`);
    removeCaptchaState(userId);
    await cleanupCaptchaMessages(client, userId, state);
    try { await client.sendMessage(userId, { message: "❌ 验证状态异常，请联系对方重置。", parseMode: "html" }); } catch {}
    return;
  }

  const isImgMode  = state.mode === CaptchaMode.IMG_DIGIT || state.mode === CaptchaMode.IMG_MIXED;
  const inputNorm  = input.trim().toUpperCase();
  const answerNorm = state.answer.trim().toUpperCase();

  const correct = isImgMode
    ? levenshtein(inputNorm, answerNorm) <= 1
    : inputNorm === answerNorm;

  if (correct) {
    removeCaptchaState(userId);
    await cleanupCaptchaMessages(client, userId, state);
    const name = await getDisplayName(client, userId).catch(() => String(userId));
    if (!isStateCurrent(state)) return;
    rec.addVerified(userId, name, usernameCache.get(userId));
    rec.delFailed(userId);
    log(LogLevel.INFO, `User ${userId} passed captcha`);
    await runPassActions(client, userId);
    if (!isStateCurrent(state)) return;
    try {
      await client.sendMessage(userId, { message: "✅ 验证通过！欢迎与我对话。", parseMode: "html" });
    } catch {}
    return;
  }

  state.tries++;
  const max       = cfg.maxTries();
  const remaining = max > 0 ? max - state.tries : Infinity;

  if (max > 0 && state.tries >= max) {
    removeCaptchaState(userId);
    await cleanupCaptchaMessages(client, userId, state);
    const name = await getDisplayName(client, userId).catch(() => String(userId));
    if (!isStateCurrent(state)) return;
    rec.addFailed(userId, name, "max_tries", usernameCache.get(userId));
    rec.delVerified(userId);
    log(LogLevel.INFO, `User ${userId} failed captcha (max tries)`);
    try {
      await client.sendMessage(userId, { message: "❌ 验证失败次数过多，对话已被限制。", parseMode: "html" });
    } catch {}
    if (!isStateCurrent(state)) return;
    await runFailActions(client, userId);
  } else {
    const hint = remaining === Infinity ? "请重试。" : `请重试（剩余次数：${remaining}）`;
    try {
      const hintMsg = await client.sendMessage(userId, { message: `❌ 答案错误，${htmlEscape(hint)}`, parseMode: "html" });