Skip to content

Commit 83b840f

Browse files
committed
test(sse): add cors middleware for testing
1 parent b9777b3 commit 83b840f

File tree

2 files changed

+10
-5
lines changed

2 files changed

+10
-5
lines changed

test/browser/playwright.config.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ const config: PlaywrightTestConfig = {
99
},
1010
],
1111
timeout: 10_000,
12-
retries: 1,
12+
retries: process.env.PWDEBUG ? 0 : 1,
1313
use: {
1414
trace: 'on-first-retry',
1515
launchOptions: {

test/browser/sse-api/sse.server.connect.test.ts

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
11
import { setupWorker, sse } from 'msw/browser'
2-
import { createTestHttpServer } from '@epic-web/test-server/http'
2+
import {
3+
createTestHttpServer,
4+
TestHttpServerOptions,
5+
} from '@epic-web/test-server/http'
36
import { test, expect } from '../playwright.extend'
47

58
declare namespace window {
@@ -151,7 +154,7 @@ test('forwards custom event from the server to the client automatically', async
151154
const { setupWorker, sse } = window.msw
152155

153156
const worker = setupWorker(
154-
sse(url, ({ client, server }) => {
157+
sse(url, ({ server }) => {
155158
server.connect()
156159
}),
157160
)
@@ -190,6 +193,7 @@ test('forwards error event from the server to the client automatically', async (
190193

191194
return new Response(stream, {
192195
headers: {
196+
'access-control-allow-origin': '*',
193197
'content-type': 'text/event-stream',
194198
'cache-control': 'no-cache',
195199
connection: 'keep-alive',
@@ -204,17 +208,18 @@ test('forwards error event from the server to the client automatically', async (
204208
const { setupWorker, sse } = window.msw
205209

206210
const worker = setupWorker(
207-
sse(url, ({ client, server }) => {
211+
sse(url, ({ server }) => {
208212
server.connect()
209213
}),
210214
)
211215
await worker.start()
212216
}, url)
213217

214218
const errorPromise = page.evaluate((url) => {
215-
return new Promise<void>((resolve) => {
219+
return new Promise<void>((resolve, reject) => {
216220
const source = new EventSource(url)
217221
source.onerror = () => resolve()
222+
source.onmessage = () => reject(new Error('Must not receive a message'))
218223
})
219224
}, url)
220225

0 commit comments

Comments
 (0)