Add safe Training Room job execution

app.js

@@ -281,6 +281,16 @@ async function startTool(kind, id, label) {
   }
 }
 
+async function trainingRequest(action, payload = {}) {
+  try {
+    const response = await fetch(`http://127.0.0.1:4777/api/training/${action}`, { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(payload) });
+    const result = await response.json();
+    if (!response.ok) throw new Error(result.error || 'Training Room request failed');
+    $('#training-status').textContent = result.status === 'running' ? `Running: ${result.id}` : `Training Room: ${result.status}`;
+    appendLog('TRAINING', JSON.stringify(result));
+  } catch (error) { $('#training-status').textContent = `Blocked: ${error.message}`; appendLog('TRAINING', error.message, 'warning'); }
+}
+
 async function digestFile(file) {
   const buffer = await file.arrayBuffer();
   const digest = await crypto.subtle.digest('SHA-256', buffer);
@@ -345,6 +355,8 @@ async function boot() {
   $('#community-add').onclick = addCommunityIssue;
   $('#lsp-button').onclick = () => startTool('lsp', 'typescript', 'TypeScript LSP');
   $('#dap-button').onclick = () => startTool('dap', 'python-debugpy', 'Python DAP');
+  $('#training-verify').onclick = () => trainingRequest('start', { id: 'verify-release', approved: true });
+  $('#training-stop').onclick = () => trainingRequest('stop');
   loadCommunity();
   $('#input').onkeydown = event => { if (event.key === 'Enter') sendChat(); };
 }

daemon/server.mjs

@@ -7,6 +7,7 @@ import { CommunityStore } from '../community/store.mjs';
 import { LspManager } from './lsp-manager.mjs';
 import { DapManager } from './dap-manager.mjs';
 import { WorkspaceManager } from './workspace-manager.mjs';
+import { TrainingManager } from './training-manager.mjs';
 
 const HOST = '127.0.0.1';
 const PORT = Number(process.env.AIDE_DAEMON_PORT || 4777);
@@ -22,6 +23,8 @@ await lspManager.load().catch(() => {});
 const dapManager = new DapManager({ manifestPath: path.join(WORKSPACE, 'debuggers', 'manifest.json'), workspace: WORKSPACE });
 await dapManager.load().catch(() => {});
 const workspaceManager = new WorkspaceManager(WORKSPACE);
+const trainingManager = new TrainingManager({ manifestPath: path.join(WORKSPACE, 'training', 'manifest.json'), workspace: WORKSPACE });
+await trainingManager.load().catch(() => {});
 
 function json(response, status, body) {
   const payload = JSON.stringify(body);
@@ -101,6 +104,16 @@ const server = http.createServer(async (request, response) => {
     if (request.method === 'GET' && request.url === '/api/dap/status') {
       return json(response, 200, { adapters: dapManager.status() });
     }
+    if (request.method === 'GET' && request.url === '/api/training/status') {
+      return json(response, 200, trainingManager.status());
+    }
+    if (request.method === 'POST' && request.url === '/api/training/start') {
+      const input = await body(request);
+      return json(response, 200, trainingManager.start(input.id, input.approved));
+    }
+    if (request.method === 'POST' && request.url === '/api/training/stop') {
+      return json(response, 200, trainingManager.stop());
+    }
     if (request.method === 'POST' && request.url === '/api/dap/start') {
       return json(response, 200, await dapManager.start((await body(request)).id));
     }

daemon/test-training-manager.mjs

@@ -0,0 +1,15 @@
+import assert from 'node:assert/strict';
+import { mkdtemp, writeFile } from 'node:fs/promises';
+import { tmpdir } from 'node:os';
+import path from 'node:path';
+import { TrainingManager } from './training-manager.mjs';
+
+const root = await mkdtemp(path.join(tmpdir(), 'aide-training-'));
+await writeFile(path.join(root, 'manifest.json'), JSON.stringify({ jobs: [{ id: 'safe', name: 'Safe', command: 'node', args: ['--version'] }] }));
+const manager = new TrainingManager({ manifestPath: path.join(root, 'manifest.json'), workspace: root, spawnProcess: () => ({ stdout: { on() {} }, stderr: { on() {} }, once() {}, kill() {} }) });
+await manager.load();
+await assert.rejects(Promise.resolve().then(() => manager.start('safe', false)), /approval/);
+assert.deepEqual(manager.start('safe', true), { id: 'safe', status: 'running' });
+await assert.rejects(Promise.resolve().then(() => manager.start('safe', true)), /already running/);
+assert.deepEqual(manager.stop(), { status: 'stopped' });
+console.log('training manager test passed');

daemon/training-manager.mjs

@@ -0,0 +1,45 @@
+import { promises as fs } from 'node:fs';
+import { spawn } from 'node:child_process';
+
+export class TrainingManager {
+  constructor({ manifestPath, workspace, spawnProcess = spawn } = {}) {
+    this.manifestPath = manifestPath;
+    this.workspace = workspace;
+    this.spawnProcess = spawnProcess;
+    this.jobs = new Map();
+    this.active = null;
+    this.logs = [];
+  }
+
+  async load() {
+    const manifest = JSON.parse(await fs.readFile(this.manifestPath, 'utf8'));
+    this.jobs = new Map(manifest.jobs.map(job => [job.id, job]));
+    return manifest;
+  }
+
+  status() {
+    return { active: this.active ? { id: this.active.id, status: this.active.status } : null, logs: this.logs.slice(-100), jobs: [...this.jobs.values()] };
+  }
+
+  start(id, approved) {
+    if (approved !== true) throw new Error('explicit training approval required');
+    if (this.active) throw new Error('another Training Room job is already running');
+    const job = this.jobs.get(id);
+    if (!job) throw new Error('training job is not allowlisted');
+    const child = this.spawnProcess(job.command, job.args, { cwd: this.workspace, stdio: ['ignore', 'pipe', 'pipe'] });
+    this.active = { id, status: 'running', child };
+    const record = line => { this.logs.push({ id, line: String(line).trimEnd(), at: new Date().toISOString() }); };
+    child.stdout?.on('data', data => String(data).split('\n').filter(Boolean).forEach(record));
+    child.stderr?.on('data', data => String(data).split('\n').filter(Boolean).forEach(line => record(`stderr: ${line}`)));
+    child.once('exit', code => { record(`job exited with code ${code}`); this.active = null; });
+    return { id, status: 'running' };
+  }
+
+  stop() {
+    if (!this.active) return { status: 'idle' };
+    this.active.child.kill('SIGTERM');
+    this.logs.push({ id: this.active.id, line: 'job cancelled by user', at: new Date().toISOString() });
+    this.active = null;
+    return { status: 'stopped' };
+  }
+}

index.html

@@ -70,6 +70,10 @@
       <button id="lsp-button" class="secondary" style="width:100%;padding:6px">START TYPESCRIPT LSP</button>
       <button id="dap-button" class="secondary" style="width:100%;margin-top:5px;padding:6px">START PYTHON DAP</button>
       <div id="tool-status" style="color:#718994;font:9px/1.6 ui-monospace,monospace;margin-top:6px">LSP/DAP status unknown.</div>
+      <div class="section-heading divider">TRAINING ROOM</div>
+      <button id="training-verify" class="secondary" style="width:100%;padding:6px">RUN VERITAS JOB</button>
+      <button id="training-stop" class="secondary" style="width:100%;margin-top:5px;padding:6px">STOP TRAINING JOB</button>
+      <div id="training-status" style="color:#718994;font:9px/1.6 ui-monospace,monospace;margin-top:6px">Training Room idle.</div>
     </aside>
 
     <section class="editor-column">

package.json

@@ -5,7 +5,7 @@
   "description": "Local-first sovereign development workbench",
   "type": "module",
   "scripts": {
-    "test": "node tests/smoke.mjs && node harness/test-orchestrator.mjs && node daemon/test-model-manager.mjs && node daemon/test-community-store.mjs && node daemon/test-lsp-manager.mjs && node daemon/test-dap-manager.mjs && node daemon/test-workspace-manager.mjs && node benchmarks/test-run.mjs && node capsules/test-create.mjs",
+    "test": "node tests/smoke.mjs && node harness/test-orchestrator.mjs && node daemon/test-model-manager.mjs && node daemon/test-community-store.mjs && node daemon/test-lsp-manager.mjs && node daemon/test-dap-manager.mjs && node daemon/test-workspace-manager.mjs && node daemon/test-training-manager.mjs && node benchmarks/test-run.mjs && node capsules/test-create.mjs",
     "check": "node --check app.js && node --check daemon/server.mjs && node --check harness/orchestrator.mjs && node --check harness/checks.mjs",
     "veritas": "node harness/run-veritas.mjs",
     "benchmarks": "node benchmarks/run.mjs",