From abc8668d25d2f9f310bf54a44c7c49d649b013a3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Sat, 29 Jun 2024 16:56:11 +0200
Subject: [PATCH] TodoRepository work

---
 packages/server/src/TodoRepository.ts | 6 +++---
 packages/server/src/index.ts          | 4 +++-
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/packages/server/src/TodoRepository.ts b/packages/server/src/TodoRepository.ts
index b54052b..ea6fc66 100644
--- a/packages/server/src/TodoRepository.ts
+++ b/packages/server/src/TodoRepository.ts
@@ -1,5 +1,5 @@
 import { Todo } from "@todo-tests/common/data"
-import { Array, Context, Data, Effect, Layer, Option, Ref, SubscriptionRef } from "effect"
+import { Array, Context, Data, Effect, Equal, Layer, Option, Ref, SubscriptionRef } from "effect"
 import crypto from "node:crypto"
 
 
@@ -19,13 +19,13 @@ export class TodoRepositoryService {
 
     get(id: string) {
         return this.todos.get.pipe(
-            Effect.map(Array.findFirst(todo => todo.id.value === id))
+            Effect.map(Array.findFirst(todo => Equal.equals(todo.id.value, id)))
         )
     }
 
     getIndex(id: string) {
         return this.todos.get.pipe(
-            Effect.map(Array.findFirstIndex(todo => todo.id.value === id))
+            Effect.map(Array.findFirstIndex(todo => Equal.equals(todo.id.value, id)))
         )
     }
 
diff --git a/packages/server/src/index.ts b/packages/server/src/index.ts
index dbb5a04..5b3e3ce 100644
--- a/packages/server/src/index.ts
+++ b/packages/server/src/index.ts
@@ -1,6 +1,6 @@
 import { BunRuntime } from "@effect/platform-bun"
 import { Todo } from "@todo-tests/common/data"
-import { Array, Console, Effect, Stream } from "effect"
+import { Array, Console, Effect, Fiber, Stream } from "effect"
 import { TodoRepository, TodoRepositoryLive, createDefaultTodos } from "./TodoRepository"
 
 
@@ -27,6 +27,8 @@ const main = Effect.gen(function*() {
 
     yield* todos.update(secondTodoModified)
     // console.log(yield* todos.todos.get)
+
+    yield* Fiber.join(watcher)
 })
 
 const runnableMain = main.pipe(