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", + 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 = ( + program: Effect.Effect +) => Effect.gen(function*() { + const runFork = yield* FiberSet.makeRuntime() + +}) + + +const testRouter = Effect.gen(function*() { + return t.router({ + test: t.procedure.query(async () => { + + }) + }) +})