♻️ refactor: rename params

Author: cy948

src/libs/agent-runtime/anthropic/index.ts

@@ -80,12 +80,9 @@ export class LobeAnthropicAI implements LobeRuntimeAI {
         debugStream(debug.toReadableStream()).catch(console.error);
       }
 
-      return StreamingResponse(
-        AnthropicStream(prod, { callbacks: options?.callback }, { inputStartAt }),
-        {
-          headers: options?.headers,
-        },
-      );
+      return StreamingResponse(AnthropicStream(prod, { callbacks: options?.callback, inputStartAt }), {
+        headers: options?.headers,
+      });
     } catch (error) {
       throw this.handleError(error);
     }
@@ -107,12 +104,12 @@ export class LobeAnthropicAI implements LobeRuntimeAI {
 
     const systemPrompts = !!system_message?.content
       ? ([
-          {
-            cache_control: enabledContextCaching ? { type: 'ephemeral' } : undefined,
-            text: system_message?.content as string,
-            type: 'text',
-          },
-        ] as Anthropic.TextBlockParam[])
+        {
+          cache_control: enabledContextCaching ? { type: 'ephemeral' } : undefined,
+          text: system_message?.content as string,
+          type: 'text',
+        },
+      ] as Anthropic.TextBlockParam[])
       : undefined;
 
     const postMessages = await buildAnthropicMessages(user_messages, { enabledContextCaching });

src/libs/agent-runtime/utils/openaiCompatibleFactory/index.ts

@@ -257,7 +257,7 @@ export const LobeOpenAICompatibleFactory = <T extends Record<string, any> = any>
           return StreamingResponse(
             chatCompletion?.handleStream
               ? chatCompletion.handleStream(prod, streamOptions.callbacks)
-              : OpenAIStream(prod, streamOptions, { inputStartAt }),
+              : OpenAIStream(prod, { ...streamOptions, inputStartAt }),
             {
               headers: options?.headers,
             },
@@ -277,7 +277,7 @@ export const LobeOpenAICompatibleFactory = <T extends Record<string, any> = any>
         return StreamingResponse(
           chatCompletion?.handleStream
             ? chatCompletion.handleStream(stream, streamOptions.callbacks)
-            : OpenAIStream(stream, streamOptions, { inputStartAt }),
+            : OpenAIStream(stream, { ...streamOptions, inputStartAt }),
           {
             headers: options?.headers,
           },

src/libs/agent-runtime/utils/streams/anthropic.test.ts

@@ -168,7 +168,7 @@ describe('AnthropicStream', () => {
 
     const protocolStream = AnthropicStream(mockReadableStream, {
       callbacks: {
-        onToolCall: onToolCallMock,
+        onToolsCalling: onToolCallMock,
       },
     });
 
@@ -322,7 +322,7 @@ describe('AnthropicStream', () => {
 
     const protocolStream = AnthropicStream(mockReadableStream, {
       callbacks: {
-        onToolCall: onToolCallMock,
+        onToolsCalling: onToolCallMock,
       },
     });
 

src/libs/agent-runtime/utils/streams/anthropic.ts

@@ -191,12 +191,12 @@ export const transformAnthropicStream = (
 
 export interface AnthropicStreamOptions {
   callbacks?: ChatStreamCallbacks;
+  inputStartAt?: number;
 }
 
 export const AnthropicStream = (
   stream: Stream<Anthropic.MessageStreamEvent> | ReadableStream,
-  { callbacks }: AnthropicStreamOptions = {},
-  { inputStartAt }: { inputStartAt?: number } = {},
+  { callbacks, inputStartAt }: AnthropicStreamOptions = {},
 ) => {
   const streamStack: StreamContext = { id: '' };
 

src/libs/agent-runtime/utils/streams/openai.ts

@@ -219,13 +219,13 @@ export interface OpenAIStreamOptions {
     name: string;
   }) => ILobeAgentRuntimeErrorType | undefined;
   callbacks?: ChatStreamCallbacks;
+  inputStartAt?: number;
   provider?: string;
 }
 
 export const OpenAIStream = (
   stream: Stream<OpenAI.ChatCompletionChunk> | ReadableStream,
-  { callbacks, provider, bizErrorTypeTransformer }: OpenAIStreamOptions = {},
-  { inputStartAt }: { inputStartAt?: number } = {},
+  { callbacks, provider, bizErrorTypeTransformer, inputStartAt }: OpenAIStreamOptions = {},
 ) => {
   const streamStack: StreamContext = { id: '' };