mirror of
https://github.com/BradNut/awesome-uses
synced 2025-09-08 17:40:31 +00:00
49 lines
1.2 KiB
TypeScript
49 lines
1.2 KiB
TypeScript
|
|
import { PassThrough } from 'stream';
|
||
|
|
import type { EntryContext } from '@remix-run/node';
|
||
|
|
import { Response } from '@remix-run/node';
|
||
|
|
import { RemixServer } from '@remix-run/react';
|
||
|
|
import { renderToPipeableStream } from 'react-dom/server';
|
||
|
|
|
||
|
|
const ABORT_DELAY = 5000;
|
||
|
|
|
||
|
|
export default function handleRequest(
|
||
|
|
request: Request,
|
||
|
|
responseStatusCode: number,
|
||
|
|
responseHeaders: Headers,
|
||
|
|
remixContext: EntryContext
|
||
|
|
) {
|
||
|
|
return new Promise((resolve, reject) => {
|
||
|
|
let didError = false;
|
||
|
|
|
||
|
|
const { pipe, abort } = renderToPipeableStream(
|
||
|
|
<RemixServer context={remixContext} url={request.url} />,
|
||
|
|
{
|
||
|
|
onShellReady: () => {
|
||
|
|
const body = new PassThrough();
|
||
|
|
|
||
|
|
responseHeaders.set('Content-Type', 'text/html');
|
||
|
|
|
||
|
|
resolve(
|
||
|
|
new Response(body, {
|
||
|
|
headers: responseHeaders,
|
||
|
|
status: didError ? 500 : responseStatusCode,
|
||
|
|
})
|
||
|
|
);
|
||
|
|
|
||
|
|
pipe(body);
|
||
|
|
},
|
||
|
|
onShellError: (err: unknown) => {
|
||
|
|
reject(err);
|
||
|
|
},
|
||
|
|
onError: (error: unknown) => {
|
||
|
|
didError = true;
|
||
|
|
|
||
|
|
console.error(error);
|
||
|
|
},
|
||
|
|
}
|
||
|
|
);
|
||
|
|
|
||
|
|
setTimeout(abort, ABORT_DELAY);
|
||
|
|
});
|
||
|
|
}
|