test: update charStream tests to support chunks

mwbrooks · mwbrooks · commit fc5ed1ab6bd9 · 2026-01-23T17:23:39.000-08:00
diff --git a/packages/web-api/src/WebClient.spec.ts b/packages/web-api/src/WebClient.spec.ts
@@ -1228,7 +1228,11 @@ describe('WebClient', () => {
           ok: true,
           ts: '123.123',
         })
-        .post('/api/chat.stopStream', { channel: 'C0123456789', ts: '123.123', markdown_text: 'nice!' })
+        .post('/api/chat.stopStream', {
+          channel: 'C0123456789',
+          ts: '123.123',
+          chunks: JSON.stringify([{ type: 'markdown_text', text: 'nice!' }]),
+        })
         .reply(200, {
           ok: true,
         });
@@ -1279,7 +1283,7 @@ describe('WebClient', () => {
       const scope = nock('https://slack.com')
         .post('/api/chat.startStream', {
           channel: 'C0123456789',
-          markdown_text: '**this messag',
+          chunks: JSON.stringify([{ type: 'markdown_text', text: '**this messag' }]),
           recipient_team_id: 'T0123456789',
           recipient_user_id: 'U0123456789',
           thread_ts: '123.000',
@@ -1290,7 +1294,7 @@ describe('WebClient', () => {
         })
         .post('/api/chat.appendStream', {
           channel: 'C0123456789',
-          markdown_text: 'e is bold!',
+          chunks: JSON.stringify([{ type: 'markdown_text', text: 'e is bold!' }]),
           token: 'xoxb-updated-1',
           ts: '123.123',
         })
@@ -1300,7 +1304,7 @@ describe('WebClient', () => {
         .post('/api/chat.stopStream', {
           blocks: JSON.stringify([contextActionsBlock]),
           channel: 'C0123456789',
-          markdown_text: '**',
+          chunks: JSON.stringify([{ type: 'markdown_text', text: '**' }]),
           token: 'xoxb-updated-2',
           ts: '123.123',
         })
@@ -1370,7 +1374,11 @@ describe('WebClient', () => {
           ok: true,
           ts: '123.123',
         })
-        .post('/api/chat.stopStream', { channel: 'C0123456789', ts: '123.123', markdown_text: 'nice!' })
+        .post('/api/chat.stopStream', {
+          channel: 'C0123456789',
+          ts: '123.123',
+          chunks: JSON.stringify([{ type: 'markdown_text', text: 'nice!' }]),
+        })
         .reply(200, {
           ok: true,
         });
diff --git a/packages/web-api/src/chat-stream.ts b/packages/web-api/src/chat-stream.ts
@@ -92,6 +92,7 @@ export class ChatStreamer {
     }
     if (args?.markdown_text) {
       this.buffer += args.markdown_text;
+      args.markdown_text = undefined;
     }
     if (this.buffer.length >= this.options.buffer_size || args?.chunks) {
       return await this.flushBuffer(args);
@@ -135,6 +136,7 @@ export class ChatStreamer {
     }
     if (args?.markdown_text) {
       this.buffer += args.markdown_text;
+      args.markdown_text = undefined;
     }
     if (!this.streamTs) {
       const response = await this.client.chat.startStream({
@@ -165,6 +167,7 @@ export class ChatStreamer {
       channel: this.streamArgs.channel,
       ts: this.streamTs,
       chunks: flushings,
+      ...args,
     });
     this.state = 'completed';
     return response;
@@ -190,6 +193,7 @@ export class ChatStreamer {
         ...this.streamArgs,
         token: this.token,
         chunks: flushings,
+        ...args,
       });
       this.buffer = '';
       this.streamTs = response.ts;
@@ -201,6 +205,7 @@ export class ChatStreamer {
       channel: this.streamArgs.channel,
       ts: this.streamTs,
       chunks: flushings,
+      ...args,
     });
     this.buffer = '';
     return response;
