1
1
import { _serialize } from '@qwik.dev/core/internal' ;
2
2
import type { ServerRequestEvent } from '@qwik.dev/router/middleware/request-handler' ;
3
- import { RequestEvShareQData , requestHandler } from '@qwik.dev/router/middleware/request-handler' ;
3
+ import {
4
+ RedirectMessage ,
5
+ RequestEvShareQData ,
6
+ requestHandler ,
7
+ } from '@qwik.dev/router/middleware/request-handler' ;
4
8
import { WritableStream } from 'node:stream/web' ;
5
9
import { pathToFileURL } from 'node:url' ;
6
10
import type { ClientPageData } from '../runtime/src/types' ;
@@ -152,6 +156,7 @@ async function workerRender(
152
156
} ) ;
153
157
}
154
158
} catch ( e : any ) {
159
+ console . error ( 'Error during stream start' , staticRoute . pathname , e ) ;
155
160
routeWriter = null ;
156
161
result . error = {
157
162
message : String ( e ) ,
@@ -166,6 +171,7 @@ async function workerRender(
166
171
routeWriter . write ( Buffer . from ( chunk . buffer ) ) ;
167
172
}
168
173
} catch ( e : any ) {
174
+ console . error ( 'Error during stream write' , staticRoute . pathname , e ) ;
169
175
routeWriter = null ;
170
176
result . error = {
171
177
message : String ( e ) ,
@@ -219,6 +225,7 @@ async function workerRender(
219
225
await Promise . all ( writePromises ) ;
220
226
}
221
227
} catch ( e : any ) {
228
+ console . error ( 'Error during stream close' , staticRoute . pathname , e ) ;
222
229
routeWriter = null ;
223
230
result . error = {
224
231
message : String ( e ) ,
@@ -242,8 +249,13 @@ async function workerRender(
242
249
} ) ;
243
250
}
244
251
} )
245
- . then ( ( e ) => {
252
+ . then ( ( e : any ) => {
246
253
if ( e !== undefined ) {
254
+ if ( e instanceof RedirectMessage ) {
255
+ // TODO We should render a html page for redirects too
256
+ // that would require refactoring redirects
257
+ return ;
258
+ }
247
259
if ( e instanceof Error ) {
248
260
result . error = {
249
261
message : e . message ,
@@ -256,6 +268,7 @@ async function workerRender(
256
268
} ;
257
269
}
258
270
}
271
+ console . error ( 'Error during request handling' , staticRoute . pathname , e ) ;
259
272
} )
260
273
. finally ( ( ) => {
261
274
pendingPromises . delete ( promise ) ;
@@ -264,6 +277,7 @@ async function workerRender(
264
277
265
278
pendingPromises . add ( promise ) ;
266
279
} catch ( e : any ) {
280
+ console . error ( 'Error during render' , staticRoute . pathname , e ) ;
267
281
if ( e instanceof Error ) {
268
282
result . error = {
269
283
message : e . message ,
0 commit comments