vps-panel.js 26 KB

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