✨ Add queue

Author: oschrenk

Sources/Cli/Watch.swift

@@ -10,15 +10,8 @@ struct Watch: ParsableCommand {
   )
 
   mutating func run() {
-    StdOut.print("111")
-    print("111a")
-    let repo = EventRepo()
-    StdOut.print("222")
-    print("bbb")
     let config = Loader.readConfig()
-    StdOut.print("\(String(describing: config))")
-    let hooks = config?.hooks ?? []
-    repo.registerForEventStoreChanges(hooks: hooks)
+    EventRepo().registerForEventStoreChanges(hooks: config?.hooks ?? [])
     dispatchMain()
   }
 }

Sources/IO/EventRepo.swift

@@ -4,6 +4,8 @@ final class EventRepo {
   private let eventStore = EKEventStore()
   private var hooks: [Hook] = []
 
+  let eventQueue = DispatchQueue(label: "com.oschrenk.plan")
+
   private func grantAccess() -> EKEventStore {
     if #available(macOS 14, *) {
       self.eventStore.requestFullAccessToEvents { granted, maybeError in
@@ -95,26 +97,25 @@ final class EventRepo {
   }
 
   func registerForEventStoreChanges(hooks: [Hook]) {
-    self.hooks = hooks
     NotificationCenter.default.addObserver(
-      self,
-      selector: #selector(eventStoreChanged(_:)),
-      name: .EKEventStoreChanged,
-      object: nil // Listen to all EKEventStore changes
-    )
-  }
-
-  @objc private func eventStoreChanged(_: Notification) {
-    for hook in hooks {
-      hook.trigger()
+      forName: .EKEventStoreChanged,
+      object: nil,
+      queue: nil
+    ) { _ in
+      print("d")
+      self.eventQueue.async {
+        for hook in hooks {
+          hook.trigger()
+        }
+      }
     }
   }
 
   deinit {
     NotificationCenter.default.removeObserver(
       self,
       name: .EKEventStoreChanged,
-      object: eventStore
+      object: nil
     )
   }
 }