authorgravatar for julius0216@outlook.comJulius Marminge <julius0216@outlook.com> 2026-02-26 20:38:23-08:00
committergravatar for jmarminge@gmail.comJulius Marminge <jmarminge@gmail.com> 2026-02-26 20:43:22-08:00
log4d6e8e1ca5a7c81f5c56b05fa20b80254ad423d9
treedb92957e55d8997a351558927e9db4a0d733faf5
parent7e4da5b15780307d7616e6b9db190a60a8a2fd90

rm redundant gen

1 files changed, 12 insertions(+), 12 deletions(-)

apps/server/src/orchestration/Layers/ProviderRuntimeIngestion.ts+12-12
...@@ -256,7 +256,8 @@ const make = Effect.gen(function* () {...@@ -256,7 +256,8 @@ const make = Effect.gen(function* () {
256 const clearBufferedAssistantText = (messageId: MessageId) =>256 const clearBufferedAssistantText = (messageId: MessageId) =>
257 Cache.invalidate(bufferedAssistantTextByMessageId, messageId);257 Cache.invalidate(bufferedAssistantTextByMessageId, messageId);
258258
259 const clearAssistantMessageState = (messageId: MessageId) => clearBufferedAssistantText(messageId);259 const clearAssistantMessageState = (messageId: MessageId) =>
260 clearBufferedAssistantText(messageId);
260261
261 const finalizeAssistantMessage = (input: {262 const finalizeAssistantMessage = (input: {
262 event: ProviderRuntimeEvent;263 event: ProviderRuntimeEvent;
...@@ -335,7 +336,8 @@ const make = Effect.gen(function* () {...@@ -335,7 +336,8 @@ const make = Effect.gen(function* () {
335 event.type === "turn.started" ||336 event.type === "turn.started" ||
336 event.type === "turn.completed"337 event.type === "turn.completed"
337 ) {338 ) {
338 const activeTurnId = event.type === "turn.started" ? (toTurnId(event.turnId) ?? null) : null;339 const activeTurnId =
340 event.type === "turn.started" ? (toTurnId(event.turnId) ?? null) : null;
339 const providerThreadIdFromEvent =341 const providerThreadIdFromEvent =
340 event.type === "thread.started"342 event.type === "thread.started"
341 ? ProviderThreadId.makeUnsafe(event.threadId)343 ? ProviderThreadId.makeUnsafe(event.threadId)
...@@ -442,16 +444,14 @@ const make = Effect.gen(function* () {...@@ -442,16 +444,14 @@ const make = Effect.gen(function* () {
442 yield* Effect.forEach(444 yield* Effect.forEach(
443 assistantMessageIds,445 assistantMessageIds,
444 (assistantMessageId) =>446 (assistantMessageId) =>
445 Effect.gen(function* () {447 finalizeAssistantMessage({
446 yield* finalizeAssistantMessage({448 event,
447 event,449 threadId: thread.id,
448 threadId: thread.id,450 messageId: assistantMessageId,
449 messageId: assistantMessageId,451 turnId,
450 turnId,452 createdAt: now,
451 createdAt: now,453 commandTag: "assistant-complete-finalize",
452 commandTag: "assistant-complete-finalize",454 finalDeltaCommandTag: "assistant-delta-finalize-fallback",
453 finalDeltaCommandTag: "assistant-delta-finalize-fallback",
454 });
455 }),455 }),
456 { concurrency: 1 },456 { concurrency: 1 },
457 ).pipe(Effect.asVoid);457 ).pipe(Effect.asVoid);