Function runChatWithMiddleware

packages/ai/tests/middleware.test.ts:1364–1393

(params: {
      threadId?: string
      conversationId?: string
    })

  // ==========================================================================
  describe('threadId / conversationId', () => {
    const runChatWithMiddleware = async (params: {
      threadId?: string
      conversationId?: string
    }): Promise<{
      ctxThreadId: string | undefined
      ctxConvId: string | undefined
    }> => {
      let ctxThreadId: string | undefined
      let ctxConvId: string | undefined
      const { adapter } = createMockAdapter({
        iterations: [
          [ev.runStarted(), ev.textContent('hi'), ev.runFinished('stop')],
        ],
      })
      const middleware: ChatMiddleware = {
        name: 'test',
        onStart: (ctx) => {
          ctxThreadId = ctx.threadId
          ctxConvId = ctx.conversationId
        },
      }
      const stream = chat({
        adapter,
        messages: [{ role: 'user', content: 'Hi' }],
        middleware: [middleware],
        ...params,
      })
      await collectChunks(stream as AsyncIterable<StreamChunk>)
      return { ctxThreadId, ctxConvId }
    }

    it('uses caller-provided threadId for both ctx.threadId and ctx.conversationId (legacy alias)', async () => {
      const { ctxThreadId, ctxConvId } = await runChatWithMiddleware({