Skip to content

Commit 2e2fd83

Browse files
Backport: refactoring(provider/openai): simplify code (#10632)
This is a backport of #10586 to the release-v5.0 branch. --------- Co-authored-by: Lars Grammel <[email protected]>
1 parent a2c893b commit 2e2fd83

File tree

2 files changed

+20
-21
lines changed

2 files changed

+20
-21
lines changed

.changeset/odd-cows-taste.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
'@ai-sdk/openai': patch
3+
---
4+
5+
refactoring(provider/openai): simplify code

packages/openai/src/responses/openai-responses-language-model.ts

Lines changed: 15 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -880,11 +880,21 @@ export class OpenAIResponsesLanguageModel implements LanguageModelV2 {
880880
},
881881
});
882882
}
883-
} else if (
884-
isResponseOutputItemDoneChunk(value) &&
885-
value.item.type !== 'message'
886-
) {
887-
if (value.item.type === 'function_call') {
883+
} else if (isResponseOutputItemDoneChunk(value)) {
884+
if (value.item.type === 'message') {
885+
controller.enqueue({
886+
type: 'text-end',
887+
id: value.item.id,
888+
providerMetadata: {
889+
openai: {
890+
itemId: value.item.id,
891+
...(ongoingAnnotations.length > 0 && {
892+
annotations: ongoingAnnotations,
893+
}),
894+
},
895+
},
896+
});
897+
} else if (value.item.type === 'function_call') {
888898
ongoingToolCalls[value.output_index] = undefined;
889899
hasFunctionCall = true;
890900

@@ -1231,22 +1241,6 @@ export class OpenAIResponsesLanguageModel implements LanguageModelV2 {
12311241
: {}),
12321242
});
12331243
}
1234-
} else if (
1235-
isResponseOutputItemDoneChunk(value) &&
1236-
value.item.type === 'message'
1237-
) {
1238-
controller.enqueue({
1239-
type: 'text-end',
1240-
id: value.item.id,
1241-
providerMetadata: {
1242-
openai: {
1243-
itemId: value.item.id,
1244-
...(ongoingAnnotations.length > 0 && {
1245-
annotations: ongoingAnnotations,
1246-
}),
1247-
},
1248-
},
1249-
});
12501244
} else if (isErrorChunk(value)) {
12511245
controller.enqueue({ type: 'error', error: value });
12521246
}

0 commit comments

Comments
 (0)