fix(core): enhance response metadata handling and optimize provider model caching

Author: dingyi222666

packages/core/src/generate/stream-text.ts

@@ -144,6 +144,25 @@ export function streamMessageChunks(
                     })
 
                     await writer.write(chunk)
+                } else if (value.type === 'response-metadata') {
+                    await writer.write({
+                        role,
+                        content: '',
+                        metadata: {
+                            response_metadata: value.metadata
+                        },
+                        chunk: true
+                    })
+                } else if (value.type === 'finish') {
+                    await writer.write({
+                        role,
+                        content: '',
+                        metadata: {
+                            usgae: value.usage,
+                            finish_reason: value.finishReason
+                        },
+                        chunk: true
+                    })
                 } else {
                     // Pass through other types directly
                     // For example, source parts would be passed through here
@@ -384,7 +403,7 @@ export function streamText({
             const metadata = {
                 type: 'response-metadata',
                 metadata: {
-                    timestamp: new Date(),
+                    timestamp: Date.now(),
                     model: settings.modelId ?? model.model,
                     // eslint-disable-next-line @typescript-eslint/no-explicit-any
                     responseType: currentPartType as any

packages/core/src/language-models/index.ts

@@ -62,8 +62,8 @@ export type LanguageModelUsage = {
 
 export type LanguageResponseMetadata = {
     id?: string
-    timestamp?: Date
-    model?: string
+    timestamp: number
+    model: string
     responseType: 'text' | 'reasoning' | 'source' | 'tool-call'
 }
 

packages/core/src/provider/registry.ts

@@ -17,7 +17,22 @@ export interface Provider<T extends ProviderConfig = ProviderConfig> {
 export class DefaultProviderRegistry implements Provider {
     private providers: Record<string, Provider> = {}
 
-    private _providerModels: Record<string, PlatformModelInfo[]> = {}
+    private _providerModels: Record<string, PlatformModelInfo[]> = new Proxy(
+        {},
+        {
+            get(target, prop) {
+                return Reflect.get(target, prop)
+            },
+            set(target, prop, value) {
+                try {
+                    throw new Error(`6667`)
+                } catch (err) {
+                    console.error(err)
+                }
+                return Reflect.set(target, prop, value)
+            }
+        }
+    )
 
     providerName: string = 'default'
 
@@ -77,7 +92,7 @@ export class DefaultProviderRegistry implements Provider {
             throw new Error(
                 `No such language model: ${modelId}. Available models: ${Object.entries(
                     this._providerModels
-                ).flatMap(([k, v]) => v.map((m) => `${k}/${m.name}`))})}`
+                ).flatMap(([k, v]) => v.map((m) => `${k}:${m.name}`))})}`
             )
         }
         return model
@@ -106,6 +121,7 @@ export class DefaultProviderRegistry implements Provider {
         for (const providerId in this.providers) {
             if (this._providerModels[providerId]) {
                 const cachedModels = this._providerModels[providerId]
+                console.log(`[${providerId}] use cached models`, cachedModels)
                 result.push(...cachedModels)
                 promises.push(Promise.resolve(cachedModels))
                 continue
@@ -121,16 +137,24 @@ export class DefaultProviderRegistry implements Provider {
                 })
             )
 
+            console.log(
+                `[${providerId}] use hardcode models`,
+                cachePlatformModels
+            )
+
             result.push(...cachePlatformModels)
             this._providerModels[providerId] = cachePlatformModels
 
             const latestPlatformModels = latestModels.then((models) => {
                 const platformModels = models.map((model) => ({
                     ...model,
                     provider: providerId
-                })) as PlatformModelInfo[]
+                }))
 
                 this._providerModels[providerId] = platformModels
+
+                console.log(`[${providerId}] use latest models`, platformModels)
+
                 return platformModels
             })
             promises.push(latestPlatformModels)

packages/openai-compatible/src/get-latest-models.ts

@@ -49,6 +49,9 @@ export async function getLatestModels(
                 .map((model): ModelInfo => {
                     // TODO: check gemini, deepseek, ... to get the correct context token
                     const modelId = model.id
+
+                    // 监听 modelId 改动
+
                     return {
                         name: modelId,
                         type:

packages/openai-compatible/src/provider.ts

@@ -92,7 +92,7 @@ export function createOpenAICompatibleProvider(
             modelId,
             provider as OpenAICompatibleProvider,
             {
-                batchSize: 200
+                batchSize: 20
             },
             fetch
         )