Update server/index.js

server/index.js

@@ -9,7 +9,7 @@ import fetch from 'node-fetch';
 import rateLimit from 'express-rate-limit';
 import fs from 'fs';
 import { registerFeedbackRoutes } from './handleFeedback.js';
-import { abortActiveStream, handleWsMessage } from './wsHandler.js';
+import { abortActiveStream, handleWsMessage, serializeSessionForClient } from './wsHandler.js';
 import { sessionStore, initStoreConfig } from './sessionStore.js';
 import { SUPABASE_URL, SUPABASE_ANON_KEY } from './config.js';
 import { safeSend } from './helpers.js';
@@ -411,12 +411,12 @@ app.get('/api/db/chats', async (req, res) => {
         })),
       });
     }
-    const items = [];
-    for (const listedSession of listed) {
-      const full = await sessionStore.getUserSessionResolved(resolved.user.id, listedSession.id);
-      if (full) items.push(full);
-    }
-    res.json({ items });
+      const items = [];
+      for (const listedSession of listed) {
+        const full = await sessionStore.getUserSessionResolved(resolved.user.id, listedSession.id);
+        if (full) items.push(serializeSessionForClient(full));
+      }
+      res.json({ items });
   } catch (err) {
     console.error('db chats list error', err);
     res.status(500).json({ error: 'db:chats_list_failed' });
@@ -436,7 +436,7 @@ app.post('/api/db/chats', async (req, res) => {
     if (Object.keys(patch).length) {
       created = await sessionStore.updateUserSession(resolved.user.id, resolved.accessToken, created.id, patch);
     }
-    res.status(201).json({ item: created });
+    res.status(201).json({ item: serializeSessionForClient(created) });
   } catch (err) {
     console.error('db chat create error', err);
     res.status(500).json({ error: 'db:chat_create_failed' });
@@ -449,7 +449,7 @@ app.get('/api/db/chats/:sessionId', async (req, res) => {
   try {
     const session = await sessionStore.getUserSessionResolved(resolved.user.id, req.params.sessionId);
     if (!session) return res.status(404).json({ error: 'db:chat_not_found' });
-    res.json({ item: session });
+    res.json({ item: serializeSessionForClient(session) });
   } catch (err) {
     console.error('db chat get error', err);
     res.status(500).json({ error: 'db:chat_get_failed' });
@@ -473,7 +473,7 @@ app.patch('/api/db/chats/:sessionId', async (req, res) => {
       patch
     );
     if (!updated) return res.status(404).json({ error: 'db:chat_not_found' });
-    res.json({ item: updated });
+    res.json({ item: serializeSessionForClient(updated) });
   } catch (err) {
     console.error('db chat patch error', err);
     res.status(500).json({ error: 'db:chat_update_failed' });
@@ -726,7 +726,7 @@ app.get('/api/db/export', async (req, res) => {
     const chats = [];
     for (const listedSession of listed) {
       const full = await sessionStore.getUserSessionResolved(resolved.user.id, listedSession.id);
-      if (full) chats.push(full);
+      if (full) chats.push(serializeSessionForClient(full));
     }
 
     const mediaResult = await mediaStore.listAll(resolved.owner, { view: 'all' });