Function relayParseResult

parsehub/parsehub.ts:242–372

(
  originMsg: Api.Message,
  link: string,
  baselineId: number,
)

      return "客户端未就绪";
    default:
      return "原因未知";
  }
};

async function forwardChunk(client: any, peer: any, ids: number[]) {
  await client.forwardMessages(peer, {
    fromPeer: BOT_USERNAME,
    messages: ids,
    dropAuthor: true,
  });
}

async function relayParseResult(
  originMsg: Api.Message,
  link: string,
  baselineId: number,
): Promise<RelayOutcome> {
  const client = originMsg.client;
  if (!client) {
    return { lastId: baselineId, forwarded: false, reason: "no_client" };
  }

  try {
    await client.sendMessage(BOT_USERNAME, { message: link });
  } catch (error: any) {
    return {
      lastId: baselineId,
      forwarded: false,
      reason: "send_failed",
      error: error?.message || String(error),
    };
  }

  // Progress msgs (解析中/下载中/上传中) often keep the SAME id and are later
  // edited into the final media. Never permanently skip them via processedIds.
  const progressIds = new Set<number>();
  const finalMessages = new Map<number, Api.Message>();

  let deadline = Date.now() + MAX_WAIT_MS;
  let lastId = baselineId;
  let lastFinalActivity = 0;
  let lastProgressActivity = Date.now();
  let firstRunIgnore = shouldIgnoreNextBotMessage;

  while (Date.now() < deadline) {
    await sleep(POLL_INTERVAL_MS);

    let messages: Api.Message[] = [];
    try {
      messages = await safeGetMessages(client, BOT_USERNAME, { limit: FETCH_LIMIT });
    } catch (error: any) {
      return {
        lastId,
        forwarded: false,
        reason: "fetch_failed",
        error: error?.message || String(error),
      };
    }