Refactoring
This commit is contained in:
@@ -1,7 +1,7 @@
|
||||
import { FileSystem, HttpMiddleware, HttpRouter, HttpServer, HttpServerRequest, HttpServerResponse, Path } from "@effect/platform"
|
||||
import { RpcServer } from "@effect/rpc"
|
||||
import { CommonConfig } from "@website/common/config"
|
||||
import { WebRpc, WebRpcSerialization } from "@website/common/webrpc"
|
||||
import { WebRpc, WebRpcSerializationDevelopment, WebRpcSerializationProduction } from "@website/common/webrpc"
|
||||
import { Duration, Effect, flow, Layer } from "effect"
|
||||
import { WebRpcLive } from "./webrpc"
|
||||
|
||||
@@ -10,10 +10,10 @@ const router = HttpRouter.empty
|
||||
|
||||
const makeWebRpcRoute = Effect.all([
|
||||
CommonConfig.webRpcHttpPath,
|
||||
RpcServer.toHttpApp(WebRpc.WebRpc),
|
||||
RpcServer.toHttpApp(WebRpc),
|
||||
]).pipe(
|
||||
Effect.map(([path, app]) => HttpRouter.mountApp(path, app)),
|
||||
Effect.provide(WebRpcLive.WebRpcLive),
|
||||
Effect.provide(WebRpcLive),
|
||||
)
|
||||
|
||||
const makeProductionWebappMiddleware = Effect.gen(function*() {
|
||||
@@ -38,7 +38,7 @@ const makeProductionWebappMiddleware = Effect.gen(function*() {
|
||||
})
|
||||
|
||||
|
||||
export const HttpAppDevelopment = Effect.provide(makeWebRpcRoute, WebRpcSerialization.WebRpcSerializationDevelopment).pipe(
|
||||
export const HttpAppDevelopment = Effect.provide(makeWebRpcRoute, WebRpcSerializationDevelopment).pipe(
|
||||
Effect.map(serveWebRpc => router.pipe(
|
||||
serveWebRpc,
|
||||
HttpServer.serve(flow(
|
||||
@@ -52,7 +52,7 @@ export const HttpAppDevelopment = Effect.provide(makeWebRpcRoute, WebRpcSerializ
|
||||
)
|
||||
|
||||
export const HttpAppProduction = Effect.all([
|
||||
Effect.provide(makeWebRpcRoute, WebRpcSerialization.WebRpcSerializationProduction),
|
||||
Effect.provide(makeWebRpcRoute, WebRpcSerializationProduction),
|
||||
makeProductionWebappMiddleware,
|
||||
]).pipe(
|
||||
Effect.map(([serveWebRpc, serveProductionWebapp]) => router.pipe(
|
||||
|
||||
@@ -1,8 +0,0 @@
|
||||
import { Layer } from "effect"
|
||||
import * as WebRpcTestLive from "./WebRpcTestLive"
|
||||
import type { WebRpc } from "@website/common/webrpc"
|
||||
|
||||
|
||||
export const WebRpcLive = Layer.mergeAll(
|
||||
WebRpcTestLive.WebRpcTestLive,
|
||||
) satisfies ReturnType<typeof WebRpc.WebRpc.toLayer>
|
||||
@@ -1,2 +1,10 @@
|
||||
export * as WebRpcLive from "./WebRpcLive"
|
||||
import type { WebRpc } from "@website/common/webrpc"
|
||||
import { Layer } from "effect"
|
||||
import * as WebRpcTestLive from "./WebRpcTestLive"
|
||||
|
||||
|
||||
export const WebRpcLive = Layer.mergeAll(
|
||||
WebRpcTestLive.WebRpcTestLive,
|
||||
) satisfies ReturnType<typeof WebRpc.toLayer>
|
||||
|
||||
export * as WebRpcTestLive from "./WebRpcTestLive"
|
||||
|
||||
Reference in New Issue
Block a user