Implement proper BlogPostRepo

Author: patroza

_project/api/_src/Usecases/Blog.Controllers.ts

@@ -1,7 +1,6 @@
 import { BlogPost } from "@effect-app-boilerplate/models/Blog"
 import { BlogRsc } from "@effect-app-boilerplate/resources"
 import { BogusEvent } from "@effect-app-boilerplate/resources/Events"
-import { NotFoundError } from "api/errors.js"
 import { BlogPostRepo, Events, Operations } from "api/services.js"
 
 const blog = matchFor(BlogRsc)
@@ -32,11 +31,9 @@ const PublishPost = blog.PublishPost(
   { BlogPostRepo, Events, Operations },
   (req, { blogPostRepo, events, operations }) =>
     Do(($) => {
-      $(
-        blogPostRepo
-          .find(req.id)
-          .flatMap((_) => _.encaseInEffect(() => new NotFoundError({ type: "BlogPost", id: req.id })))
-      )
+      const post = $(blogPostRepo.get(req.id))
+
+      console.log("publishing post", post)
 
       const targets = [
         "google",

_project/api/_src/api.ts

@@ -14,7 +14,7 @@ import { createServer } from "node:http"
 import { MergedConfig } from "./config.js"
 import * as MW from "./middleware/index.js"
 import { RequestContextMiddleware } from "./middleware/RequestContextMiddleware.js"
-import { BlogPostRepoLive, Operations, UserRepo } from "./services.js"
+import { BlogPostRepo, Operations, UserRepo } from "./services.js"
 import { Events } from "./services/Events.js"
 
 export const devApi = MergedConfig
@@ -87,6 +87,6 @@ export const api = App.provide(
       RequestContextContainer.live,
       HttpClientNode.client.layer,
       UserRepo.Live,
-      BlogPostRepoLive
+      BlogPostRepo.Live
     )
 )

_project/api/_src/services/DBContext/BlogPostRepo.ts

@@ -1,25 +1,43 @@
 import { BlogPost, BlogPostId } from "@effect-app-boilerplate/models/Blog"
+import { RepositoryDefaultImpl } from "@effect-app/infra/services/RepositoryBase"
+import { RepoLive } from "api/migrate.js"
 
-export interface BlogPostRepo {
-  all: Effect<never, never, readonly BlogPost[]>
-  find: (id: BlogPostId) => Effect<never, never, Option<BlogPost>>
-  save: (post: BlogPost) => Effect<never, never, void>
+export interface BlogPostPersistenceModel extends BlogPost.From {
+  _etag: string | undefined
 }
-export const BlogPostRepo = Tag<BlogPostRepo>()
 
-export const BlogPostRepoLive = Layer
-  .sync(BlogPostRepo, () => {
-    const items: BlogPost[] = [
-      new BlogPost({
-        id: BlogPostId("post-test123"),
-        title: NonEmptyString255("Test post"),
-        body: NonEmptyString2k("imma test body")
-      })
-    ]
+export type BlogPostSeed = "sample" | ""
 
-    return {
-      all: Effect.sync(() => [...items]),
-      find: (id) => Effect.sync(() => items.findFirst((_) => _.id === id)),
-      save: (post) => Effect.sync(() => items.push(post))
-    }
+/**
+ * @tsplus type BlogPostRepo
+ * @tsplus companion BlogPostRepo.Ops
+ */
+export class BlogPostRepo extends RepositoryDefaultImpl<BlogPostRepo>()<BlogPostPersistenceModel>()(
+  "BlogPost",
+  BlogPost
+) {}
+
+/**
+ * @tsplus static BlogPostRepo.Ops Live
+ */
+export const LiveBlogPostRepo = Effect
+  .sync(() => {
+    const seed = "sample"
+    const makeInitial = Effect.sync(() => {
+      const items = seed === "sample"
+        ? [
+          new BlogPost({
+            id: BlogPostId("post-test123"),
+            title: NonEmptyString255("Test post"),
+            body: NonEmptyString2k("imma test body")
+          })
+        ] as const
+        : []
+      return items
+    })
+    return BlogPostRepo
+      .makeWith({ makeInitial }, (_) => new BlogPostRepo(_))
+      .toLayer(BlogPostRepo)
   })
+  .unwrapLayer
+  .provide(RepoLive)