From 467e5689ec6187f811afacc337d411863dc9e9ca Mon Sep 17 00:00:00 2001 From: Shoubhit Dash Date: Wed, 15 Apr 2026 04:57:18 +0530 Subject: feat(server): extract question handler factory --- packages/server/package.json | 3 ++- packages/server/src/api/index.ts | 3 ++- packages/server/src/api/question.ts | 37 +++++++++++++++++++++++++++++++++++++ packages/server/src/index.ts | 2 ++ 4 files changed, 43 insertions(+), 2 deletions(-) create mode 100644 packages/server/src/api/question.ts (limited to 'packages/server') diff --git a/packages/server/package.json b/packages/server/package.json index 3fc013310..ec4c325fd 100644 --- a/packages/server/package.json +++ b/packages/server/package.json @@ -10,7 +10,8 @@ "./definition": "./src/definition/index.ts", "./definition/api": "./src/definition/api.ts", "./definition/question": "./src/definition/question.ts", - "./api": "./src/api/index.ts" + "./api": "./src/api/index.ts", + "./api/question": "./src/api/question.ts" }, "files": [ "dist" diff --git a/packages/server/src/api/index.ts b/packages/server/src/api/index.ts index 336ce12bb..375e3584b 100644 --- a/packages/server/src/api/index.ts +++ b/packages/server/src/api/index.ts @@ -1 +1,2 @@ -export {} +export { makeQuestionHandler } from "./question.js" +export type { QuestionOps } from "./question.js" diff --git a/packages/server/src/api/question.ts b/packages/server/src/api/question.ts new file mode 100644 index 000000000..f72c37aa1 --- /dev/null +++ b/packages/server/src/api/question.ts @@ -0,0 +1,37 @@ +import { Effect, Schema } from "effect" +import { HttpApiBuilder } from "effect/unstable/httpapi" +import { QuestionReply, QuestionRequest, questionApi } from "../definition/question.js" + +export interface QuestionOps { + readonly list: () => Effect.Effect, never, R> + readonly reply: (input: { + requestID: string + answers: Schema.Schema.Type["answers"] + }) => Effect.Effect +} + +export const makeQuestionHandler = (ops: QuestionOps) => + HttpApiBuilder.group( + questionApi, + "question", + Effect.fn("QuestionHttpApi.handlers")(function* (handlers) { + const decode = Schema.decodeUnknownSync(Schema.Array(QuestionRequest)) + + const list = Effect.fn("QuestionHttpApi.list")(function* () { + return decode(yield* ops.list()) + }) + + const reply = Effect.fn("QuestionHttpApi.reply")(function* (ctx: { + params: { requestID: string } + payload: Schema.Schema.Type + }) { + yield* ops.reply({ + requestID: ctx.params.requestID, + answers: ctx.payload.answers, + }) + return true + }) + + return handlers.handle("list", list).handle("reply", reply) + }), + ) diff --git a/packages/server/src/index.ts b/packages/server/src/index.ts index d5bdb6c8d..67b82a0be 100644 --- a/packages/server/src/index.ts +++ b/packages/server/src/index.ts @@ -1,4 +1,6 @@ export { openapi } from "./openapi.js" +export { makeQuestionHandler } from "./api/question.js" export { api } from "./definition/api.js" export { questionApi, QuestionReply, QuestionRequest } from "./definition/question.js" export type { OpenApiSpec, ServerApi } from "./types.js" +export type { QuestionOps } from "./api/question.js" -- cgit v1.2.3