Skip to content

Commit a0f194c

Browse files
committed
worker: drop dispatcher URL session identifier (redacted by CF; DO reads ctx.id.name instead)
1 parent d3d243b commit a0f194c

1 file changed

Lines changed: 6 additions & 8 deletions

File tree

worker/index.ts

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -236,10 +236,9 @@ async function handleWebSocketWithDispatcher(
236236
const doId = env.DISPATCHER_DO.idFromName(sessionId);
237237
const stub = env.DISPATCHER_DO.get(doId);
238238

239-
const upgradeRequest = new Request(
240-
`http://dispatcher/websocket?meetingId=${encodeURIComponent(sessionId)}`,
241-
{ headers: { 'Upgrade': 'websocket' } },
242-
);
239+
const upgradeRequest = new Request('http://dispatcher/websocket', {
240+
headers: { 'Upgrade': 'websocket' },
241+
});
243242
const doResponse = await stub.fetch(upgradeRequest);
244243

245244
if (doResponse.webSocket) {
@@ -296,10 +295,9 @@ async function handleWebSocketWithDispatcher(
296295
const doId = env.DISPATCHER_DO.idFromName(sessionId);
297296
const stub = env.DISPATCHER_DO.get(doId);
298297

299-
const upgradeRequest = new Request(
300-
`http://dispatcher/websocket?meetingId=${encodeURIComponent(sessionId)}`,
301-
{ headers: { 'Upgrade': 'websocket' } },
302-
);
298+
const upgradeRequest = new Request('http://dispatcher/websocket', {
299+
headers: { 'Upgrade': 'websocket' },
300+
});
303301
const doResponse = await stub.fetch(upgradeRequest);
304302

305303
if (doResponse.webSocket) {

0 commit comments

Comments
 (0)