rename user api

Author: SandroMaglione

apps/server/src/main.ts

@@ -13,7 +13,7 @@ import { ServerApi } from "@local/api";
 import { Effect, Layer } from "effect";
 import { createServer } from "node:http";
 import { MigratorLive } from "./migrator";
-import { RestApiLive } from "./rest";
+import { UserGroupLive } from "./user";
 
 const EnvProviderLayer = Layer.unwrapEffect(
   PlatformConfigProvider.fromDotEnv(".env").pipe(
@@ -23,7 +23,7 @@ const EnvProviderLayer = Layer.unwrapEffect(
 );
 
 const MainApiLive = HttpApiBuilder.api(ServerApi).pipe(
-  Layer.provide([MigratorLive, RestApiLive]),
+  Layer.provide([MigratorLive, UserGroupLive]),
   Layer.provide(EnvProviderLayer)
 );
 

apps/server/src/rest.ts

@@ -0,0 +1,54 @@
+import { HttpApiBuilder } from "@effect/platform";
+import { SqlClient, SqlResolver } from "@effect/sql";
+import { ServerApi, User } from "@local/api";
+import { Effect, flow, Function, Layer, Schema } from "effect";
+import { DatabaseLive } from "./database";
+
+export const UserGroupLive = HttpApiBuilder.group(
+  ServerApi,
+  "user",
+  (handlers) =>
+    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 *`,
+          });
+
+          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));

apps/server/src/user.ts

@@ -12,7 +12,7 @@ export class User extends Schema.Class<User>("User")({
   created_at: Schema.DateFromSelf,
 }) {}
 
-class RestGroup extends HttpApiGroup.make("rest")
+class UserGroup extends HttpApiGroup.make("user")
   .add(
     HttpApiEndpoint.post("create-user")`/user/create`
       .setPayload(Schema.Struct({ name: Schema.String }))
@@ -27,4 +27,4 @@ class RestGroup extends HttpApiGroup.make("rest")
       .addSuccess(User)
   ) {}
 
-export class ServerApi extends HttpApi.make("server-api").add(RestGroup) {}
+export class ServerApi extends HttpApi.make("server-api").add(UserGroup) {}