chore: cleanup comments, expand examples

Author: goosewin

fern/chat/non-streaming.mdx

@@ -216,7 +216,7 @@ We'll build a help desk system for "TechFlow" that processes support messages th
         });
 
         const chat = await response.json();
-        lastChatId = chat.id; // Save for next message
+        lastChatId = chat.id;
         return chat.output[0].content;
       }
 
@@ -295,7 +295,6 @@ We'll build a help desk system for "TechFlow" that processes support messages th
       };
     }
 
-    // Create specialized handlers
     const technicalSupport = await createSpecializedChat(
       "You are a technical support specialist. Ask clarifying questions and provide step-by-step troubleshooting."
     );

fern/chat/openai-compatibility.mdx

@@ -225,18 +225,39 @@ We'll migrate "TechFlow's" existing OpenAI-powered customer support chat to use
 
       let fullResponse = '';
 
-      for await (const event of stream) {
-        if (event.type === 'response.output_text.delta') {
-          process.stdout.write(event.delta);
-          fullResponse += event.delta;
+      const reader = stream.body?.getReader();
+      if (!reader) return fullResponse;
+      
+      const decoder = new TextDecoder();
+
+      while (true) {
+        const { done, value } = await reader.read();
+        if (done) break;
+
+        const chunk = decoder.decode(value);
+        
+        // Parse and process SSE events
+        const lines = chunk.split('\n').filter(line => line.trim());
+        for (const line of lines) {
+          if (line.startsWith('data: ')) {
+            try {
+              const event = JSON.parse(line.slice(6));
+              if (event.path && event.delta) {
+                process.stdout.write(event.delta);
+                fullResponse += event.delta;
+              }
+            } catch (e) {
+              console.error('Invalid JSON line:', line);
+              continue;
+            }
+          }
         }
       }
 
       console.log('\n\nComplete response received.');
       return fullResponse;
     }
 
-    // Test streaming
     streamWithVapi('Write a detailed explanation of REST APIs');
     ```
   </Step>
@@ -267,7 +288,7 @@ We'll migrate "TechFlow's" existing OpenAI-powered customer support chat to use
           return response.output[0].content[0].text;
         }
 
-        return response; // Return stream for streaming requests
+        return response;
       }
 
       return { sendMessage };
@@ -391,8 +412,22 @@ We'll migrate "TechFlow's" existing OpenAI-powered customer support chat to use
         if (done) break;
 
         const chunk = decoder.decode(value);
-        // Process SSE events here...
-        console.log(chunk);
+        
+        // Parse and process SSE events
+        const lines = chunk.split('\n').filter(line => line.trim());
+        for (const line of lines) {
+          if (line.startsWith('data: ')) {
+            try {
+              const event = JSON.parse(line.slice(6));
+              if (event.path && event.delta) {
+                process.stdout.write(event.delta);
+              }
+            } catch (e) {
+              console.error('Invalid JSON line:', line);
+              continue;
+            }
+          }
+        }
       }
     }
 
@@ -440,8 +475,27 @@ We'll migrate "TechFlow's" existing OpenAI-powered customer support chat to use
 
       if (stream) {
         res.setHeader('Content-Type', 'text/event-stream');
+        res.setHeader('Cache-Control', 'no-cache');
+        res.setHeader('Connection', 'keep-alive');
+        
         const reader = response.body?.getReader();
-        // Handle streaming response...
+        if (!reader) {
+          return res.status(500).json({ error: 'Failed to get stream reader' });
+        }
+        
+        const decoder = new TextDecoder();
+        
+        while (true) {
+          const { done, value } = await reader.read();
+          if (done) {
+            res.write('data: [DONE]\n\n');
+            res.end();
+            break;
+          }
+          
+          const chunk = decoder.decode(value);
+          res.write(chunk);
+        }
       } else {
         const chat = await response.json();
         const openaiResponse = {

fern/chat/streaming.mdx

@@ -106,7 +106,7 @@ We'll enhance the TechFlow support chat from the quickstart to provide real-time
             const data = JSON.parse(line.slice(6));
             if (data.path && data.delta) {
               fullResponse += data.delta;
-              process.stdout.write(data.delta); // Print each token
+              process.stdout.write(data.delta);
             }
           }
         }
@@ -158,6 +158,7 @@ We'll enhance the TechFlow support chat from the quickstart to provide real-time
 
         const decoder = new TextDecoder();
         let fullContent = '';
+        let currentChatId: string | undefined;
 
         while (true) {
           const { done, value } = await reader.read();
@@ -169,6 +170,11 @@ We'll enhance the TechFlow support chat from the quickstart to provide real-time
           for (const line of lines) {
             if (line.startsWith('data: ')) {
               const event = JSON.parse(line.slice(6));
+              
+              if (event.id && !currentChatId) {
+                currentChatId = event.id;
+              }
+              
               if (event.path && event.delta) {
                 fullContent += event.delta;
                 process.stdout.write(event.delta);
@@ -177,10 +183,8 @@ We'll enhance the TechFlow support chat from the quickstart to provide real-time
           }
         }
 
-        // Extract chatId from first message for context
-        if (!lastChatId) {
-          // You'd get this from a non-streaming call or API response
-          // For simplicity, we'll assume you track it separately
+        if (currentChatId) {
+          lastChatId = currentChatId;
         }
 
         return fullContent;