vps-panel.js 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649
  1. // content/vps-panel.js — Content script for CPA panel (steps 1, 9)
  2. // Injected on: CPA panel (user-configured URL)
  3. //
  4. // Actual DOM structure (after login click):
  5. // <div class="card">
  6. // <div class="card-header">
  7. // <span class="OAuthPage-module__cardTitle___yFaP0">Codex OAuth</span>
  8. // <button class="btn btn-primary"><span>登录</span></button>
  9. // </div>
  10. // <div class="OAuthPage-module__cardContent___1sXLA">
  11. // <div class="OAuthPage-module__authUrlBox___Iu1d4">
  12. // <div class="OAuthPage-module__authUrlLabel___mYFJB">授权链接:</div>
  13. // <div class="OAuthPage-module__authUrlValue___axvUJ">https://auth.openai.com/...</div>
  14. // <div class="OAuthPage-module__authUrlActions___venPj">
  15. // <button class="btn btn-secondary btn-sm"><span>复制链接</span></button>
  16. // <button class="btn btn-secondary btn-sm"><span>打开链接</span></button>
  17. // </div>
  18. // </div>
  19. // <div class="OAuthPage-module__callbackSection___8kA31">
  20. // <input class="input" placeholder="http://localhost:1455/auth/callback?code=...&state=...">
  21. // <button class="btn btn-secondary btn-sm"><span>提交回调 URL</span></button>
  22. // </div>
  23. // </div>
  24. // </div>
  25. console.log('[MultiPage:vps-panel] Content script loaded on', location.href);
  26. const VPS_PANEL_LISTENER_SENTINEL = 'data-multipage-vps-panel-listener';
  27. const STEP9_SUCCESS_BADGE_TIMEOUT_MS = 120000;
  28. const {
  29. isRecoverableStep9AuthFailure,
  30. } = self.MultiPageActivationUtils || {};
  31. if (document.documentElement.getAttribute(VPS_PANEL_LISTENER_SENTINEL) !== '1') {
  32. document.documentElement.setAttribute(VPS_PANEL_LISTENER_SENTINEL, '1');
  33. // Listen for commands from Background
  34. chrome.runtime.onMessage.addListener((message, sender, sendResponse) => {
  35. if (message.type === 'EXECUTE_STEP') {
  36. resetStopState();
  37. const startedAt = Date.now();
  38. console.log(LOG_PREFIX, `EXECUTE_STEP received for step ${message.step}`, {
  39. url: location.href,
  40. payloadKeys: Object.keys(message.payload || {}),
  41. snapshot: getVpsPanelSnapshot(),
  42. });
  43. handleStep(message.step, message.payload).then(() => {
  44. console.log(LOG_PREFIX, `EXECUTE_STEP resolved for step ${message.step} after ${Date.now() - startedAt}ms`, {
  45. url: location.href,
  46. snapshot: getVpsPanelSnapshot(),
  47. });
  48. sendResponse({ ok: true });
  49. }).catch(err => {
  50. console.error(LOG_PREFIX, `EXECUTE_STEP rejected for step ${message.step} after ${Date.now() - startedAt}ms: ${err?.message || err}`, {
  51. url: location.href,
  52. snapshot: getVpsPanelSnapshot(),
  53. });
  54. if (isStopError(err)) {
  55. log(`步骤 ${message.step}:已被用户停止。`, 'warn');
  56. sendResponse({ stopped: true, error: err.message });
  57. return;
  58. }
  59. reportError(message.step, err.message);
  60. sendResponse({ error: err.message });
  61. });
  62. return true;
  63. }
  64. });
  65. } else {
  66. console.log('[MultiPage:vps-panel] 消息监听已存在,跳过重复注册');
  67. }
  68. async function handleStep(step, payload) {
  69. switch (step) {
  70. case 1: return await step1_getOAuthLink(payload);
  71. case 9: return await step9_vpsVerify(payload);
  72. default:
  73. throw new Error(`vps-panel.js 不处理步骤 ${step}`);
  74. }
  75. }
  76. function isVisibleElement(el) {
  77. if (!el) return false;
  78. const style = window.getComputedStyle(el);
  79. const rect = el.getBoundingClientRect();
  80. return style.display !== 'none'
  81. && style.visibility !== 'hidden'
  82. && rect.width > 0
  83. && rect.height > 0;
  84. }
  85. function getActionText(el) {
  86. return [
  87. el?.textContent,
  88. el?.value,
  89. el?.getAttribute?.('aria-label'),
  90. el?.getAttribute?.('title'),
  91. ]
  92. .filter(Boolean)
  93. .join(' ')
  94. .replace(/\s+/g, ' ')
  95. .trim();
  96. }
  97. function getInlineTextSnippet(text, maxLength = 160) {
  98. const normalized = (text || '').replace(/\s+/g, ' ').trim();
  99. if (!normalized) return '';
  100. if (normalized.length <= maxLength) return normalized;
  101. return `${normalized.slice(0, maxLength)}...`;
  102. }
  103. function getPageTextSnippet(maxLength = 240) {
  104. const bodyText = document.body?.innerText || document.documentElement?.innerText || '';
  105. return getInlineTextSnippet(bodyText, maxLength);
  106. }
  107. function getVpsPanelSnapshot() {
  108. const authUrlEl = findAuthUrlElement();
  109. const oauthHeader = findCodexOAuthHeader();
  110. const managementKeyInput = findManagementKeyInput();
  111. const managementLoginButton = findManagementLoginButton();
  112. const rememberCheckbox = findRememberPasswordCheckbox();
  113. const oauthNavLink = findOAuthNavLink();
  114. return {
  115. url: location.href,
  116. readyState: document.readyState,
  117. title: getInlineTextSnippet(document.title || '', 80),
  118. authUrlVisible: Boolean(authUrlEl),
  119. authUrlText: getInlineTextSnippet(authUrlEl?.textContent || '', 120),
  120. oauthHeaderVisible: Boolean(oauthHeader),
  121. oauthHeaderText: getInlineTextSnippet(oauthHeader?.textContent || '', 120),
  122. managementKeyVisible: Boolean(managementKeyInput),
  123. managementLoginVisible: Boolean(managementLoginButton),
  124. managementLoginText: getInlineTextSnippet(getActionText(managementLoginButton), 60),
  125. rememberCheckboxVisible: Boolean(rememberCheckbox),
  126. rememberCheckboxChecked: Boolean(rememberCheckbox?.checked),
  127. oauthNavVisible: Boolean(oauthNavLink),
  128. oauthNavText: getInlineTextSnippet(getActionText(oauthNavLink), 80),
  129. bodySnippet: getPageTextSnippet(),
  130. };
  131. }
  132. function getVpsPanelSnapshotSignature(snapshot) {
  133. return JSON.stringify({
  134. readyState: snapshot.readyState,
  135. title: snapshot.title,
  136. authUrlVisible: snapshot.authUrlVisible,
  137. authUrlText: snapshot.authUrlText,
  138. oauthHeaderVisible: snapshot.oauthHeaderVisible,
  139. oauthHeaderText: snapshot.oauthHeaderText,
  140. managementKeyVisible: snapshot.managementKeyVisible,
  141. managementLoginVisible: snapshot.managementLoginVisible,
  142. rememberCheckboxVisible: snapshot.rememberCheckboxVisible,
  143. rememberCheckboxChecked: snapshot.rememberCheckboxChecked,
  144. oauthNavVisible: snapshot.oauthNavVisible,
  145. oauthNavText: snapshot.oauthNavText,
  146. bodySnippet: snapshot.bodySnippet,
  147. });
  148. }
  149. function parseUrlSafely(rawUrl) {
  150. if (!rawUrl) return null;
  151. try {
  152. return new URL(rawUrl);
  153. } catch {
  154. return null;
  155. }
  156. }
  157. function isLocalhostOAuthCallbackUrl(rawUrl) {
  158. const parsed = parseUrlSafely(rawUrl);
  159. if (!parsed) return false;
  160. if (!['http:', 'https:'].includes(parsed.protocol)) return false;
  161. if (!['localhost', '127.0.0.1'].includes(parsed.hostname)) return false;
  162. if (!['/auth/callback', '/codex/callback'].includes(parsed.pathname)) return false;
  163. const code = (parsed.searchParams.get('code') || '').trim();
  164. const state = (parsed.searchParams.get('state') || '').trim();
  165. return Boolean(code && state);
  166. }
  167. function getStatusBadgeSelectors() {
  168. return [
  169. '#root > div > div > div > main > div > div > div > div > div:nth-child(1) > div > div.OAuthPage-module__cardContent___1sXLA > div.status-badge',
  170. '#root .OAuthPage-module__cardContent___1sXLA > .status-badge',
  171. '.OAuthPage-module__cardContent___1sXLA > .status-badge',
  172. '.status-badge',
  173. ];
  174. }
  175. function getStatusBadgeEntries() {
  176. const seen = new Set();
  177. const entries = [];
  178. for (const selector of getStatusBadgeSelectors()) {
  179. const candidates = document.querySelectorAll(selector);
  180. for (const candidate of candidates) {
  181. if (seen.has(candidate)) continue;
  182. seen.add(candidate);
  183. entries.push({
  184. element: candidate,
  185. selector,
  186. visible: isVisibleElement(candidate),
  187. text: (candidate.textContent || '').replace(/\s+/g, ' ').trim(),
  188. className: String(candidate.className || '').replace(/\s+/g, ' ').trim(),
  189. });
  190. }
  191. }
  192. return entries;
  193. }
  194. function summarizeStatusBadgeEntries(entries) {
  195. if (!entries.length) return '无可见状态徽标';
  196. return entries
  197. .map((entry, index) => {
  198. const text = entry.text || '(空文本)';
  199. const className = entry.className ? ` class=${getInlineTextSnippet(entry.className, 80)}` : '';
  200. return `#${index + 1}="${getInlineTextSnippet(text, 80)}"${className}`;
  201. })
  202. .join(' | ');
  203. }
  204. const STEP9_SUCCESS_STATUSES = new Set([
  205. 'Authentication successful!',
  206. 'Аутентификация успешна!',
  207. '认证成功!',
  208. ]);
  209. function normalizeStep9StatusText(statusText) {
  210. return String(statusText || '').replace(/\s+/g, ' ').trim();
  211. }
  212. function isStep9SuccessStatus(statusText) {
  213. return STEP9_SUCCESS_STATUSES.has(normalizeStep9StatusText(statusText));
  214. }
  215. function isStep9SuccessLikeStatus(statusText) {
  216. const text = normalizeStep9StatusText(statusText);
  217. return /authentication successful|аутентификац.*успеш|认证成功/i.test(text);
  218. }
  219. function getStatusBadgeDiagnostics() {
  220. const entries = getStatusBadgeEntries();
  221. const visibleEntries = entries.filter((entry) => entry.visible);
  222. const selectedEntry = visibleEntries[0] || null;
  223. const selectedText = selectedEntry?.text || '';
  224. const successLikeEntries = visibleEntries.filter((entry) => isStep9SuccessLikeStatus(entry.text));
  225. const exactSuccessEntries = visibleEntries.filter((entry) => isStep9SuccessStatus(entry.text));
  226. const visibleSummary = summarizeStatusBadgeEntries(visibleEntries);
  227. const pageSnippet = getPageTextSnippet();
  228. return {
  229. selectedText,
  230. visibleCount: visibleEntries.length,
  231. visibleSummary,
  232. hasSuccessLikeVisibleBadge: successLikeEntries.length > 0,
  233. hasExactSuccessVisibleBadge: exactSuccessEntries.length > 0,
  234. successLikeSummary: summarizeStatusBadgeEntries(successLikeEntries),
  235. exactSuccessSummary: summarizeStatusBadgeEntries(exactSuccessEntries),
  236. pageSnippet,
  237. signature: JSON.stringify({
  238. selectedText,
  239. visibleCount: visibleEntries.length,
  240. visibleSummary,
  241. successLikeSummary: summarizeStatusBadgeEntries(successLikeEntries),
  242. }),
  243. summary: selectedText
  244. ? `当前选中徽标="${getInlineTextSnippet(selectedText, 80)}";可见徽标 ${visibleEntries.length} 个:${visibleSummary}`
  245. : `当前未选中任何可见状态徽标;可见徽标 ${visibleEntries.length} 个:${visibleSummary};页面片段="${getInlineTextSnippet(pageSnippet, 120)}"`,
  246. };
  247. }
  248. function getStatusBadgeElement() {
  249. const visibleEntry = getStatusBadgeEntries().find((entry) => entry.visible);
  250. return visibleEntry ? visibleEntry.element : null;
  251. }
  252. function getStatusBadgeText() {
  253. const diagnostics = getStatusBadgeDiagnostics();
  254. return diagnostics.selectedText;
  255. }
  256. function isOAuthCallbackTimeoutFailure(statusText) {
  257. return /认证失败:\s*Timeout waiting for OAuth callback/i.test(statusText || '');
  258. }
  259. async function waitForExactSuccessBadge(timeout = STEP9_SUCCESS_BADGE_TIMEOUT_MS) {
  260. const start = Date.now();
  261. let lastDiagnosticsSignature = '';
  262. let lastHeartbeatLoggedAt = 0;
  263. let lastSuccessLikeMismatchSignature = '';
  264. while (Date.now() - start < timeout) {
  265. throwIfStopped();
  266. const diagnostics = getStatusBadgeDiagnostics();
  267. const statusText = diagnostics.selectedText;
  268. const elapsed = Date.now() - start;
  269. if (diagnostics.signature !== lastDiagnosticsSignature) {
  270. lastDiagnosticsSignature = diagnostics.signature;
  271. lastHeartbeatLoggedAt = elapsed;
  272. log(`步骤 9:认证状态检测中,${diagnostics.summary}`);
  273. console.log(LOG_PREFIX, '[Step 9] status badge diagnostics changed', diagnostics);
  274. } else if (elapsed - lastHeartbeatLoggedAt >= 10000) {
  275. lastHeartbeatLoggedAt = elapsed;
  276. log(`步骤 9:仍在等待认证成功,${diagnostics.summary}`);
  277. console.log(LOG_PREFIX, '[Step 9] still waiting for success badge', diagnostics);
  278. }
  279. if (diagnostics.hasSuccessLikeVisibleBadge && !diagnostics.hasExactSuccessVisibleBadge) {
  280. const mismatchSignature = JSON.stringify({
  281. selectedText: diagnostics.selectedText,
  282. successLikeSummary: diagnostics.successLikeSummary,
  283. visibleSummary: diagnostics.visibleSummary,
  284. });
  285. if (mismatchSignature !== lastSuccessLikeMismatchSignature) {
  286. lastSuccessLikeMismatchSignature = mismatchSignature;
  287. log(
  288. `步骤 9:检测到“认证成功”相关徽标,但未命中精确条件。当前选中="${getInlineTextSnippet(diagnostics.selectedText || '(空)', 80)}";成功相关徽标:${diagnostics.successLikeSummary}`,
  289. 'warn'
  290. );
  291. console.warn(LOG_PREFIX, '[Step 9] success-like badge detected without exact match', diagnostics);
  292. }
  293. }
  294. if (isOAuthCallbackTimeoutFailure(statusText)) {
  295. throw new Error(`STEP9_OAUTH_TIMEOUT::${statusText}`);
  296. }
  297. if (typeof isRecoverableStep9AuthFailure === 'function' && isRecoverableStep9AuthFailure(statusText)) {
  298. throw new Error(`STEP9_OAUTH_RETRY::${statusText}`);
  299. }
  300. if (isStep9SuccessStatus(statusText)) {
  301. return statusText;
  302. }
  303. await sleep(200);
  304. }
  305. const finalDiagnostics = getStatusBadgeDiagnostics();
  306. const finalText = finalDiagnostics.selectedText;
  307. const diagnosticsSuffix = ` 当前诊断:${finalDiagnostics.summary}`;
  308. if (isOAuthCallbackTimeoutFailure(finalText)) {
  309. throw new Error(`STEP9_OAUTH_TIMEOUT::${finalText}${diagnosticsSuffix}`);
  310. }
  311. if (typeof isRecoverableStep9AuthFailure === 'function' && isRecoverableStep9AuthFailure(finalText)) {
  312. throw new Error(`STEP9_OAUTH_RETRY::${finalText}${diagnosticsSuffix}`);
  313. }
  314. throw new Error(finalText
  315. ? `CPA 面板状态未进入成功状态,当前为“${finalText}”。${diagnosticsSuffix}`
  316. : `CPA 面板长时间未出现成功状态徽标。${diagnosticsSuffix}`);
  317. }
  318. function findManagementKeyInput() {
  319. const candidates = document.querySelectorAll(
  320. '.LoginPage-module__loginCard___OgP-R input[type="password"], input[placeholder*="管理密钥"], input[aria-label*="管理密钥"]'
  321. );
  322. return Array.from(candidates).find(isVisibleElement) || null;
  323. }
  324. function findManagementLoginButton() {
  325. const candidates = document.querySelectorAll('.LoginPage-module__loginCard___OgP-R button, .LoginPage-module__loginCard___OgP-R .btn');
  326. return Array.from(candidates).find((el) => {
  327. if (!isVisibleElement(el)) return false;
  328. return /登录|login/i.test(getActionText(el));
  329. }) || null;
  330. }
  331. function findRememberPasswordCheckbox() {
  332. const candidates = document.querySelectorAll('.LoginPage-module__loginCard___OgP-R input[type="checkbox"]');
  333. return Array.from(candidates).find((el) => {
  334. const label = el.closest('label');
  335. const text = getActionText(label || el);
  336. return /记住密码|remember/i.test(text);
  337. }) || null;
  338. }
  339. function findOAuthNavLink() {
  340. const candidates = document.querySelectorAll('a[href*="#/oauth"], a.nav-item, button, [role="link"], [role="button"]');
  341. return Array.from(candidates).find((el) => {
  342. if (!isVisibleElement(el)) return false;
  343. const text = getActionText(el);
  344. const href = el.getAttribute('href') || '';
  345. return href.includes('#/oauth') || /oauth/i.test(text);
  346. }) || null;
  347. }
  348. function findCodexOAuthHeader() {
  349. const candidates = document.querySelectorAll('.card-header, [class*="cardHeader"], .card, [class*="card"]');
  350. return Array.from(candidates).find((el) => {
  351. if (!isVisibleElement(el)) return false;
  352. const text = (el.textContent || '').toLowerCase();
  353. return text.includes('codex') && text.includes('oauth');
  354. }) || null;
  355. }
  356. function findOAuthCardLoginButton(header) {
  357. const card = header?.closest('.card, [class*="card"]') || header?.parentElement || document;
  358. const candidates = card.querySelectorAll('button.btn.btn-primary, button.btn-primary, button.btn');
  359. return Array.from(candidates).find((el) => isVisibleElement(el) && /登录|login/i.test(getActionText(el))) || null;
  360. }
  361. function findAuthUrlElement() {
  362. const candidates = document.querySelectorAll('[class*="authUrlValue"], .OAuthPage-module__authUrlValue___axvUJ');
  363. return Array.from(candidates).find((el) => isVisibleElement(el) && /^https?:\/\//i.test((el.textContent || '').trim())) || null;
  364. }
  365. async function ensureOAuthManagementPage(vpsPassword, step = 1, timeout = 45000) {
  366. const start = Date.now();
  367. let lastLoginAttemptAt = 0;
  368. let lastOauthNavAttemptAt = 0;
  369. let lastSnapshotSignature = '';
  370. let lastSnapshotLogAt = 0;
  371. console.log(LOG_PREFIX, `[Step ${step}] ensureOAuthManagementPage start`, {
  372. timeout,
  373. url: location.href,
  374. hasVpsPassword: Boolean(vpsPassword),
  375. snapshot: getVpsPanelSnapshot(),
  376. });
  377. while (Date.now() - start < timeout) {
  378. throwIfStopped();
  379. const elapsed = Date.now() - start;
  380. const snapshot = getVpsPanelSnapshot();
  381. const signature = getVpsPanelSnapshotSignature(snapshot);
  382. if (signature !== lastSnapshotSignature || elapsed - lastSnapshotLogAt >= 5000) {
  383. lastSnapshotSignature = signature;
  384. lastSnapshotLogAt = elapsed;
  385. console.log(LOG_PREFIX, `[Step ${step}] panel snapshot at ${elapsed}ms`, snapshot);
  386. }
  387. const authUrlEl = findAuthUrlElement();
  388. if (authUrlEl) {
  389. console.log(LOG_PREFIX, `[Step ${step}] found visible auth URL after ${elapsed}ms`, {
  390. url: location.href,
  391. authUrlText: getInlineTextSnippet(authUrlEl.textContent || '', 120),
  392. });
  393. return { header: findCodexOAuthHeader(), authUrlEl };
  394. }
  395. const oauthHeader = findCodexOAuthHeader();
  396. if (oauthHeader) {
  397. console.log(LOG_PREFIX, `[Step ${step}] found OAuth card header after ${elapsed}ms`, {
  398. url: location.href,
  399. headerText: getInlineTextSnippet(oauthHeader.textContent || '', 120),
  400. });
  401. return { header: oauthHeader, authUrlEl: null };
  402. }
  403. const managementKeyInput = findManagementKeyInput();
  404. const managementLoginButton = findManagementLoginButton();
  405. if (managementKeyInput && managementLoginButton) {
  406. if (!vpsPassword) {
  407. throw new Error('CPA 面板需要管理密钥,请先在侧边栏填写 CPA Key(管理密钥)。');
  408. }
  409. if ((managementKeyInput.value || '') !== vpsPassword) {
  410. await humanPause(350, 900);
  411. fillInput(managementKeyInput, vpsPassword);
  412. console.log(LOG_PREFIX, `[Step ${step}] filled management key after ${elapsed}ms`);
  413. log(`步骤 ${step}:已填写 CPA 管理密钥。`);
  414. }
  415. const rememberCheckbox = findRememberPasswordCheckbox();
  416. if (rememberCheckbox && !rememberCheckbox.checked) {
  417. simulateClick(rememberCheckbox);
  418. console.log(LOG_PREFIX, `[Step ${step}] toggled remember checkbox after ${elapsed}ms`);
  419. log(`步骤 ${step}:已勾选 CPA 面板“记住密码”。`);
  420. await sleep(300);
  421. }
  422. if (Date.now() - lastLoginAttemptAt > 3000) {
  423. lastLoginAttemptAt = Date.now();
  424. await humanPause(350, 900);
  425. simulateClick(managementLoginButton);
  426. console.log(LOG_PREFIX, `[Step ${step}] clicked management login after ${elapsed}ms`, {
  427. buttonText: getInlineTextSnippet(getActionText(managementLoginButton), 80),
  428. });
  429. log(`步骤 ${step}:已提交 CPA 管理登录。`);
  430. }
  431. await sleep(1500);
  432. continue;
  433. }
  434. const oauthNavLink = findOAuthNavLink();
  435. if (oauthNavLink && Date.now() - lastOauthNavAttemptAt > 2000) {
  436. lastOauthNavAttemptAt = Date.now();
  437. await humanPause(300, 800);
  438. simulateClick(oauthNavLink);
  439. console.log(LOG_PREFIX, `[Step ${step}] clicked OAuth nav after ${elapsed}ms`, {
  440. navText: getInlineTextSnippet(getActionText(oauthNavLink), 80),
  441. });
  442. log(`步骤 ${step}:已打开“OAuth 登录”导航。`);
  443. await sleep(1200);
  444. continue;
  445. }
  446. await sleep(250);
  447. }
  448. console.error(LOG_PREFIX, `[Step ${step}] ensureOAuthManagementPage timeout after ${Date.now() - start}ms`, {
  449. url: location.href,
  450. snapshot: getVpsPanelSnapshot(),
  451. });
  452. throw new Error('无法进入 CPA 的 OAuth 管理页面,请检查面板是否正常加载。URL: ' + location.href);
  453. }
  454. // ============================================================
  455. // Step 1: Get OAuth Link
  456. // ============================================================
  457. async function step1_getOAuthLink(payload) {
  458. const { vpsPassword } = payload || {};
  459. console.log(LOG_PREFIX, '[Step 1] step1_getOAuthLink start', {
  460. url: location.href,
  461. hasVpsPassword: Boolean(vpsPassword),
  462. snapshot: getVpsPanelSnapshot(),
  463. });
  464. log('步骤 1:正在等待 CPA 面板加载并进入 OAuth 页面...');
  465. const { header, authUrlEl: existingAuthUrlEl } = await ensureOAuthManagementPage(vpsPassword, 1);
  466. let authUrlEl = existingAuthUrlEl;
  467. console.log(LOG_PREFIX, '[Step 1] ensureOAuthManagementPage resolved', {
  468. url: location.href,
  469. hasHeader: Boolean(header),
  470. hasExistingAuthUrl: Boolean(existingAuthUrlEl),
  471. snapshot: getVpsPanelSnapshot(),
  472. });
  473. if (!authUrlEl) {
  474. const loginBtn = findOAuthCardLoginButton(header);
  475. if (!loginBtn) {
  476. throw new Error('已找到 Codex OAuth 卡片,但卡片内没有登录按钮。URL: ' + location.href);
  477. }
  478. if (loginBtn.disabled) {
  479. console.log(LOG_PREFIX, '[Step 1] OAuth login button is disabled, waiting for auth URL', {
  480. url: location.href,
  481. buttonText: getInlineTextSnippet(getActionText(loginBtn), 80),
  482. });
  483. log('步骤 1:OAuth 登录按钮当前不可用,正在等待授权链接出现...');
  484. } else {
  485. await humanPause(500, 1400);
  486. simulateClick(loginBtn);
  487. console.log(LOG_PREFIX, '[Step 1] clicked OAuth login button and waiting for auth URL', {
  488. url: location.href,
  489. buttonText: getInlineTextSnippet(getActionText(loginBtn), 80),
  490. });
  491. log('步骤 1:已点击 OAuth 登录按钮,正在等待授权链接...');
  492. }
  493. try {
  494. authUrlEl = await waitForElement('[class*="authUrlValue"]', 15000);
  495. } catch {
  496. throw new Error(
  497. '点击 OAuth 登录按钮后未出现授权链接。' +
  498. '请检查 CPA 面板服务是否正在运行。URL: ' + location.href
  499. );
  500. }
  501. } else {
  502. log('步骤 1:CPA 面板上已显示授权链接。');
  503. }
  504. const oauthUrl = (authUrlEl.textContent || '').trim();
  505. if (!oauthUrl || !oauthUrl.startsWith('http')) {
  506. throw new Error(`拿到的 OAuth 链接无效:\"${oauthUrl.slice(0, 50)}\"。应为 http 开头的 URL。`);
  507. }
  508. log(`步骤 1:已获取 OAuth 链接:${oauthUrl.slice(0, 80)}...`, 'ok');
  509. console.log(LOG_PREFIX, '[Step 1] reporting completion with oauthUrl', {
  510. url: location.href,
  511. oauthUrlPreview: oauthUrl.slice(0, 120),
  512. });
  513. reportComplete(1, { oauthUrl });
  514. }
  515. // ============================================================
  516. // 步骤 9:CPA 回调验证——填写 localhost 回调地址并提交
  517. // ============================================================
  518. async function step9_vpsVerify(payload) {
  519. await ensureOAuthManagementPage(payload?.vpsPassword, 9);
  520. // 优先从 payload 读取 localhostUrl;没有时再回退到全局状态
  521. let localhostUrl = payload?.localhostUrl;
  522. if (localhostUrl && !isLocalhostOAuthCallbackUrl(localhostUrl)) {
  523. throw new Error('步骤 9 只接受真实的 localhost OAuth 回调地址,请重新执行步骤 8。');
  524. }
  525. if (!localhostUrl) {
  526. log('步骤 9:payload 中没有 localhostUrl,正在从状态中读取...');
  527. const state = await chrome.runtime.sendMessage({ type: 'GET_STATE' });
  528. localhostUrl = state.localhostUrl;
  529. if (localhostUrl && !isLocalhostOAuthCallbackUrl(localhostUrl)) {
  530. throw new Error('步骤 9 只接受真实的 localhost OAuth 回调地址,请重新执行步骤 8。');
  531. }
  532. }
  533. if (!localhostUrl) {
  534. throw new Error('未找到 localhost 回调地址,请先完成步骤 8。');
  535. }
  536. log(`步骤 9:已获取 localhostUrl:${localhostUrl.slice(0, 60)}...`);
  537. log('步骤 9:正在查找回调地址输入框...');
  538. // Find the callback URL input
  539. // Actual DOM: <input class="input" placeholder="http://localhost:1455/auth/callback?code=...&state=...">
  540. let urlInput = null;
  541. try {
  542. urlInput = await waitForElement('[class*="callbackSection"] input.input', 10000);
  543. } catch {
  544. try {
  545. urlInput = await waitForElement('input[placeholder*="localhost"]', 5000);
  546. } catch {
  547. throw new Error('在 CPA 面板中未找到回调地址输入框。URL: ' + location.href);
  548. }
  549. }
  550. await humanPause(600, 1500);
  551. fillInput(urlInput, localhostUrl);
  552. log(`步骤 9:已填写回调地址:${localhostUrl.slice(0, 80)}...`);
  553. // Find and click the callback submit button in supported UI languages.
  554. const callbackSubmitPattern = /提交回调\s*URL|Submit\s+Callback\s+URL|Отправить\s+Callback\s+URL/i;
  555. let submitBtn = null;
  556. try {
  557. submitBtn = await waitForElementByText(
  558. '[class*="callbackActions"] button, [class*="callbackSection"] button',
  559. callbackSubmitPattern,
  560. 5000
  561. );
  562. } catch {
  563. try {
  564. submitBtn = await waitForElementByText('button.btn', callbackSubmitPattern, 5000);
  565. } catch {
  566. throw new Error('未找到回调提交按钮(提交回调 URL / Submit Callback URL / Отправить Callback URL)。URL: ' + location.href);
  567. }
  568. }
  569. await humanPause(450, 1200);
  570. simulateClick(submitBtn);
  571. log('步骤 9:已点击回调提交按钮,正在等待认证结果...');
  572. const verifiedStatus = await waitForExactSuccessBadge();
  573. log(`步骤 9:${verifiedStatus}`, 'ok');
  574. reportComplete(9, { localhostUrl, verifiedStatus });
  575. }