working api insert into database

Author: SandroMaglione

apps/server/package.json

@@ -5,7 +5,7 @@
   "main": "main.js",
   "scripts": {
     "typecheck": "tsc",
-    "dev": "tsx src/main.ts"
+    "dev": "tsx watch src/main.ts"
   },
   "keywords": [],
   "author": "",

apps/server/src/database.ts

@@ -0,0 +1,10 @@
+import { PgClient } from "@effect/sql-pg";
+import { Config } from "effect";
+
+export const DatabaseLive = PgClient.layerConfig({
+  password: Config.redacted("POSTGRES_PW"),
+  username: Config.succeed("postgres"),
+  database: Config.succeed("postgres"),
+  host: Config.succeed("localhost"),
+  port: Config.succeed(5435),
+});

apps/server/src/main.ts

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

apps/server/src/migration.ts

@@ -0,0 +1,13 @@
+import { NodeContext } from "@effect/platform-node";
+import { PgMigrator } from "@effect/sql-pg";
+import { Layer } from "effect";
+import { fileURLToPath } from "node:url";
+import { DatabaseLive } from "./database";
+
+export const MigratorLive = PgMigrator.layer({
+  // Where to put the `_schema.sql` file
+  schemaDirectory: "src/migrations",
+  loader: PgMigrator.fromFileSystem(
+    fileURLToPath(new URL("migrations", import.meta.url))
+  ),
+}).pipe(Layer.provide([DatabaseLive, NodeContext.layer]));

apps/server/src/migrator.ts

@@ -1,11 +1,29 @@
 import { HttpApiBuilder } from "@effect/platform";
-import { Example, ServerApi } from "@local/api";
-import { Effect } from "effect";
+import { SqlClient, SqlResolver } from "@effect/sql";
+import { ServerApi, User } from "@local/api";
+import { Effect, Layer, Schema } from "effect";
+import { DatabaseLive } from "./database";
 
 export const RestApiLive = HttpApiBuilder.group(ServerApi, "rest", (handlers) =>
-  handlers.handle("example", () =>
+  handlers.handle("create-user", ({ payload }) =>
     Effect.gen(function* () {
-      return new Example({ id: crypto.randomUUID(), name: "example" });
-    })
+      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)
+    )
   )
-);
+).pipe(Layer.provide(DatabaseLive));

apps/server/src/rest.ts

@@ -1,15 +1,17 @@
 import { HttpApi, HttpApiEndpoint, HttpApiGroup } from "@effect/platform";
 import { Schema } from "effect";
 
-export class Example extends Schema.Class<Example>("Example")({
-  id: Schema.UUID,
+export class User extends Schema.Class<User>("User")({
+  id: Schema.Number,
   name: Schema.String,
+  created_at: Schema.DateFromSelf,
 }) {}
 
 class RestGroup extends HttpApiGroup.make("rest").add(
-  HttpApiEndpoint.get("example")`/example`
+  HttpApiEndpoint.post("create-user")`/user/create`
+    .setPayload(Schema.Struct({ name: Schema.String }))
     .addError(Schema.String)
-    .addSuccess(Example)
+    .addSuccess(User)
 ) {}
 
 export class ServerApi extends HttpApi.make("server-api").add(RestGroup) {}