RPC server work

packages/server/src/express/ExpressApp.ts

@@ -1,8 +1,8 @@
 import { Context, Layer } from "effect"
-import express from "express"
+import express, { type Express } from "express"
 
 
-export class ExpressApp extends Context.Tag("Express")<ExpressApp, ReturnType<typeof express>>() {}
+export class ExpressApp extends Context.Tag("Express")<ExpressApp, Express>() {}
 
 export module ExpressApp {
     export const Live = Layer.sync(ExpressApp, () => express())

packages/server/src/rpc/RPCServer.ts

@@ -1,19 +1,21 @@
 import { createExpressMiddleware } from "@trpc/server/adapters/express"
 import { Config, Effect, Layer } from "effect"
 import { ExpressApp } from "../express/ExpressApp"
-import { createTRPCContext } from "../trpc/context"
+import { CreateTRPCContext } from "../trpc/CreateTRPCContext"
 import { router } from "./routers"
 
 
-export const RPCServerLive = Layer.effectDiscard(Effect.gen(function*() {
+export module RPCServer {
-    const app = yield* ExpressApp
+    export const Live = Layer.effectDiscard(Effect.gen(function*() {
+        const app = yield* ExpressApp
 
-    app.use(
+        app.use(
-        yield* Config.string("RPC_ROOT").pipe(Config.withDefault("/rpc")),
+            yield* Config.string("RPC_ROOT").pipe(Config.withDefault("/rpc")),
 
-        createExpressMiddleware({
+            createExpressMiddleware({
-            router: yield* router,
+                router:         yield* router,
-            createContext: createTRPCContext,
+                createContext:  yield* CreateTRPCContext,
-        }),
+            }),
-    )
+        )
-}))
+    }))
+}

packages/server/src/trpc/CreateTRPCContext.ts

@@ -0,0 +1,12 @@
+import type { CreateExpressContextOptions } from "@trpc/server/adapters/express"
+import { Context, Layer } from "effect"
+import type { TRPCContext } from "./TRPCContext"
+
+
+export class CreateTRPCContext extends Context.Tag("CreateTRPCContext")<CreateTRPCContext,
+    (opts: CreateExpressContextOptions) => TRPCContext
+>() {}
+
+export module CreateTRPCContext {
+    export const Live = Layer.sync(CreateTRPCContext, () => ({ req }) => ({ req }))
+}

packages/server/src/trpc/TRPCBuilder.ts

@@ -1,6 +1,6 @@
 import { initTRPC } from "@trpc/server"
 import { Context, Layer } from "effect"
-import type { TRPCContext } from "./context"
+import type { TRPCContext } from "./TRPCContext"
 
 
 const createTRPC = () => initTRPC.context<TRPCContext>().create()

packages/server/src/trpc/TRPCContext.ts

@@ -0,0 +1,6 @@
+import type { Request } from "express"
+
+
+export interface TRPCContext {
+    req: Request
+}

packages/server/src/trpc/context.ts

@@ -1,5 +0,0 @@
-import type { CreateExpressContextOptions } from "@trpc/server/adapters/express"
-
-
-export const createTRPCContext = ({ req }: CreateExpressContextOptions) => ({ req })
-export type TRPCContext = Awaited<ReturnType<typeof createTRPCContext>>