0.1.17 #18
@@ -1,4 +1,4 @@
|
|||||||
import { Config, Context, Effect, Layer } from "effect"
|
import { Config, Effect, Layer } from "effect"
|
||||||
import * as TRPC from "."
|
import * as TRPC from "."
|
||||||
import { ExpressApp, ExpressNodeHTTPServer } from "../express"
|
import { ExpressApp, ExpressNodeHTTPServer } from "../express"
|
||||||
|
|
||||||
@@ -17,11 +17,16 @@ const router = TRPCBuilder.pipe(Effect.map(t => t.router({
|
|||||||
|
|
||||||
const { TRPCRouter, TRPCRouterLive } = TRPC.TRPCRouter.make(router)
|
const { TRPCRouter, TRPCRouterLive } = TRPC.TRPCRouter.make(router)
|
||||||
|
|
||||||
|
const { TRPCWebSocketServer, TRPCWebSocketServerLive } = TRPC.TRPCWebSocketServer.make(TRPCRouter)
|
||||||
|
|
||||||
|
|
||||||
const ServerLive = Layer.empty.pipe(
|
const ServerLive = Layer.empty.pipe(
|
||||||
Layer.provideMerge(TRPC.TRPCExpressRoute.TRPCExpressRouteLive(TRPCRouter, {
|
Layer.provideMerge(TRPC.TRPCExpressRoute.TRPCExpressRouteLive(TRPCRouter, {
|
||||||
root: Config.succeed("/rpc")
|
root: Config.succeed("/rpc")
|
||||||
})),
|
})),
|
||||||
|
Layer.provideMerge(TRPCWebSocketServerLive({
|
||||||
|
host: Config.succeed("/rpc")
|
||||||
|
})),
|
||||||
|
|
||||||
Layer.provideMerge(TRPCRouterLive),
|
Layer.provideMerge(TRPCRouterLive),
|
||||||
Layer.provideMerge(TRPCBuilderLive),
|
Layer.provideMerge(TRPCBuilderLive),
|
||||||
|
|||||||
Reference in New Issue
Block a user