0.1.20 (#21)

Co-authored-by: Julien Valverdé <julien.valverde@mailo.com>
Reviewed-on: #21

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*() {
+    const t = yield* TRPCBuilder
+
+    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,7 +9,8 @@ export const ExpressOnly = importTRPCServer.pipe(Effect.map(({
 }) => experimental_standaloneMiddleware<{
     ctx: TRPCContextTransaction
 }>().create(({ ctx, next }) => next({
-    ctx: Match.value(ctx.transaction).pipe(
+    ctx: {
+        transaction: Match.value(ctx.transaction).pipe(
             Match.tag("Express", identity),
 
             Match.orElse(() => {
@@ -19,4 +20,5 @@ export const ExpressOnly = importTRPCServer.pipe(Effect.map(({
                 })
             }),
         )
+    }
 }))))

src/TRPC/middlewares/WebSocketOnly.ts

@@ -9,7 +9,8 @@ export const WebSocketOnly = importTRPCServer.pipe(Effect.map(({
 }) => experimental_standaloneMiddleware<{
     ctx: TRPCContextTransaction
 }>().create(({ ctx, next }) => next({
-    ctx: Match.value(ctx.transaction).pipe(
+    ctx: {
+        transaction: Match.value(ctx.transaction).pipe(
             Match.tag("WebSocket", identity),
 
             Match.orElse(() => {
@@ -19,4 +20,5 @@ export const WebSocketOnly = importTRPCServer.pipe(Effect.map(({
                 })
             }),
         )
+    }
 }))))