package.json

@@ -1,6 +1,6 @@
 {
   "name": "@thilawyn/thilalib",
-  "version": "0.1.19",
+  "version": "0.1.20",
   "type": "module",
   "files": [
     "./dist"
@@ -53,7 +53,7 @@
   },
   "dependencies": {
     "remeda": "^2.12.0",
-    "type-fest": "^4.26.0"
+    "type-fest": "^4.26.1"
   },
   "devDependencies": {
     "@effect/schema": "^0.72.3",

src/TRPC/example.ts

@@ -16,11 +16,22 @@ const { TRPCContextCreator, TRPCContextCreatorLive } = TRPC.TRPCContextCreator.m
 const { TRPCBuilder, TRPCBuilderLive } = TRPC.TRPCBuilder.make<Services>()
 
 
-const router = TRPCBuilder.pipe(Effect.map(t => t.router({
+const router = Effect.gen(function*() {
-    ping: t.procedure.query(({ ctx }) => ctx.run(
+    const t = yield* TRPCBuilder
-        Effect.succeed("pong")
+
-    )),
+    return t.router({
-})))
+        ping: t.procedure.query(({ ctx }) => ctx.run(
+            Effect.succeed("pong")
+        )),
+
+        expressOnlyProcedure: t.procedure
+            .use(yield* TRPC.ExpressOnly)
+            .query(({ ctx }) => ctx.run(Effect.gen(function*() {
+                ctx.transaction
+            }))),
+    })
+})
+
 const { TRPCRouter, TRPCRouterLive } = TRPC.TRPCRouter.make(router)
 
 

src/TRPC/middlewares/DecodeInput.ts

@@ -23,7 +23,7 @@ export const DecodeInput = <A, I>(
     )
 
     return experimental_standaloneMiddleware<{
-        ctx:    TRPCContextRuntime<any>
+        ctx:    TRPCContextRuntime<never>
         input:  I
     }>().create(
         async ({ ctx, input, next }) => next({

src/TRPC/middlewares/ExpressOnly.ts

@@ -9,14 +9,16 @@ export const ExpressOnly = importTRPCServer.pipe(Effect.map(({
 }) => experimental_standaloneMiddleware<{
     ctx: TRPCContextTransaction
 }>().create(({ ctx, next }) => next({
-    ctx: Match.value(ctx.transaction).pipe(
+    ctx: {
-        Match.tag("Express", identity),
+        transaction: Match.value(ctx.transaction).pipe(
+            Match.tag("Express", identity),
 
-        Match.orElse(() => {
+            Match.orElse(() => {
-            throw new TRPCError({
+                throw new TRPCError({
-                code: "BAD_REQUEST",
+                    code: "BAD_REQUEST",
-                message: "Only Express transport is supported by this procedure",
+                    message: "Only Express transport is supported by this procedure",
-            })
+                })
-        }),
+            }),
-    )
+        )
+    }
 }))))

src/TRPC/middlewares/WebSocketOnly.ts

@@ -9,14 +9,16 @@ export const WebSocketOnly = importTRPCServer.pipe(Effect.map(({
 }) => experimental_standaloneMiddleware<{
     ctx: TRPCContextTransaction
 }>().create(({ ctx, next }) => next({
-    ctx: Match.value(ctx.transaction).pipe(
+    ctx: {
-        Match.tag("WebSocket", identity),
+        transaction: Match.value(ctx.transaction).pipe(
+            Match.tag("WebSocket", identity),
 
-        Match.orElse(() => {
+            Match.orElse(() => {
-            throw new TRPCError({
+                throw new TRPCError({
-                code: "BAD_REQUEST",
+                    code: "BAD_REQUEST",
-                message: "Only WebSocket transport is supported by this procedure",
+                    message: "Only WebSocket transport is supported by this procedure",
-            })
+                })
-        }),
+            }),
-    )
+        )
+    }
 }))))