fix(server)!: JSON-encode tokens to retain characters such as newline…

…s properly
waylaidwanderer · Feb 27, 2023 · 46bdc57 · 46bdc57
1 parent af1b9e8
commit 46bdc57
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/bin/server.js b/bin/server.js
@@ -83,7 +83,7 @@ server.post('/conversation', async (request, reply) => {
                 console.debug(token);
             }
             if (token !== '[DONE]') {
-                reply.sse({ id: '', data: token });
+                reply.sse({ id: '', data: JSON.stringify(token) });
             }
         };
     } else {

diff --git a/demos/use-api-server-streaming.js b/demos/use-api-server-streaming.js
@@ -16,7 +16,7 @@ const opts = {
 try {
     let reply = '';
     const controller = new AbortController();
-    await fetchEventSource('http://localhost:3000/conversation', {
+    await fetchEventSource('http://localhost:3001/conversation', {
         ...opts,
         signal: controller.signal,
         onopen(response) {
@@ -40,12 +40,11 @@ try {
             }
             if (message.event === 'result') {
                 const result = JSON.parse(message.data);
-                const { response, conversationId } = result;
-                console.log({ response, conversationId });
+                console.log(result);
                 return;
             }
             console.log(message);
-            reply += message.data;
+            reply += JSON.parse(message.data);
         },
     });
     console.log(reply);