|
@@ -1007,7 +1007,7 @@ export namespace Session {
|
|
|
async process(stream: StreamTextResult<Record<string, AITool>, never>) {
|
|
async process(stream: StreamTextResult<Record<string, AITool>, never>) {
|
|
|
try {
|
|
try {
|
|
|
let currentText: MessageV2.TextPart | undefined
|
|
let currentText: MessageV2.TextPart | undefined
|
|
|
- let reasoningMap: Record<string, MessageV2.ReasoningPart> = {}
|
|
|
|
|
|
|
+ // let reasoningMap: Record<string, MessageV2.ReasoningPart> = {}
|
|
|
|
|
|
|
|
for await (const value of stream.fullStream) {
|
|
for await (const value of stream.fullStream) {
|
|
|
log.info("part", {
|
|
log.info("part", {
|
|
@@ -1017,6 +1017,7 @@ export namespace Session {
|
|
|
case "start":
|
|
case "start":
|
|
|
break
|
|
break
|
|
|
|
|
|
|
|
|
|
+ /*
|
|
|
case "reasoning-start":
|
|
case "reasoning-start":
|
|
|
if (value.id in reasoningMap) {
|
|
if (value.id in reasoningMap) {
|
|
|
continue
|
|
continue
|
|
@@ -1045,15 +1046,16 @@ export namespace Session {
|
|
|
if (value.id in reasoningMap) {
|
|
if (value.id in reasoningMap) {
|
|
|
const part = reasoningMap[value.id]
|
|
const part = reasoningMap[value.id]
|
|
|
part.text = part.text.trimEnd()
|
|
part.text = part.text.trimEnd()
|
|
|
- part.providerMetadata = value.providerMetadata
|
|
|
|
|
|
|
+ part.metadata = value.providerMetadata
|
|
|
part.time = {
|
|
part.time = {
|
|
|
- start: Date.now(),
|
|
|
|
|
|
|
+ ...part.time,
|
|
|
end: Date.now(),
|
|
end: Date.now(),
|
|
|
}
|
|
}
|
|
|
await updatePart(part)
|
|
await updatePart(part)
|
|
|
delete reasoningMap[value.id]
|
|
delete reasoningMap[value.id]
|
|
|
}
|
|
}
|
|
|
break
|
|
break
|
|
|
|
|
+ */
|
|
|
|
|
|
|
|
case "tool-input-start":
|
|
case "tool-input-start":
|
|
|
const part = await updatePart({
|
|
const part = await updatePart({
|