support logs

Author: nanehambardzumyan

.gitignore

@@ -1,3 +1,4 @@
 node_modules
 dist
 module
+logs

client/pulse-chat.js

@@ -219,6 +219,7 @@ async function sendMessage(text) {
     _context.emit('chat:message-sent', {
       conversationId: conv.id,
       contactName: conv.name,
+      sender: 'user',
       text: text.trim()
     });
   }
@@ -252,6 +253,7 @@ async function sendMessage(text) {
       _context.emit('chat:message-received', {
         conversationId: conv.id,
         contactName: conv.name,
+        sender: conv.name,
         text: data.response
       });
     }

client/standalone.js

@@ -1,7 +1,34 @@
 import { init } from './pulse-chat.js';
 
+const SIM_ID = 'pulse-chat';
+const logBuffer = [];
+let flushTimer = null;
+
+function flushLogs() {
+  const entries = logBuffer.splice(0);
+  flushTimer = null;
+  if (entries.length === 0) return;
+  fetch('/api/log', {
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json' },
+    body: JSON.stringify({ entries })
+  }).catch(err => console.error('Failed to flush logs:', err));
+}
+
+function pushLog(entry) {
+  logBuffer.push({ ...entry, ts: new Date().toISOString() });
+  if (!flushTimer) flushTimer = setTimeout(flushLogs, 1000);
+}
+
+const context = {
+  config: { id: SIM_ID, basePath: '' },
+  emit: (eventType, payload = {}) => {
+    pushLog({ simId: SIM_ID, dir: 'event', type: eventType, payload });
+  }
+};
+
 if (document.readyState === 'loading') {
-  document.addEventListener('DOMContentLoaded', () => init({}));
+  document.addEventListener('DOMContentLoaded', () => init(context));
 } else {
-  init({});
+  init(context);
 }

server.js

@@ -26,6 +26,10 @@ const OPENAI_BASE_URL = (process.env.OPENAI_BASE_URL || 'https://api.openai.com/
 
 const wsClients = new Set();
 
+const LOG_DIR = path.join(__dirname, 'logs');
+const LOG_FILE = path.join(LOG_DIR, 'events.jsonl');
+if (!fs.existsSync(LOG_DIR)) fs.mkdirSync(LOG_DIR, { recursive: true });
+
 const mimeTypes = {
   '.html': 'text/html', '.js': 'text/javascript', '.css': 'text/css',
   '.json': 'application/json', '.png': 'image/png', '.jpg': 'image/jpeg',
@@ -137,7 +141,33 @@ function generateFallbackResponse(persona) {
   return responses[Math.floor(Math.random() * responses.length)];
 }
 
+async function handleLogRequest(req, res) {
+  try {
+    const data = await readBody(req);
+    const entries = data.entries;
+    if (!Array.isArray(entries) || entries.length === 0) {
+      res.writeHead(400, { 'Content-Type': 'application/json' });
+      res.end(JSON.stringify({ error: 'entries array is required' }));
+      return;
+    }
+    const lines = entries.map(e => JSON.stringify(e)).join('\n') + '\n';
+    fs.appendFile(LOG_FILE, lines, (err) => {
+      if (err) console.error('Failed to write log:', err);
+    });
+    res.writeHead(200, { 'Content-Type': 'application/json' });
+    res.end(JSON.stringify({ ok: true, count: entries.length }));
+  } catch (error) {
+    res.writeHead(400, { 'Content-Type': 'application/json' });
+    res.end(JSON.stringify({ error: 'Invalid JSON' }));
+  }
+}
+
 function handlePostRequest(req, res, parsedUrl) {
+  if (parsedUrl.pathname === '/api/log') {
+    handleLogRequest(req, res);
+    return;
+  }
+
   if (parsedUrl.pathname === '/api/chat') {
     handleChatRequest(req, res);
     return;