TodoRepository work

packages/server/src/TodoRepository.ts

@@ -1,9 +1,10 @@
 import { Todo } from "@todo-tests/common/data"
-import { Array, Context, Effect, Option, Ref, SubscriptionRef } from "effect"
+import { Array, Context, Data, Effect, Option, Ref, SubscriptionRef } from "effect"
 
 
 export class TodoRepository extends Context.Tag("TodoRepository")<TodoRepository, Ref.Ref<Todo[]>>() {}
 
+
 export class TodoRepositoryService {
     constructor(
         readonly ref: SubscriptionRef.SubscriptionRef<(Todo & { id: Option.Some<string> })[]>
@@ -14,29 +15,59 @@ export class TodoRepositoryService {
             Effect.map(Array.findFirst(todo => todo.id.value === id))
         )
     }
+
     getIndex(id: string) {
         return this.ref.get.pipe(
             Effect.map(Array.findFirstIndex(todo => todo.id.value === id))
         )
     }
 
-    add(todo: Todo & { id: Option.None<string> }) {
+    add(todo: Todo) {
-        return Ref.update(this.ref, todos =>
+        return Effect.gen(this, function*() {
+            if (Option.isSome(todo.id))
+                return yield* Effect.fail(new TodoHasID({ todo }))
+
+            yield* Ref.update(this.ref, todos =>
                 Array.append(todos, new Todo({
                     ...todo,
                     id: Option.some(""),
-            }))
+                }) as Todo & { id: Option.Some<string> })
             )
+        })
     }
 
-    update(todo: Todo & { id: Option.Some<string> }) {
+    update(todo: Todo) {
         return Effect.gen(this, function*() {
-            const index = yield* yield* this.getIndex(todo.id.value)
+            if (Option.isNone(todo.id))
-            yield* Ref.update(this.ref, Array.replace(index, todo))
+                return yield* Effect.fail(new TodoHasNoID({ todo }))
+
+            yield* Ref.update(this.ref, Array.replace(
+                yield* yield* this.getIndex(todo.id.value),
+                todo as Todo & { id: Option.Some<string> },
+            ))
+        })
+    }
+
+    remove(todo: Todo) {
+        return Effect.gen(this, function*() {
+            if (Option.isNone(todo.id))
+                return yield* Effect.fail(new TodoHasNoID({ todo }))
+
+            yield* Ref.update(this.ref, Array.remove(
+                yield* yield* this.getIndex(todo.id.value)
+            ))
         })
     }
 }
 
+export class TodoHasID extends Data.TaggedError("TodoHasID")<{
+    todo: Todo
+}> {}
+
+export class TodoHasNoID extends Data.TaggedError("TodoHasNoID")<{
+    todo: Todo
+}> {}
+
 
 export const createDefaultTodos = TodoRepository.pipe(Effect.flatMap(repo =>
     Ref.update(repo, todos =>