MCPcopy Index your code
hub / github.com/triggerdotdev/trigger.dev / handleBotRequest

Function handleBotRequest

apps/webapp/app/entry.server.tsx:63–113  ·  view source on GitHub ↗
(
  request: Request,
  responseStatusCode: number,
  responseHeaders: Headers,
  remixContext: EntryContext,
  locales: string[],
  platform: OperatingSystemPlatform
)

Source from the content-addressed store, hash-verified

61}
62
63function handleBotRequest(
64 request: Request,
65 responseStatusCode: number,
66 responseHeaders: Headers,
67 remixContext: EntryContext,
68 locales: string[],
69 platform: OperatingSystemPlatform
70) {
71 return new Promise((resolve, reject) => {
72 let shellRendered = false;
73 const { pipe, abort } = renderToPipeableStream(
74 <OperatingSystemContextProvider platform={platform}>
75 <LocaleContextProvider locales={locales}>
76 <RemixServer context={remixContext} url={request.url} abortDelay={ABORT_DELAY} />,
77 </LocaleContextProvider>
78 </OperatingSystemContextProvider>,
79 {
80 onAllReady() {
81 shellRendered = true;
82 const body = new PassThrough();
83 const stream = createReadableStreamFromReadable(body);
84
85 responseHeaders.set("Content-Type", "text/html");
86
87 resolve(
88 new Response(stream, {
89 headers: responseHeaders,
90 status: responseStatusCode,
91 })
92 );
93
94 pipe(body);
95 },
96 onShellError(error: unknown) {
97 reject(error);
98 },
99 onError(error: unknown) {
100 responseStatusCode = 500;
101 // Log streaming rendering errors from inside the shell. Don't log
102 // errors encountered during initial shell rendering since they'll
103 // reject and get logged in handleDocumentRequest.
104 if (shellRendered) {
105 console.error(error);
106 }
107 },
108 }
109 );
110
111 setTimeout(abort, ABORT_DELAY);
112 });
113}
114
115function handleBrowserRequest(
116 request: Request,

Callers 1

handleRequestFunction · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…