Blog.Controllers.ts

import { matchFor } from "api/lib/matchFor"
import { BlogPostRepo, Events, forkOperationWithEffect, Operations, UserRepo } from "api/services"
import { Duration, Effect, Schedule } from "effect"
import { NonNegativeInt } from "effect-app/schema"
import { BlogPost } from "models/Blog"
import { BlogRsc } from "resources"
import { BogusEvent } from "resources/Events"

const blog = matchFor(BlogRsc)

export default blog.controllers({
  FindPost: blog.FindPost((req) =>
    BlogPostRepo
      .find(req.id)
      .andThen((_) => _.value ?? null)
  ),

  GetPosts: blog.GetPosts(
    BlogPostRepo
      .all
      .andThen((items) => ({ items }))
  ),

  CreatePost: blog.CreatePost((req) =>
    UserRepo
      .getCurrentUser
      .andThen((author) => (new BlogPost({ ...req, author }, true)))
      .tap(BlogPostRepo.save)
  ),

  PublishPost: blog.PublishPost((req) =>
    Effect.gen(function*($) {
      const post = yield* $(BlogPostRepo.get(req.id))

      console.log("publishing post", post)

      const targets = [
        "google",
        "twitter",
        "facebook"
      ]

      const done: string[] = []

      const operationId = yield* $(
        forkOperationWithEffect(
          (opId) =>
            Operations
              .update(opId, {
                total: NonNegativeInt(targets.length),
                completed: NonNegativeInt(done.length)
              })
              .andThen(targets
                .forEachEffect((_) =>
                  Effect
                    .sync(() => done.push(_))
                    .tap(() =>
                      Operations.update(opId, {
                        total: NonNegativeInt(targets.length),
                        completed: NonNegativeInt(done.length)
                      })
                    )
                    .pipe(Effect.delay(Duration.seconds(4)))
                ))
              .andThen(() => "the answer to the universe is 41"),
          // while operation is running...
          (_opId) =>
            Effect
              .suspend(() => Events.publish(new BogusEvent()))
              .pipe(Effect.schedule(Schedule.spaced(Duration.seconds(1))))
        )
      )

      return operationId
    })
  )
})