test: simplify openresponses event type collection · openclaw/openclaw@91a6372
steipete
·
2026-05-09
·
via Recent Commits to openclaw:main
| Original file line number | Diff line number | Diff line change |
|---|
@@ -132,6 +132,16 @@ function parseSseEvents(text: string): SseEvent[] {
|
132 | 132 | return events; |
133 | 133 | } |
134 | 134 | |
| 135 | +function collectSseEventTypes(events: readonly SseEvent[]): string[] { |
| 136 | +const eventTypes: string[] = []; |
| 137 | +for (const event of events) { |
| 138 | +if (event.event) { |
| 139 | +eventTypes.push(event.event); |
| 140 | +} |
| 141 | +} |
| 142 | +return eventTypes; |
| 143 | +} |
| 144 | + |
135 | 145 | function findSseEvent(events: SseEvent[], eventName: string): SseEvent { |
136 | 146 | const event = events.find((candidate) => candidate.event === eventName); |
137 | 147 | if (!event) { |
@@ -710,7 +720,7 @@ describe("OpenResponses HTTP API (e2e)", () => {
|
710 | 720 | const deltaText = await resDelta.text(); |
711 | 721 | const deltaEvents = parseSseEvents(deltaText); |
712 | 722 | |
713 | | -const eventTypes = deltaEvents.map((e) => e.event).filter(Boolean); |
| 723 | +const eventTypes = collectSseEventTypes(deltaEvents); |
714 | 724 | expect(eventTypes).toContain("response.created"); |
715 | 725 | expect(eventTypes).toContain("response.output_item.added"); |
716 | 726 | expect(eventTypes).toContain("response.in_progress"); |
|
此内容由惯性聚合(RSS阅读器)自动聚合整理,仅供阅读参考。 原文来自 — 版权归原作者所有。