From c78f48946a37a79b15f76ec0446fd2d24c92a803 Mon Sep 17 00:00:00 2001
From: Rocko <rocko@mosaicstack.dev>
Date: Wed, 21 Oct 2026 19:20:25 -0500
Subject: [PATCH] test: use private tester socket for processing controls

---
 packages/webui/tests/processing.test.mjs | 19 ++++++++++++++-----
 1 file changed, 14 insertions(+), 5 deletions(-)

diff --git a/packages/webui/tests/processing.test.mjs b/packages/webui/tests/processing.test.mjs
index 62e0e4295..e9874602c 100644
--- a/packages/webui/tests/processing.test.mjs
+++ b/packages/webui/tests/processing.test.mjs
@@ -1,12 +1,17 @@
 import test from 'node:test';
 import assert from 'node:assert/strict';
 import { request } from 'node:http';
+import { mkdtempSync, rmSync } from 'node:fs';
+import { join } from 'node:path';
+import { tmpdir } from 'node:os';
+import { startTesterSocket, TESTER_ORIGIN } from '../src/tester-socket.mjs';
 import { startServer } from '../src/serve.mjs';
 import { close } from './fixture.mjs';
 const GEN = '12345678-1234-4234-8234-123456789abc';
 function http(server, path, { method = 'GET', headers = {}, body = '' } = {}) {
   return new Promise((resolve, reject) => {
-    const req = request({ host: '127.0.0.1', port: server.address().port, path, method,
+    const address = server.address();
+    const req = request({ ...(typeof address === 'string' ? { socketPath: address } : { host: '127.0.0.1', port: address.port }), path, method,
       headers: Object.fromEntries(Object.entries({ host: 'console.example', 'x-user': 'jason', ...headers }).filter(([, v]) => v !== undefined)) }, res => {
       let text = ''; res.on('data', c => { text += c; }); res.on('end', () => resolve({ status: res.statusCode, text, value: JSON.parse(text) }));
     }); req.on('error', reject); req.end(body);
@@ -21,9 +26,13 @@ async function fixture(t, { send = true, tester = false } = {}) {
     halt: async args => { calls.push(['halt', args]); state.halted = true; return { ...state }; },
     resume: async args => { calls.push(['resume', args]); state.halted = false; return { ...state }; },
   };
-  const server = await startServer({ port: 0, ...(tester ? { tester: true } : { preview: { host: 'console.example', header: 'x-user', user: 'jason' } }),
-    send: send && !tester ? async () => {} : null, processing, log: () => {} });
-  t.after(() => close(server)); return { server, calls, state, processing };
+  const root = tester ? mkdtempSync(join(tmpdir(), 'processing-web-')) : null;
+  const options = { processing, log: () => {} };
+  const server = tester ? await startTesterSocket({ dataRoot: root, ...options }) : await startServer({ port: 0,
+    preview: { host: 'console.example', header: 'x-user', user: 'jason' },
+    send: send ? async () => {} : null, ...options });
+  t.after(async () => { await close(server); if (root) rmSync(root, { recursive: true, force: true }); });
+  return { server, calls, state, processing };
 }
 test('read-only Console can read processing state but neither human control writes without --send', async t => {
   const f = await fixture(t, { send: false });
@@ -56,7 +65,7 @@ test('processing write fences refuse cross-site, wrong origin, unnamed host, dup
 });
 test('tester cannot invoke either control writer and failures never echo backend text', async t => {
   const f = await fixture(t, { tester: true });
-  const headers = { host: `127.0.0.1:${f.server.address().port}` };
+  const headers = { host: new URL(TESTER_ORIGIN).host, origin: TESTER_ORIGIN, 'x-user': undefined };
   for (const action of ['halt', 'resume']) assert.equal((await http(f.server, '/api/processing/' + action, { ...POST, headers: { ...POST.headers, ...headers } })).status, 403);
   assert.deepEqual(f.calls, []);
   const human = await fixture(t); human.processing.halt = async () => { throw Object.assign(Error('NEVER ECHO fixture path'), { code: 'outcome-unknown' }); };