Function handlePollEmail

content/mail-2925.js:294–435

(step, payload)

}

async function handlePollEmail(step, payload) {
  const {
    senderFilters,
    subjectFilters,
    maxAttempts,
    intervalMs,
    filterAfterTimestamp = 0,
    excludeCodes = [],
    strictChatGPTCodeOnly = false,
    targetEmail = '',
  } = payload;
  const excludedCodeSet = new Set(excludeCodes.filter(Boolean));
  const filterAfterMinute = normalizeMinuteTimestamp(Number(filterAfterTimestamp) || 0);

  log(`步骤 ${step}：开始轮询 2925 邮箱（最多 ${maxAttempts} 次）`);
  if (filterAfterMinute) {
    log(`步骤 ${step}：仅尝试 ${new Date(filterAfterMinute).toLocaleString('zh-CN', { hour12: false })} 及之后时间的邮件。`);
  }

  let initialItems = [];
  for (let i = 0; i < 20; i++) {
    initialItems = findMailItems();
    if (initialItems.length > 0) break;
    await sleep(500);
  }

  if (initialItems.length === 0) {
    await refreshInbox();
    await sleep(2000);
    initialItems = findMailItems();
  }

  if (initialItems.length === 0) {
    throw new Error('2925 邮箱列表未加载完成，请确认当前已打开收件箱。');
  }

  const existingMailIds = getCurrentMailIds(initialItems);
  log(`步骤 ${step}：邮件列表已加载，共 ${initialItems.length} 封邮件`);
  log(`步骤 ${step}：已记录当前 ${existingMailIds.size} 封旧邮件快照`);

  const FALLBACK_AFTER = 3;

  for (let attempt = 1; attempt <= maxAttempts; attempt++) {
    log(`步骤 ${step}：正在轮询 2925 邮箱，第 ${attempt}/${maxAttempts} 次`);

    if (attempt > 1) {
      await refreshInbox();
      await sleepRandom(900, 1500);
    }

    const items = findMailItems();
    if (items.length > 0) {
      const useFallback = attempt > FALLBACK_AFTER;

      for (let index = 0; index < items.length; index++) {
        const item = items[index];
        const itemId = getMailItemId(item, index);
        const itemTimestamp = parseMailItemTimestamp(item);