Add draggable toast with nerd mode live log viewer

JobStatusToast is now draggable via react-rnd and includes a terminal
icon (>_) that toggles an expandable log panel. During execution, the
panel shows a live tail of FireSTARR stdout/stderr via SSE. After
completion, the full log is scrollable and searchable. Dismissing the
toast clears the log.

Backend: JobLogEmitter singleton bridges FireSTARREngine.onOutput to
SSE subscribers. The /jobs/:id/stream route replays buffered lines on
connect and streams new lines as event:log SSE events.

Author: spydmobile

backend/src/api/routes/v1/jobs.ts

@@ -2,6 +2,7 @@ import { Router } from 'express';
 import { asyncHandler } from '../../middleware/index.js';
 import { createJobId } from '../../../domain/entities/index.js';
 import { getJobQueue } from '../../../infrastructure/services/index.js';
+import { getJobLogEmitter } from '../../../infrastructure/services/JobLogEmitter.js';
 
 const router = Router();
 
@@ -57,8 +58,29 @@ router.get(
 
     sendStatus(initialResult.value);
 
+    // Subscribe to log lines for this model
+    const logEmitter = getJobLogEmitter();
+    const modelId = initialResult.value.modelId;
+
+    const sendLogLine = (line: string) => {
+      try {
+        res.write(`event: log\ndata: ${JSON.stringify({ line })}\n\n`);
+      } catch {
+        // Connection may be closed
+      }
+    };
+
+    // Replay buffered log lines (for late-connecting clients)
+    for (const line of logEmitter.getBuffer(modelId)) {
+      sendLogLine(line);
+    }
+
+    // Subscribe to new log lines
+    const unsubscribeLogs = logEmitter.subscribe(modelId, sendLogLine);
+
     // If job is already terminal, close connection
     if (initialResult.value.isTerminal()) {
+      unsubscribeLogs();
       res.write('event: complete\ndata: {}\n\n');
       res.end();
       return;
@@ -69,6 +91,7 @@ router.get(
       const result = await jobQueue.getJob(jobId);
       if (!result.success) {
         clearInterval(pollInterval);
+        unsubscribeLogs();
         res.write(`event: error\ndata: ${JSON.stringify({ error: 'Job not found' })}\n\n`);
         res.end();
         return;
@@ -80,6 +103,7 @@ router.get(
       // Check if job is terminal
       if (job.isTerminal()) {
         clearInterval(pollInterval);
+        unsubscribeLogs();
         res.write('event: complete\ndata: {}\n\n');
         res.end();
       }
@@ -88,6 +112,7 @@ router.get(
     // Clean up on client disconnect
     req.on('close', () => {
       clearInterval(pollInterval);
+      unsubscribeLogs();
     });
   })
 );

backend/src/infrastructure/firestarr/FireSTARREngine.ts

@@ -14,6 +14,7 @@ import {
   EngineCapabilities,
 } from '../../application/interfaces/IFireModelingEngine.js';
 import { IContainerExecutor, OutputCallback } from '../../application/interfaces/IContainerExecutor.js';
+import { getJobLogEmitter } from '../services/JobLogEmitter.js';
 import { IInputGenerator, InputGenerationResult } from '../../application/interfaces/IInputGenerator.js';
 import { IOutputParser, ParsedOutput } from '../../application/interfaces/IOutputParser.js';
 import {
@@ -190,6 +191,9 @@ export class FireSTARREngine implements IFireModelingEngine {
       } else {
         logger.info(line, 'FireSTARR:output');
       }
+
+      // Emit to SSE subscribers for live log streaming
+      getJobLogEmitter().emit(modelId, line);
     };
 
     // Build environment variables for native binary execution

backend/src/infrastructure/services/JobLogEmitter.ts

@@ -0,0 +1,83 @@
+/**
+ * JobLogEmitter — in-process pub/sub bridge for FireSTARR log lines.
+ *
+ * FireSTARREngine pushes stdout/stderr lines via emit().
+ * SSE routes subscribe per connection to stream lines to the browser.
+ * Buffers all lines per model for replay when a new SSE client connects.
+ */
+
+type LogSubscriber = (line: string) => void;
+
+class JobLogEmitter {
+  private subscribers = new Map<string, Set<LogSubscriber>>();
+  private buffers = new Map<string, string[]>();
+
+  /**
+   * Emit a log line for a model. Buffers it and notifies all subscribers.
+   */
+  emit(modelId: string, line: string): void {
+    // Buffer
+    let buffer = this.buffers.get(modelId);
+    if (!buffer) {
+      buffer = [];
+      this.buffers.set(modelId, buffer);
+    }
+    buffer.push(line);
+
+    // Notify subscribers
+    const subs = this.subscribers.get(modelId);
+    if (subs) {
+      for (const callback of subs) {
+        try {
+          callback(line);
+        } catch {
+          // Don't let a broken subscriber crash the engine
+        }
+      }
+    }
+  }
+
+  /**
+   * Subscribe to log lines for a model. Returns an unsubscribe function.
+   */
+  subscribe(modelId: string, callback: LogSubscriber): () => void {
+    let subs = this.subscribers.get(modelId);
+    if (!subs) {
+      subs = new Set();
+      this.subscribers.set(modelId, subs);
+    }
+    subs.add(callback);
+
+    return () => {
+      subs!.delete(callback);
+      if (subs!.size === 0) {
+        this.subscribers.delete(modelId);
+      }
+    };
+  }
+
+  /**
+   * Get all buffered log lines for a model (for replay on SSE connect).
+   */
+  getBuffer(modelId: string): string[] {
+    return this.buffers.get(modelId) ?? [];
+  }
+
+  /**
+   * Clean up buffer and subscribers for a model.
+   * Call after all SSE connections have closed.
+   */
+  cleanup(modelId: string): void {
+    this.buffers.delete(modelId);
+    this.subscribers.delete(modelId);
+  }
+}
+
+// Singleton
+const jobLogEmitter = new JobLogEmitter();
+
+export function getJobLogEmitter(): JobLogEmitter {
+  return jobLogEmitter;
+}
+
+export { JobLogEmitter };

frontend/src/App.tsx

@@ -126,6 +126,7 @@ function AppContent() {
   // Job notifications
   const {
     status: jobStatus,
+    logLines,
     watchJob,
     stopWatching,
     requestPermission,
@@ -481,6 +482,7 @@ function AppContent() {
       {/* Job status toast */}
       <JobStatusToast
         status={jobStatus}
+        logLines={logLines}
         onDismiss={handleDismissToast}
         onViewResults={handleViewResults}
       />