feat: support 2925 mail provider in OAuth signup flow

- 合并 PR #37 的核心改动：新增 2925 邮箱选项、步骤 3 自动别名邮箱生成，以及步骤 4/7 的 2925 收件箱轮询 - 本地补充修复：整合侧边栏邮箱登录与邮箱生成显隐冲突，并在离开 2925 或导入配置时清空托管邮箱残留状态 - 影响范围：sidepanel mail provider config、background step orchestration、2925 mail content script
2026-04-13 20:59:19 +08:00
parent b487c2c33c 42680642c3
commit 1c4ea22dcc
5 changed files with 573 additions and 12 deletions
@@ -0,0 +1,437 @@
+// content/mail-2925.js — Content script for 2925 Mail (steps 4, 7)
+// Injected dynamically on: 2925.com
+
+const MAIL2925_PREFIX = '[MultiPage:mail-2925]';
+const isTopFrame = window === window.top;
+
+console.log(MAIL2925_PREFIX, 'Content script loaded on', location.href, 'frame:', isTopFrame ? 'top' : 'child');
+
+if (!isTopFrame) {
+  console.log(MAIL2925_PREFIX, 'Skipping child frame');
+} else {
+
+let seenCodes = new Set();
+
+async function loadSeenCodes() {
+  try {
+    const data = await chrome.storage.session.get('seen2925Codes');
+    if (data.seen2925Codes && Array.isArray(data.seen2925Codes)) {
+      seenCodes = new Set(data.seen2925Codes);
+      console.log(MAIL2925_PREFIX, `Loaded ${seenCodes.size} previously seen codes`);
+    }
+  } catch (err) {
+    console.warn(MAIL2925_PREFIX, 'Session storage unavailable, using in-memory seen codes:', err?.message || err);
+  }
+}
+
+loadSeenCodes();
+
+async function persistSeenCodes() {
+  try {
+    await chrome.storage.session.set({ seen2925Codes: [...seenCodes] });
+  } catch (err) {
+    console.warn(MAIL2925_PREFIX, 'Could not persist seen codes, continuing in-memory only:', err?.message || err);
+  }
+}
+
+chrome.runtime.onMessage.addListener((message, sender, sendResponse) => {
+  if (message.type === 'POLL_EMAIL') {
+    resetStopState();
+    handlePollEmail(message.step, message.payload).then(result => {
+      sendResponse(result);
+    }).catch(err => {
+      if (isStopError(err)) {
+        log(`步骤 ${message.step}：已被用户停止。`, 'warn');
+        sendResponse({ stopped: true, error: err.message });
+        return;
+      }
+      log(`步骤 ${message.step}：邮箱轮询失败：${err.message}`, 'warn');
+      sendResponse({ error: err.message });
+    });
+    return true;
+  }
+});
+
+const MAIL_ITEM_SELECTORS = [
+  '.mail-item',
+  '.letter-item',
+  '[class*="mailItem"]',
+  '[class*="mail-item"]',
+  '[class*="MailItem"]',
+  '.el-table__row',
+  'tr[class*="mail"]',
+  '[class*="listItem"]',
+  '[class*="list-item"]',
+  'li[class*="mail"]',
+];
+
+function findMailItems() {
+  for (const selector of MAIL_ITEM_SELECTORS) {
+    const items = document.querySelectorAll(selector);
+    if (items.length > 0) {
+      return Array.from(items);
+    }
+  }
+  return [];
+}
+
+function getMailItemText(item) {
+  if (!item) return '';
+  const contentCell = item.querySelector('td.content, .content, .mail-content');
+  const titleEl = item.querySelector('.mail-content-title');
+  const textEl = item.querySelector('.mail-content-text');
+  return [
+    titleEl?.getAttribute('title') || '',
+    titleEl?.textContent || '',
+    textEl?.textContent || '',
+    contentCell?.textContent || '',
+    item.textContent || '',
+  ].join(' ');
+}
+
+function getMailItemTimeText(item) {
+  const timeEl = item?.querySelector('.date-time-text, [class*="date-time"], [class*="time"], td.time');
+  return (timeEl?.textContent || '').replace(/\s+/g, ' ').trim();
+}
+
+function normalizeMailIdentityPart(value) {
+  return (value || '').replace(/\s+/g, ' ').trim().toLowerCase();
+}
+
+function getMailItemId(item, index = 0) {
+  const candidates = [
+    item?.getAttribute?.('data-id'),
+    item?.dataset?.id,
+    item?.getAttribute?.('data-mail-id'),
+    item?.dataset?.mailId,
+    item?.getAttribute?.('data-key'),
+    item?.getAttribute?.('key'),
+  ].filter(Boolean);
+
+  if (candidates.length > 0) {
+    return String(candidates[0]);
+  }
+
+  return [
+    index,
+    normalizeMailIdentityPart(getMailItemTimeText(item)),
+    normalizeMailIdentityPart(getMailItemText(item)).slice(0, 240),
+  ].join('|');
+}
+
+function getCurrentMailIds(items = []) {
+  const ids = new Set();
+  items.forEach((item, index) => {
+    ids.add(getMailItemId(item, index));
+  });
+  return ids;
+}
+
+function normalizeMinuteTimestamp(timestamp) {
+  if (!Number.isFinite(timestamp) || timestamp <= 0) return 0;
+  const date = new Date(timestamp);
+  date.setSeconds(0, 0);
+  return date.getTime();
+}
+
+function matchesMailFilters(text, senderFilters, subjectFilters) {
+  const lower = (text || '').toLowerCase();
+  const senderMatch = senderFilters.some(filter => lower.includes(filter.toLowerCase()));
+  const subjectMatch = subjectFilters.some(filter => lower.includes(filter.toLowerCase()));
+  return senderMatch || subjectMatch;
+}
+
+function extractVerificationCode(text, strictChatGPTCodeOnly = false) {
+  if (strictChatGPTCodeOnly) {
+    const strictMatch = text.match(/your\s+chatgpt\s+code\s+is\s+(\d{6})/i);
+    return strictMatch ? strictMatch[1] : null;
+  }
+
+  const matchCn = text.match(/(?:代码为|验证码[^0-9]*?)[\s：:]*(\d{6})/);
+  if (matchCn) return matchCn[1];
+
+  const matchChatGPT = text.match(/your\s+chatgpt\s+code\s+is\s+(\d{6})/i);
+  if (matchChatGPT) return matchChatGPT[1];
+
+  const matchEn = text.match(/code[:\s]+is[:\s]+(\d{6})|code[:\s]+(\d{6})/i);
+  if (matchEn) return matchEn[1] || matchEn[2];
+
+  const match6 = text.match(/\b(\d{6})\b/);
+  if (match6) return match6[1];
+
+  return null;
+}
+
+function extractEmails(text) {
+  const matches = text.match(/[A-Z0-9._%+-]+@[A-Z0-9.-]+\.[A-Z]{2,}/ig) || [];
+  return [...new Set(matches.map(item => item.toLowerCase()))];
+}
+
+function emailMatchesTarget(candidate, targetEmail) {
+  const normalizedCandidate = String(candidate || '').trim().toLowerCase();
+  const normalizedTarget = String(targetEmail || '').trim().toLowerCase();
+  return Boolean(normalizedCandidate && normalizedTarget && normalizedCandidate === normalizedTarget);
+}
+
+function getTargetEmailMatchState(text, targetEmail) {
+  const normalizedTarget = String(targetEmail || '').trim().toLowerCase();
+  if (!normalizedTarget) {
+    return { matches: true, hasExplicitEmail: false };
+  }
+
+  const normalizedText = String(text || '').toLowerCase();
+  if (normalizedText.includes(normalizedTarget)) {
+    return { matches: true, hasExplicitEmail: true };
+  }
+
+  const atIndex = normalizedTarget.indexOf('@');
+  if (atIndex > 0) {
+    const encodedTarget = `${normalizedTarget.slice(0, atIndex)}=${normalizedTarget.slice(atIndex + 1)}`;
+    if (normalizedText.includes(encodedTarget)) {
+      return { matches: true, hasExplicitEmail: true };
+    }
+  }
+
+  const emails = extractEmails(text);
+  if (!emails.length) {
+    return { matches: false, hasExplicitEmail: false };
+  }
+
+  return {
+    matches: emails.some(email => emailMatchesTarget(email, normalizedTarget)),
+    hasExplicitEmail: true,
+  };
+}
+
+function parseMailItemTimestamp(item) {
+  const timeText = getMailItemTimeText(item);
+  if (!timeText) return null;
+
+  const now = new Date();
+  const date = new Date(now);
+  let match = null;
+
+  if (/刚刚/.test(timeText)) {
+    return now.getTime();
+  }
+
+  match = timeText.match(/(\d+)\s*分(?:钟)?前/);
+  if (match) {
+    return now.getTime() - Number(match[1]) * 60 * 1000;
+  }
+
+  match = timeText.match(/(\d+)\s*秒前/);
+  if (match) {
+    return now.getTime() - Number(match[1]) * 1000;
+  }
+
+  match = timeText.match(/^(\d{1,2}):(\d{2})$/);
+  if (match) {
+    date.setHours(Number(match[1]), Number(match[2]), 0, 0);
+    return date.getTime();
+  }
+
+  match = timeText.match(/今天\s*(\d{1,2}):(\d{2})/);
+  if (match) {
+    date.setHours(Number(match[1]), Number(match[2]), 0, 0);
+    return date.getTime();
+  }
+
+  match = timeText.match(/昨天\s*(\d{1,2}):(\d{2})/);
+  if (match) {
+    date.setDate(date.getDate() - 1);
+    date.setHours(Number(match[1]), Number(match[2]), 0, 0);
+    return date.getTime();
+  }
+
+  match = timeText.match(/(\d{1,2})-(\d{1,2})\s*(\d{1,2}):(\d{2})/);
+  if (match) {
+    date.setMonth(Number(match[1]) - 1, Number(match[2]));
+    date.setHours(Number(match[3]), Number(match[4]), 0, 0);
+    return date.getTime();
+  }
+
+  match = timeText.match(/(\d{4})-(\d{1,2})-(\d{1,2})\s*(\d{1,2}):(\d{2})/);
+  if (match) {
+    return new Date(
+      Number(match[1]),
+      Number(match[2]) - 1,
+      Number(match[3]),
+      Number(match[4]),
+      Number(match[5]),
+      0,
+      0
+    ).getTime();
+  }
+
+  return null;
+}
+
+async function sleepRandom(minMs, maxMs = minMs) {
+  const duration = Math.floor(Math.random() * (maxMs - minMs + 1)) + minMs;
+  await sleep(duration);
+}
+
+async function refreshInbox() {
+  const refreshBtn = document.querySelector(
+    '[class*="refresh"], [title*="刷新"], [aria-label*="刷新"], [class*="Refresh"]'
+  );
+  if (refreshBtn) {
+    simulateClick(refreshBtn);
+    await sleepRandom(700, 1200);
+    return;
+  }
+
+  const inboxLink = document.querySelector(
+    'a[href*="mailList"], [class*="inbox"], [class*="Inbox"], [title*="收件箱"]'
+  );
+  if (inboxLink) {
+    simulateClick(inboxLink);
+    await sleepRandom(700, 1200);
+  }
+}
+
+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);
+        const itemMinute = normalizeMinuteTimestamp(itemTimestamp || 0);
+        const passesTimeFilter = !filterAfterMinute || (itemMinute && itemMinute >= filterAfterMinute);
+        const shouldBypassOldSnapshot = Boolean(filterAfterMinute && passesTimeFilter && itemMinute > 0);
+
+        if (!passesTimeFilter) {
+          continue;
+        }
+
+        if (!useFallback && !shouldBypassOldSnapshot && existingMailIds.has(itemId)) {
+          continue;
+        }
+
+        const text = getMailItemText(item);
+        if (!matchesMailFilters(text, senderFilters, subjectFilters)) {
+          continue;
+        }
+
+        const previewEmails = extractEmails(text);
+        const previewTargetState = getTargetEmailMatchState(text, targetEmail);
+        const previewMatchesTarget = previewTargetState.matches;
+        if (targetEmail && previewEmails.length > 0 && !previewMatchesTarget) {
+          continue;
+        }
+
+        const code = extractVerificationCode(text, strictChatGPTCodeOnly);
+        if (code && previewMatchesTarget) {
+          if (excludedCodeSet.has(code)) {
+            log(`步骤 ${step}：跳过排除的验证码：${code}`, 'info');
+            continue;
+          }
+          if (seenCodes.has(code)) {
+            log(`步骤 ${step}：跳过已处理过的验证码：${code}`, 'info');
+            continue;
+          }
+          seenCodes.add(code);
+          persistSeenCodes();
+          const source = useFallback && existingMailIds.has(itemId) ? '回退匹配邮件' : '新邮件';
+          const timeLabel = itemTimestamp ? `，时间：${new Date(itemTimestamp).toLocaleString('zh-CN', { hour12: false })}` : '';
+          log(`步骤 ${step}：已找到验证码：${code}（来源：${source}${timeLabel}）`, 'ok');
+          await sleep(1000);
+          return { ok: true, code, emailTimestamp: Date.now() };
+        }
+
+        simulateClick(item);
+        await sleepRandom(1200, 2200);
+        const openedText = document.body?.textContent || '';
+        const bodyCode = extractVerificationCode(openedText, strictChatGPTCodeOnly);
+        const openedTargetState = getTargetEmailMatchState(openedText, targetEmail);
+        if (targetEmail && openedTargetState.hasExplicitEmail && !openedTargetState.matches) {
+          continue;
+        }
+        if (bodyCode) {
+          if (excludedCodeSet.has(bodyCode)) {
+            log(`步骤 ${step}：跳过排除的验证码：${bodyCode}`, 'info');
+            continue;
+          }
+          if (seenCodes.has(bodyCode)) {
+            log(`步骤 ${step}：跳过已处理过的验证码：${bodyCode}`, 'info');
+            continue;
+          }
+          seenCodes.add(bodyCode);
+          persistSeenCodes();
+          const source = useFallback && existingMailIds.has(itemId) ? '回退匹配邮件正文' : '新邮件正文';
+          const timeLabel = itemTimestamp ? `，时间：${new Date(itemTimestamp).toLocaleString('zh-CN', { hour12: false })}` : '';
+          log(`步骤 ${step}：已在邮件正文中找到验证码：${bodyCode}（来源：${source}${timeLabel}）`, 'ok');
+          await sleep(1000);
+          return { ok: true, code: bodyCode, emailTimestamp: Date.now() };
+        }
+      }
+    }
+
+    if (attempt === FALLBACK_AFTER + 1) {
+      log(`步骤 ${step}：连续 ${FALLBACK_AFTER} 次未发现新邮件，开始回退到首封匹配邮件`, 'warn');
+    }
+
+    if (attempt < maxAttempts) {
+      await sleepRandom(intervalMs, intervalMs + 1200);
+    }
+  }
+
+  throw new Error(
+    `${(maxAttempts * intervalMs / 1000).toFixed(0)} 秒后仍未在 2925 邮箱中找到新的匹配邮件。请手动检查收件箱。`
+  );
+}
+
+}