Unified · Split
| @@ -834,6 +834,7 @@ describe("ProviderRuntimeIngestion", () => { · 833 unmodified lines | ||
| 834 | 834 | payload: { |
| 835 | 835 | itemType: "assistant_message", |
| 836 | 836 | status: "completed", |
| 837 | + detail: "hello live", | |
| 837 | 838 | }, |
| 838 | 839 | }); |
| 839 | 840 | |
| @@ -951,6 +951,10 @@ const make = Effect.gen(function* () { · 950 unmodified lines | ||
| 951 | 951 | if (assistantCompletion) { |
| 952 | 952 | const assistantMessageId = assistantCompletion.messageId; |
| 953 | 953 | const turnId = toTurnId(event.turnId); |
| 954 | + const existingAssistantMessage = thread.messages.find((entry) => entry.id === assistantMessageId); | |
| 955 | + const shouldApplyFallbackCompletionText = | |
| 956 | + !existingAssistantMessage || | |
| 957 | + existingAssistantMessage.text.length === 0; | |
| 954 | 958 | if (turnId) { |
| 955 | 959 | yield* rememberAssistantMessageId(thread.id, turnId, assistantMessageId); |
| 956 | 960 | } |
| @@ -963,7 +967,7 @@ const make = Effect.gen(function* () { · 6 unmodified lines | ||
| 963 | 967 | createdAt: now, |
| 964 | 968 | commandTag: "assistant-complete", |
| 965 | 969 | finalDeltaCommandTag: "assistant-delta-finalize", |
| 966 | − ...(assistantCompletion.fallbackText !== undefined | |
| 970 | + ...(assistantCompletion.fallbackText !== undefined && shouldApplyFallbackCompletionText | |
| 967 | 971 | ? { fallbackText: assistantCompletion.fallbackText } |
| 968 | 972 | : {}), |
| 969 | 973 | }); |