Skip to content

Commit 1e7be14

Browse files
committed
fix(cloudflare): fix the node wrapper
Returns the response converted from the internal event. It fixes a "This ReadableStream did not return bytes" workerd error.
1 parent d2ead58 commit 1e7be14

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

.changeset/giant-parrots-hear.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
"@opennextjs/aws": patch
3+
---
4+
5+
fix(cloudflare): fix the node wrapper

packages/open-next/src/overrides/wrappers/cloudflare-node.ts

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -31,9 +31,6 @@ const handler: WrapperHandler<InternalEvent, InternalResult> =
3131
const url = new URL(internalEvent.url);
3232
(internalEvent.url as string) = url.href.slice(url.origin.length);
3333

34-
const { promise: promiseResponse, resolve: resolveResponse } =
35-
Promise.withResolvers<Response>();
36-
3734
const streamCreator: StreamCreator = {
3835
writeHeaders(prelude: {
3936
statusCode: number;
@@ -52,17 +49,15 @@ const handler: WrapperHandler<InternalEvent, InternalResult> =
5249
status: statusCode,
5350
headers: responseHeaders,
5451
});
55-
resolveResponse(response);
5652

5753
return Writable.fromWeb(writable);
5854
},
5955
onWrite: () => {},
6056
onFinish: (_length: number) => {},
6157
};
6258

63-
ctx.waitUntil(handler(internalEvent, streamCreator));
64-
65-
return promiseResponse;
59+
const internalResult = await handler(internalEvent, streamCreator);
60+
return converter.convertTo(internalResult);
6661
};
6762

6863
export default {

0 commit comments

Comments
 (0)