gitoria

5.2 KB

1. // tests/firefox.mjs — a REAL Firefox for the gate (mission 033: the creator uses Firefox and saw full page loads).
2. // Headless Firefox driven over WebDriver BiDi (Firefox's own protocol, `--remote-debugging-port`, ws …/session), no
3. // driver or npm package. Host names are mapped to 127.0.0.1 with the pref `network.dns.localDomains` (exact names).
4. // Clicks are REAL pointer input (input.performActions), not element.click().
5. // const ff = await launchFirefox({ port: 8730, hosts: ['gitoria.test', 'alpha.gitoria.test'] });
6. // await ff.goto(url); await ff.click('#navcode'); await ff.waitFor('expr'); await ff.evaluate('expr'); await ff.close();
7. import { spawn } from 'node:child_process';
8. import { mkdtempSync, writeFileSync, rmSync } from 'node:fs';
9. import { tmpdir } from 'node:os';
10. import { join } from 'node:path';
12. const sleep = (ms) => new Promise(r => setTimeout(r, ms));
14. export async function launchFirefox({ port, hosts = [], bin = process.env.HL_FIREFOX || '/usr/bin/firefox' }) {
15. const profile = mkdtempSync(join(tmpdir(), 'gitoria-ff-'));
16. writeFileSync(join(profile, 'user.js'), [
17. `user_pref("network.dns.localDomains", ${JSON.stringify(hosts.join(','))});`,
18. 'user_pref("browser.shell.checkDefaultBrowser", false);',
19. 'user_pref("datareporting.policy.dataSubmissionEnabled", false);',
20. 'user_pref("toolkit.telemetry.reportingpolicy.firstRun", false);',
21. 'user_pref("browser.aboutwelcome.enabled", false);',
22. 'user_pref("network.proxy.type", 0);',
23. ].join('\n') + '\n');
24. const proc = spawn(bin, ['--headless', '--no-remote', '--profile', profile, `--remote-debugging-port=${port}`, 'about:blank'], { stdio: ['ignore', 'pipe', 'pipe'] });
25. let out = '';
26. proc.stdout.on('data', d => out += d); proc.stderr.on('data', d => out += d);
27. let ws = null;
28. for (let i = 0; i < 80 && !ws; i++) {
29. await sleep(250);
30. if (!/WebDriver BiDi listening/.test(out)) continue;
31. ws = await new Promise((res) => { const w = new WebSocket(`ws://127.0.0.1:${port}/session`); w.onopen = () => res(w); w.onerror = () => res(null); });
32. }
33. if (!ws) { try { proc.kill('SIGKILL'); } catch {} rmSync(profile, { recursive: true, force: true }); throw new Error('firefox did not open BiDi\n' + out.slice(-800)); }
34. let next = 0; const pending = new Map();
35. const errors = [];
36. ws.onmessage = (ev) => {
37. const m = JSON.parse(ev.data);
38. if (m.id != null && pending.has(m.id)) { const p = pending.get(m.id); pending.delete(m.id); m.type === 'error' ? p.rej(new Error(m.error + ': ' + m.message)) : p.res(m.result); return; }
39. if (m.method === 'log.entryAdded' && m.params && m.params.level === 'error') errors.push(m.params.text || '');
40. };
41. const send = (method, params = {}) => new Promise((res, rej) => { const id = ++next; pending.set(id, { res, rej }); ws.send(JSON.stringify({ id, method, params })); });
42. await send('session.new', { capabilities: {} });
43. await send('session.subscribe', { events: ['log.entryAdded'] });
44. const tree = await send('browsingContext.getTree', {});
45. const context = tree.contexts[0].context;
46. const evaluate = async (expression) => {
47. const r = await send('script.evaluate', { expression, target: { context }, awaitPromise: true, resultOwnership: 'none' });
48. if (r.type === 'exception') throw new Error('evaluate: ' + (r.exceptionDetails && r.exceptionDetails.text));
49. // primitives only (string, number, boolean, null): an expression that wants to hand back more returns JSON.stringify(…)
50. const v = r.result; return v && 'value' in v && typeof v.value !== 'object' ? v.value : null;
51. };
52. const waitFor = async (expression, { timeout = 15000, label = expression } = {}) => {
53. const end = Date.now() + timeout;
54. while (Date.now() < end) { try { const v = await evaluate(expression); if (v) return v; } catch {} await sleep(100); }
55. throw new Error('firefox waitFor timed out: ' + label);
56. };
57. return {
58. context, errors,
59. evaluate,
60. waitFor,
61. goto: (url) => send('browsingContext.navigate', { context, url, wait: 'complete' }),
62. setCookie: (name, value, domain) => send('storage.setCookie', { cookie: { name, value: { type: 'string', value }, domain, path: '/' } }),
63. async click(selector, { timeout = 15000 } = {}) {
64. const box = await waitFor(`(() => { const el = document.querySelector(${JSON.stringify(selector)}); if (!el) return null; el.scrollIntoView({ block: 'center' }); const b = el.getBoundingClientRect(); return b.width ? JSON.stringify({ x: Math.round(b.left + b.width / 2), y: Math.round(b.top + b.height / 2) }) : null; })()`, { timeout, label: 'click ' + selector });
65. const { x, y } = JSON.parse(box);
66. await send('input.performActions', { context, actions: [{ type: 'pointer', id: 'mouse', parameters: { pointerType: 'mouse' }, actions: [{ type: 'pointerMove', x, y }, { type: 'pointerDown', button: 0 }, { type: 'pointerUp', button: 0 }] }] });
67. },
68. async close() {
69. try { await send('session.end', {}); } catch {}
70. try { ws.close(); } catch {}
71. try { proc.kill('SIGTERM'); } catch {}
72. await new Promise(r => { if (proc.exitCode !== null || proc.signalCode !== null) return r(); proc.once('exit', r); setTimeout(() => { try { proc.kill('SIGKILL'); } catch {} r(); }, 4000); });
73. rmSync(profile, { recursive: true, force: true });
74. },
75. };
76. }