select api endpoint

Author: SandroMaglione

apps/server/src/rest.ts

@@ -1,29 +1,46 @@
 import { HttpApiBuilder } from "@effect/platform";
 import { SqlClient, SqlResolver } from "@effect/sql";
 import { ServerApi, User } from "@local/api";
-import { Effect, Layer, Schema } from "effect";
+import { Effect, flow, Function, Layer, Schema } from "effect";
 import { DatabaseLive } from "./database";
 
 export const RestApiLive = HttpApiBuilder.group(ServerApi, "rest", (handlers) =>
-  handlers.handle("create-user", ({ payload }) =>
-    Effect.gen(function* () {
-      const sql = yield* SqlClient.SqlClient;
+  handlers
+    .handle("create-user", ({ payload }) =>
+      Effect.gen(function* () {
+        const sql = yield* SqlClient.SqlClient;
 
-      const InsertPerson = yield* SqlResolver.ordered("InsertPerson", {
-        Request: User.pipe(Schema.omit("id", "created_at")),
-        Result: User,
-        execute: (requests) =>
-          sql`
-        INSERT INTO "user"
-        ${sql.insert(requests)}
-        RETURNING *
-      `,
-      });
+        const InsertPerson = yield* SqlResolver.ordered("InsertPerson", {
+          Request: User.pipe(Schema.omit("id", "created_at")),
+          Result: User,
+          execute: (requests) =>
+            sql`INSERT INTO "user" ${sql.insert(requests)} RETURNING *`,
+        });
 
-      return yield* InsertPerson.execute({ name: payload.name });
-    }).pipe(
-      Effect.tapError(Effect.logError),
-      Effect.mapError((error) => error.message)
+        return yield* InsertPerson.execute({ name: payload.name });
+      }).pipe(
+        Effect.tapError(Effect.logError),
+        Effect.mapError((error) => error.message)
+      )
+    )
+    .handle("get-user", ({ path }) =>
+      Effect.gen(function* () {
+        const sql = yield* SqlClient.SqlClient;
+
+        const GetById = yield* SqlResolver.findById("GetUserById", {
+          Id: Schema.Number,
+          Result: User,
+          ResultId: (_) => _.id,
+          execute: (ids) =>
+            sql`SELECT * FROM "user" WHERE ${sql.in("id", ids)}`,
+        });
+
+        const getById = flow(GetById.execute, Effect.withRequestCaching(true));
+
+        return yield* getById(path.id).pipe(Effect.flatMap(Function.identity));
+      }).pipe(
+        Effect.tapError(Effect.logError),
+        Effect.mapError((error) => error.message)
+      )
     )
-  )
 ).pipe(Layer.provide(DatabaseLive));

packages/api/src/main.ts

@@ -1,4 +1,9 @@
-import { HttpApi, HttpApiEndpoint, HttpApiGroup } from "@effect/platform";
+import {
+  HttpApi,
+  HttpApiEndpoint,
+  HttpApiGroup,
+  HttpApiSchema,
+} from "@effect/platform";
 import { Schema } from "effect";
 
 export class User extends Schema.Class<User>("User")({
@@ -7,11 +12,19 @@ export class User extends Schema.Class<User>("User")({
   created_at: Schema.DateFromSelf,
 }) {}
 
-class RestGroup extends HttpApiGroup.make("rest").add(
-  HttpApiEndpoint.post("create-user")`/user/create`
-    .setPayload(Schema.Struct({ name: Schema.String }))
-    .addError(Schema.String)
-    .addSuccess(User)
-) {}
+class RestGroup extends HttpApiGroup.make("rest")
+  .add(
+    HttpApiEndpoint.post("create-user")`/user/create`
+      .setPayload(Schema.Struct({ name: Schema.String }))
+      .addError(Schema.String)
+      .addSuccess(User)
+  )
+  .add(
+    HttpApiEndpoint.get(
+      "get-user"
+    )`/user/get/${HttpApiSchema.param("id", Schema.NumberFromString)}`
+      .addError(Schema.String)
+      .addSuccess(User)
+  ) {}
 
 export class ServerApi extends HttpApi.make("server-api").add(RestGroup) {}