Merge branch '贡献功能开发' into dev

background/message-router.js

@@ -57,6 +57,7 @@
       notifyStepComplete,
       notifyStepError,
       patchHotmailAccount,
+      pollContributionStatus,
       registerTab,
       requestStop,
       handleCloudflareSecurityBlocked,
@@ -65,6 +66,7 @@
       scheduleAutoRun,
       selectLuckmailPurchase,
       setCurrentHotmailAccount,
+      setContributionMode,
       setEmailState,
       setEmailStateSilently,
       setIcloudAliasPreservedState,
@@ -77,6 +79,7 @@
       setStepStatus,
       skipAutoRunCountdown,
       skipStep,
+      startContributionFlow,
       startAutoRunLoop,
       syncHotmailAccounts,
       testHotmailAccountMailAccess,
@@ -289,6 +292,49 @@
           return { ok: true };
         }
 
+        case 'SET_CONTRIBUTION_MODE': {
+          const enabled = Boolean(message.payload?.enabled);
+          const state = await ensureManualInteractionAllowed(enabled ? '进入贡献模式' : '退出贡献模式');
+          if (Object.values(state.stepStatuses || {}).some((status) => status === 'running')) {
+            throw new Error(enabled ? '当前有步骤正在执行，无法进入贡献模式。' : '当前有步骤正在执行，无法退出贡献模式。');
+          }
+          if (typeof setContributionMode !== 'function') {
+            throw new Error('贡献模式切换能力未接入。');
+          }
+          return {
+            ok: true,
+            state: await setContributionMode(enabled),
+          };
+        }
+
+        case 'START_CONTRIBUTION_FLOW': {
+          const state = await ensureManualInteractionAllowed('开始贡献');
+          if (Object.values(state.stepStatuses || {}).some((status) => status === 'running')) {
+            throw new Error('当前有步骤正在执行，无法开始贡献流程。');
+          }
+          if (typeof startContributionFlow !== 'function') {
+            throw new Error('贡献 OAuth 流程尚未接入。');
+          }
+          return {
+            ok: true,
+            state: await startContributionFlow({
+              nickname: message.payload?.nickname,
+            }),
+          };
+        }
+
+        case 'POLL_CONTRIBUTION_STATUS': {
+          if (typeof pollContributionStatus !== 'function') {
+            throw new Error('贡献状态轮询能力尚未接入。');
+          }
+          return {
+            ok: true,
+            state: await pollContributionStatus({
+              reason: message.payload?.reason || 'sidepanel_poll',
+            }),
+          };
+        }
+
         case 'CLEAR_ACCOUNT_RUN_HISTORY': {
           const state = await getState();
           if (isAutoRunLockedState(state)) {
@@ -340,6 +386,9 @@
 
         case 'AUTO_RUN': {
           clearStopRequest();
+          if (Boolean(message.payload?.contributionMode) && typeof setContributionMode === 'function') {
+            await setContributionMode(true);
+          }
           const state = await getState();
           if (getPendingAutoRunTimerPlan(state)) {
             throw new Error('已有自动运行倒计时计划，请先取消或立即开始。');
@@ -354,6 +403,9 @@
 
         case 'SCHEDULE_AUTO_RUN': {
           clearStopRequest();
+          if (Boolean(message.payload?.contributionMode) && typeof setContributionMode === 'function') {
+            await setContributionMode(true);
+          }
           const totalRuns = normalizeRunCount(message.payload?.totalRuns || 1);
           return await scheduleAutoRun(totalRuns, {
             delayMinutes: message.payload?.delayMinutes,