(conversationId, event, data = {})
| 284 | |
| 285 | // Emit progress events for AI orchestration |
| 286 | emitProgress(conversationId, event, data = {}) { |
| 287 | if (!this.io) return; // Skip if not initialized |
| 288 | const room = `conversation:${conversationId}`; |
| 289 | this.io.to(room).emit("ai-progress", { |
| 290 | event, |
| 291 | data, |
| 292 | timestamp: new Date().toISOString() |
| 293 | }); |
| 294 | } |
| 295 | |
| 296 | // Emit to specific user |
| 297 | emitToUser(userId, event, data = {}) { |
no outgoing calls
no test coverage detected