Function handlePollEmail

content/gmail-mail.js:543–683

(step, payload)

}

async function handlePollEmail(step, payload) {
  const {
    senderFilters = [],
    subjectFilters = [],
    maxAttempts = 5,
    intervalMs = 3000,
    filterAfterTimestamp = 0,
    excludeCodes = [],
    targetEmail = '',
  } = payload || {};

  const excludedCodeSet = new Set(excludeCodes.filter(Boolean));
  const filterAfterMinute = normalizeMinuteTimestamp(Number(filterAfterTimestamp) || 0);

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

  let initialRows = await ensureInboxReady(step);
  if (!initialRows.length) {
    await refreshInbox(step);
    initialRows = await ensureInboxReady(step);
  }

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

  const categoryOrder = getCategoryScanOrder();
  const existingMailIdsByCategory = new Map();

  for (const category of categoryOrder) {
    const activeCategory = await activateCategoryTab(step, category.key);
    const rows = collectThreadRows();
    existingMailIdsByCategory.set(activeCategory.key, getCurrentMailIds(rows));
    log(`步骤 ${step}：已记录 Gmail 分类 ${activeCategory.label} 的 ${rows.length} 封旧邮件快照`);
  }

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

    if (attempt > 1) {
      await refreshInbox(step);
    }

    const useFallback = attempt > GMAIL_FALLBACK_AFTER;

    for (const category of categoryOrder) {
      const activeCategory = await activateCategoryTab(step, category.key);
      const rows = collectThreadRows();
      const existingMailIds = existingMailIdsByCategory.get(activeCategory.key) || new Set();

      for (let index = 0; index < rows.length; index++) {
        const row = rows[index];
        const rowId = getRowFingerprint(row, index);
        const rowTimestamp = getRowTimestamp(row);
        const rowMinute = normalizeMinuteTimestamp(rowTimestamp || 0);