This commit is contained in:
@@ -16,51 +16,41 @@ const makeWebRpcRoute = Effect.all([
|
|||||||
Effect.provide(WebRpcLive),
|
Effect.provide(WebRpcLive),
|
||||||
)
|
)
|
||||||
|
|
||||||
const makeProductionWebappMiddleware = Effect.gen(function*() {
|
const makeProductionWebappRoute = Effect.fnUntraced(function*(route: HttpRouter.PathInput) {
|
||||||
const path = yield* Path.Path
|
const path = yield* Path.Path
|
||||||
const fs = yield* FileSystem.FileSystem
|
const fs = yield* FileSystem.FileSystem
|
||||||
const dist = path.join(yield* path.fromFileUrl(new URL(".", import.meta.resolve("@website/webapp"))), "dist")
|
const dist = path.join(yield* path.fromFileUrl(new URL(".", import.meta.resolve("@website/webapp"))), "dist")
|
||||||
|
|
||||||
return () => Effect.gen(function*() {
|
return HttpRouter.all(route, Effect.gen(function*() {
|
||||||
const req = yield* HttpServerRequest.HttpServerRequest
|
const req = yield* HttpServerRequest.HttpServerRequest
|
||||||
const source = path.join(dist, req.url)
|
const source = path.join(dist, req.url)
|
||||||
const isValid = yield* fs.stat(source).pipe(
|
const exists = yield* fs.stat(source).pipe(
|
||||||
Effect.andThen(stat => stat.type === "File"),
|
Effect.andThen(stat => stat.type === "File"),
|
||||||
Effect.catchAll(() => Effect.succeed(false)),
|
Effect.catchAll(() => Effect.succeed(false)),
|
||||||
)
|
)
|
||||||
|
|
||||||
return yield* HttpServerResponse.setHeader(
|
return yield* HttpServerResponse.setHeader(
|
||||||
yield* HttpServerResponse.file(isValid ? source : path.join(dist, "index.html")),
|
yield* HttpServerResponse.file(exists ? source : path.join(dist, "index.html")),
|
||||||
"Cache-Control",
|
"Cache-Control",
|
||||||
`public, max-age=${Duration.toSeconds("365 days")}, immutable`
|
`public, max-age=${Duration.toSeconds("365 days")}, immutable`
|
||||||
)
|
)
|
||||||
})
|
}))
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|
||||||
export const HttpAppDevelopment = Effect.provide(makeWebRpcRoute, WebRpcSerializationDevelopment).pipe(
|
export const HttpAppDevelopment = Layer.unwrapScoped(Effect.gen(function*() {
|
||||||
Effect.map(serveWebRpc => router.pipe(
|
return router.pipe(
|
||||||
serveWebRpc,
|
yield* Effect.provide(makeWebRpcRoute, WebRpcSerializationDevelopment),
|
||||||
HttpServer.serve(flow(
|
HttpServer.serve(flow(HttpMiddleware.logger, HttpMiddleware.xForwardedHeaders)),
|
||||||
HttpMiddleware.logger,
|
|
||||||
HttpMiddleware.xForwardedHeaders,
|
|
||||||
)),
|
|
||||||
HttpServer.withLogAddress,
|
HttpServer.withLogAddress,
|
||||||
)),
|
|
||||||
|
|
||||||
Layer.unwrapScoped,
|
|
||||||
)
|
)
|
||||||
|
}))
|
||||||
|
|
||||||
export const HttpAppProduction = Effect.all([
|
export const HttpAppProduction = Layer.unwrapScoped(Effect.gen(function*() {
|
||||||
Effect.provide(makeWebRpcRoute, WebRpcSerializationProduction),
|
return router.pipe(
|
||||||
makeProductionWebappMiddleware,
|
yield* Effect.provide(makeWebRpcRoute, WebRpcSerializationProduction),
|
||||||
]).pipe(
|
yield* makeProductionWebappRoute("*"),
|
||||||
Effect.map(([serveWebRpc, serveProductionWebapp]) => router.pipe(
|
|
||||||
serveWebRpc,
|
|
||||||
serveProductionWebapp,
|
|
||||||
HttpServer.serve(HttpMiddleware.xForwardedHeaders),
|
HttpServer.serve(HttpMiddleware.xForwardedHeaders),
|
||||||
HttpServer.withLogAddress,
|
HttpServer.withLogAddress,
|
||||||
)),
|
|
||||||
|
|
||||||
Layer.unwrapScoped,
|
|
||||||
)
|
)
|
||||||
|
}))
|
||||||
|
|||||||
Reference in New Issue
Block a user