Function createRouteHandler

packages/uploadthing/src/express.ts:36–62

(
  opts: RouteHandlerOptions<TRouter>,
)

) => createBuilder<AdapterArgs, TErrorShape>(opts);

export const createRouteHandler = <TRouter extends FileRouter>(
  opts: RouteHandlerOptions<TRouter>,
): ExpressRouter => {
  const handler = makeAdapterHandler<
    [ExpressRequest, ExpressResponse],
    AdapterArgs
  >(
    (req, res) => Effect.succeed({ req, res }),
    (req) =>
      Effect.flatMap(getPostBody({ req }), (body) =>
        toWebRequest(req, body),
      ).pipe(Effect.orDie),
    opts,
    "express",
  );

  return ExpressRouter().all("/", async (req, res) => {
    const response = await handler(req, res);
    res.writeHead(response.status, Object.fromEntries(response.headers));
    if (response.body) {
      // Slight type mismatch in `node:stream.ReadableStream` and Fetch's `ReadableStream`.
      Readable.fromWeb(response.body as never).pipe(res);
    } else {
      res.end();
    }
  });
};