From 546c14e841b2d5b30625f093fd06ad8095850b56 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Mon, 1 Jul 2024 19:19:20 +0200
Subject: [PATCH] tRPC work

---
 packages/common/src/rpc/index.ts | 11 +++++++++++
 packages/server/src/trpc.ts      | 21 +++++++++++++++++++++
 2 files changed, 32 insertions(+)

diff --git a/packages/common/src/rpc/index.ts b/packages/common/src/rpc/index.ts
index e69de29..7cc37f9 100644
--- a/packages/common/src/rpc/index.ts
+++ b/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,
+    {},
+) {}
diff --git a/packages/server/src/trpc.ts b/packages/server/src/trpc.ts
index e69de29..b89dd61 100644
--- a/packages/server/src/trpc.ts
+++ b/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 () => {
+
+        })
+    })
+})