address reviewer feedback

Author: Eric Oliver

src/api/streaming/SSEOutputAdapter.ts

@@ -301,7 +301,7 @@ export class SSEOutputAdapter implements IUserInterface {
 		if (!success) {
 			this.logger.warn(`Failed to emit event ${event.type} for job ${this.jobId}`)
 			console.log(`[SSE] Failed to send event ${event.type} for job ${this.jobId}`)
-			console.log(`[SSE] Available streams:`, Object.keys((this.streamManager as any).streams || {}))
+			console.log(`[SSE] Available streams:`, this.streamManager.getActiveStreamIds())
 		} else {
 			console.log(`[SSE] Successfully sent event ${event.type} for job ${this.jobId}`)
 		}

src/api/streaming/__tests__/SSEOutputAdapter.test.ts

@@ -300,4 +300,27 @@ describe("SSEOutputAdapter", () => {
 			expect(new Date(event.timestamp)).toBeInstanceOf(Date)
 		})
 	})
+
+	describe("error handling", () => {
+		it("should handle stream failure gracefully", async () => {
+			// Close the stream to simulate failure
+			streamManager.closeStream(jobId)
+
+			// Spy on console.log to verify error logging
+			const consoleSpy = jest.spyOn(console, "log").mockImplementation(() => {})
+
+			await adapter.showInformation("Test message")
+
+			// Verify that error logging uses public API
+			expect(consoleSpy).toHaveBeenCalledWith(
+				expect.stringContaining("[SSE] Failed to send event information for job test-job-123"),
+			)
+			expect(consoleSpy).toHaveBeenCalledWith(
+				expect.stringContaining("[SSE] Available streams:"),
+				expect.any(Array),
+			)
+
+			consoleSpy.mockRestore()
+		})
+	})
 })

src/shared/paths.ts

@@ -4,21 +4,22 @@
  */
 
 import * as os from "os"
+import * as path from "path"
 
 /**
  * Get the global storage path for the application
  * Uses .agentz directory for consistency with CLI config
  */
 export function getGlobalStoragePath(): string {
 	const homeDir = os.homedir()
-	return `${homeDir}/.agentz`
+	return path.join(homeDir, ".agentz")
 }
 
 /**
  * Get the fallback storage path for environments without home directory
  */
 export function getFallbackStoragePath(): string {
-	return "/tmp/.agentz"
+	return path.join("/tmp", ".agentz")
 }
 
 /**