packages/svelte/src/chat.svelte.test.ts 58- ], 59- }; 60- 61: await chat.sendMessage({ 62- parts: [{ text: 'hi', type: 'text' }], 63- }); 64- expect(chat.messages.at(0)).toStrictEqual( -- 83- body: 'Not found', 84- }; 85- 86: await chat.sendMessage({ 87- text: 'hi', 88- }); 89- expect(chat.error).toBeInstanceOf(Error); -- 101- ], 102- }; 103- 104: await chat.sendMessage({ 105- role: 'user', 106- parts: [{ text: 'hi', type: 'text' }], 107- }); -- 117- controller, 118- }; 119- 120: const appendOperation = chat.sendMessage({ 121- role: 'user', 122- parts: [{ text: 'hi', type: 'text' }], 123- }); -- 140- body: 'Not found', 141- }; 142- 143: chat.sendMessage({ 144- role: 'user', 145- parts: [{ text: 'hi', type: 'text' }], 146- }); packages/react/src/use-chat.ts 27- error: Error | undefined; 28-} & Pick< 29- AbstractChat, 30: | 'sendMessage' 31- | 'regenerate' 32- | 'stop' 33- | 'resumeStream' -- 156- id: chatRef.current.id, 157- messages, 158- setMessages, 159: sendMessage: chatRef.current.sendMessage, 160- regenerate: chatRef.current.regenerate, 161- clearError: chatRef.current.clearError, 162- stop: chatRef.current.stop, packages/codemod/src/test/__testfixtures__/replace-usechat-api-with-transport.output.ts 2-import { useChat, DefaultChatTransport } from '@ai-sdk/react'; 3- 4-export function ChatWithApiString() { 5: const { messages, sendMessage } = useChat({ 6- transport: new DefaultChatTransport({ 7- api: '/api/chat' 8- }) -- 12-} 13- 14-export function ChatWithApiAndOptions() { 15: const { messages, sendMessage } = useChat({ 16- onError: (error) => console.error(error), 17- initialMessages: [], 18- -- 25-} 26- 27-export function ChatWithoutApi() { 28: const { messages, sendMessage } = useChat({ 29- onError: (error) => console.error(error), 30- }); 31- -- 34- 35-export function ChatWithApiVariable() { 36- const apiEndpoint = '/api/chat'; 37: const { messages, sendMessage } = useChat({ 38- maxSteps: 5, 39- 40- transport: new DefaultChatTransport({ -- 47- 48-export function ChatWithComplexApi() { 49- const baseUrl = 'https://api.example.com'; 50: const { messages, sendMessage, isLoading } = useChat({ 51- onError: handleError, 52- onFinish: handleFinish, 53- packages/codemod/src/test/__testfixtures__/replace-usechat-api-with-transport.input.ts 2-import { useChat } from 'ai/react'; 3- 4-export function ChatWithApiString() { 5: const { messages, sendMessage } = useChat({ 6- api: '/api/chat', 7- }); 8- -- 10-} 11- 12-export function ChatWithApiAndOptions() { 13: const { messages, sendMessage } = useChat({ 14- api: '/api/custom-chat', 15- onError: (error) => console.error(error), 16- initialMessages: [], -- 20-} 21- 22-export function ChatWithoutApi() { 23: const { messages, sendMessage } = useChat({ 24- onError: (error) => console.error(error), 25- }); 26- -- 29- 30-export function ChatWithApiVariable() { 31- const apiEndpoint = '/api/chat'; 32: const { messages, sendMessage } = useChat({ 33- api: apiEndpoint, 34- maxSteps: 5, 35- }); -- 39- 40-export function ChatWithComplexApi() { 41- const baseUrl = 'https://api.example.com'; 42: const { messages, sendMessage, isLoading } = useChat({ 43- api: `${baseUrl}/chat`, 44- onError: handleError, 45- onFinish: handleFinish, packages/codemod/src/codemods/v5/rename-addtoolresult-to-addtooloutput.ts 127- } 128- }); 129- 130: // Replace string literals in type unions (e.g., Pick) 131- root.find(j.StringLiteral).forEach(path => { 132- if (path.node.value === 'addToolOutput') { 133- path.node.value = 'addToolOutput'; packages/angular/src/lib/chat.ng.test.ts 55- ], 56- }; 57- 58: await chat.sendMessage({ 59- parts: [{ text: 'hi', type: 'text' }], 60- }); 61- expect(chat.messages.at(0)).toStrictEqual( -- 80- body: 'Not found', 81- }; 82- 83: await chat.sendMessage({ 84- text: 'hi', 85- }); 86- expect(chat.error).toBeInstanceOf(Error); -- 98- ], 99- }; 100- 101: await chat.sendMessage({ 102- role: 'user', 103- parts: [{ text: 'hi', type: 'text' }], 104- }); -- 114- controller, 115- }; 116- 117: const appendOperation = chat.sendMessage({ 118- role: 'user', 119- parts: [{ text: 'hi', type: 'text' }], 120- }); -- 137- body: 'Not found', 138- }; 139- 140: chat.sendMessage({ 141- role: 'user', 142- parts: [{ text: 'hi', type: 'text' }], 143- }); packages/langchain/src/transport.ts 57- }); 58- } 59- 60: async sendMessages( 61- options: { 62- trigger: 'submit-message' | 'regenerate-message'; 63- chatId: string; packages/langchain/src/transport.test.ts 8- apiKey: 'test-key', 9- }); 10- 11: expect('sendMessages' in transport).toBe(true); 12- expect('reconnectToStream' in transport).toBe(true); 13- }); 14- -- 17- url: 'https://test.langsmith.app', 18- }); 19- 20: expect('sendMessages' in transport).toBe(true); 21- }); 22- 23- it('should create transport with custom graphId', () => { -- 26- graphId: 'custom-agent', 27- }); 28- 29: expect('sendMessages' in transport).toBe(true); 30- }); 31- 32- it('should throw error for reconnectToStream', async () => { packages/ai/src/ui/http-chat-transport.ts 153- this.prepareReconnectToStreamRequest = prepareReconnectToStreamRequest; 154- } 155- 156: async sendMessages({ 157- abortSignal, 158- ...options 159: }: Parameters['sendMessages']>[0]) { 160- const resolvedBody = await resolve(this.body); 161- const resolvedHeaders = await resolve(this.headers); 162- const resolvedCredentials = await resolve(this.credentials); packages/ai/src/ui/http-chat-transport.test.ts 35- body: { someData: true }, 36- }); 37- 38: await transport.sendMessages({ 39- chatId: 'c123', 40- messageId: 'm123', 41- trigger: 'submit-message', -- 82- body: () => ({ someData: true }), 83- }); 84- 85: await transport.sendMessages({ 86- chatId: 'c123', 87- messageId: 'm123', 88- trigger: 'submit-message', -- 131- headers: { 'X-Test-Header': 'test-value' }, 132- }); 133- 134: await transport.sendMessages({ 135- chatId: 'c123', 136- messageId: 'm123', 137- trigger: 'submit-message', -- 162- headers: () => ({ 'X-Test-Header': 'test-value-fn' }), 163- }); 164- 165: await transport.sendMessages({ 166- chatId: 'c123', 167- messageId: 'm123', 168- trigger: 'submit-message', packages/ai/src/ui/direct-chat-transport.ts 41- * import { DirectChatTransport } from 'ai'; 42- * import { myAgent } from './my-agent'; 43- * 44: * const { messages, sendMessage } = useChat({ 45- * transport: new DirectChatTransport({ agent: myAgent }), 46- * }); 47- * ``` -- 74- this.uiMessageStreamOptions = uiMessageStreamOptions; 75- } 76- 77: async sendMessages({ 78- messages, 79- abortSignal, 80: }: Parameters['sendMessages']>[0]): Promise< 81- ReadableStream 82- > { 83- // Validate the incoming UI messages packages/ai/src/ui/direct-chat-transport.test.ts 5-import { DirectChatTransport } from './direct-chat-transport'; 6- 7-describe('DirectChatTransport', () => { 8: describe('sendMessages', () => { 9- let mockModel: MockLanguageModelV3; 10- 11- beforeEach(() => { -- 55- const agent = new ToolLoopAgent({ model: mockModel }); 56- const transport = new DirectChatTransport({ agent }); 57- 58: const stream = await transport.sendMessages({ 59- chatId: 'chat-1', 60- messageId: undefined, 61- trigger: 'submit-message', -- 140- 141- const abortController = new AbortController(); 142- 143: const stream = await transport.sendMessages({ 144- chatId: 'chat-1', 145- messageId: undefined, 146- trigger: 'submit-message', -- 213- options: { customOption: 'test-value' }, 214- }); 215- 216: const stream = await transport.sendMessages({ 217- chatId: 'chat-1', 218- messageId: undefined, 219- trigger: 'submit-message', -- 283- sendReasoning: true, 284- }); 285- 286: const stream = await transportWithReasoning.sendMessages({ 287- chatId: 'chat-1', 288- messageId: undefined, 289- trigger: 'submit-message', packages/ai/src/ui/chat.ts 286- * 287- * If a messageId is provided, the message will be replaced. 288- */ 289: sendMessage = async ( 290- message?: 291- | (CreateUIMessage & { 292- text?: never; -- 599- 600- stream = reconnect; 601- } else { 602: stream = await this.transport.sendMessages({ 603- chatId: this.id, 604- messages: this.state.messages, 605- abortSignal: activeResponse.abortController.signal, packages/ai/src/ui/chat.test.ts 118- }, 119- }); 120- 121: chat.sendMessage({ 122- text: 'Hello, world!', 123- }); 124- -- 463- }, 464- }); 465- 466: chat.sendMessage({ 467- text: 'Hello, world!', 468- }); 469- -- 685- id: '123', 686- generateId: mockId(), 687- transport: { 688: sendMessages: async options => { 689- options.abortSignal?.addEventListener('abort', () => { 690- isAborted = true; 691- controller.error(new DOMException('Aborted', 'AbortError')); -- 702- }, 703- }); 704- 705: chat.sendMessage({ 706- text: 'Hello, world!', 707- }); 708- -- 924- onFinish: () => finishPromise.resolve(), 925- }); 926- 927: chat.sendMessage({ 928- text: 'Hello, world!', 929- metadata: { someData: true }, 930- }); packages/ai/src/ui/chat-transport.ts 40- * 41- * @throws Error when the API request fails or response is invalid 42- */ 43: sendMessages: ( 44- options: { 45- /** The type of message submission - either new message or regeneration */ 46- trigger: 'submit-message' | 'regenerate-message';