From 1d6791cc3cceb32c03003296ccb09ed40d659615 Mon Sep 17 00:00:00 2001
From: Niek van der Maas <mail@niekvandermaas.nl>
Date: Wed, 22 Mar 2023 10:29:27 +0100
Subject: [PATCH] Work on the SSE

---
 src/lib/Chat.svelte | 44 ++++++++++++++++++++++++--------------------
 1 file changed, 24 insertions(+), 20 deletions(-)

diff --git a/src/lib/Chat.svelte b/src/lib/Chat.svelte
index 27dad4d..c3d3bb0 100644
--- a/src/lib/Chat.svelte
+++ b/src/lib/Chat.svelte
@@ -1,5 +1,5 @@
 <script lang="ts">
-  // import { fetchEventSource } from "@microsoft/fetch-event-source";
+  // import { fetchEventSource } from '@microsoft/fetch-event-source'
 
   import { apiKeyStorage, chatsStorage, addMessage, clearMessages } from './Storage.svelte'
   import {
@@ -173,26 +173,8 @@
     mangle: false // Do not mangle email addresses
   }
 
+  // Send API request
   const sendRequest = async (messages: Message[]): Promise<Response> => {
-    // Send API request
-    /*
-    // Not working yet: a way to get the response as a stream
-    await fetchEventSource(apiBase + "/v1/chat/completions", {
-      method: "POST",
-      headers: {
-        Authorization:
-          `Bearer ${$apiKeyStorage}`,
-        "Content-Type": "text/event-stream",
-      },
-      body: JSON.stringify(request),
-      onmessage(ev) {
-        console.log(ev);
-      },
-      onerror(err) {
-        throw err;
-      },
-    });
-    */
     // Show updating bar
     updating = true
 
@@ -217,6 +199,28 @@
           return acc
         }, {})
       }
+
+      // Not working yet: a way to get the response as a stream
+      /*
+      request.stream = true
+      await fetchEventSource(apiBase + '/v1/chat/completions', {
+        method: 'POST',
+        headers: {
+          Authorization:
+          `Bearer ${$apiKeyStorage}`,
+          'Content-Type': 'application/json'
+        },
+        body: JSON.stringify(request),
+        onmessage (ev) {
+          const data = JSON.parse(ev.data)
+          console.log(data)
+        },
+        onerror (err) {
+          throw err
+        }
+      })
+      */
+
       response = await (
         await fetch(apiBase + '/v1/chat/completions', {
           method: 'POST',