tRPC work

packages/common/src/rpc/index.ts

@@ -0,0 +1,11 @@
+import { Rpc } from "@effect/rpc"
+import { Schema as S } from "@effect/schema"
+import { JsonifiableTodo } from "../data"
+
+
+export class GetTodos extends Rpc.StreamRequest<GetTodos>()(
+    "GetTodos",
+    S.Never,
+    JsonifiableTodo,
+    {},
+) {}

packages/server/src/trpc.ts

@@ -0,0 +1,21 @@
+import { initTRPC } from "@trpc/server"
+import { Context, Effect, FiberSet } from "effect"
+
+
+export const t = initTRPC.create()
+
+export const run = <A, E, R>(
+    program: Effect.Effect<A, E, R>
+) => Effect.gen(function*() {
+    const runFork = yield* FiberSet.makeRuntime<R>()
+
+})
+
+
+const testRouter = Effect.gen(function*() {
+    return t.router({
+        test: t.procedure.query(async () => {
+
+        })
+    })
+})