From 04f953bc2853309c2acbf10254743fc543444c52 Mon Sep 17 00:00:00 2001
From: Jake Zerrer <him@jakezerrer.com>
Date: Tue, 9 Dec 2025 15:21:15 -0500
Subject: Add error logging

---
 src/unheard/midi.clj | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

(limited to 'src/unheard/midi.clj')

diff --git a/src/unheard/midi.clj b/src/unheard/midi.clj
index f0debad..c5cf925 100644
--- a/src/unheard/midi.clj
+++ b/src/unheard/midi.clj
@@ -31,6 +31,7 @@
                   (m/amb))
               (m/?< >devices)
               (try (m/? m/never)
+                   (catch Exception e (println "EEE" e) (throw e))
                    (finally
                      (m/? (m/via
                             m/blk
@@ -69,6 +70,7 @@
                         :id :midi/device-opened,
                         :data {:device (str device)}})
              (m/? (tfn device))
+             (catch Exception e (println "EEE" e) (throw e))
              (finally (log/log! {:level :info, :id :midi/closing-device})
                       ;; NOTE:
                       ;; Be careful, (.close device) will wait for (.send
@@ -124,6 +126,7 @@
                                                  :data {:value (str v)}})
                                       v)
                                     (recur)))))))
+           (catch Exception e (println "EEE" e) (throw e))
            (finally (log/log! {:level :info, :id :midi/closing-tx})
                     (m/? (m/via m/blk (.close transmitter)))
                     (log/log! {:level :info, :id :midi/tx-closed}))))))
@@ -154,6 +157,7 @@
                                           (.send receiver v UNSCHEDULED-EVENT)))
                               (log/log! {:level :debug,
                                          :id :midi/send-returned})))))
+               (catch Exception e (println "EEE" e) (throw e))
                (finally (log/log! {:level :info, :id :midi/closing-rx})
                         (m/? (m/via m/blk (.close receiver)))
                         (log/log! {:level :info, :id :midi/rx-closed}))))))
@@ -281,10 +285,10 @@
               short-messages (atom nil)
               >short-messages (m/watch short-messages)]
           (m/amb= (do (reset! short-messages nil)
-                      (m/? (<bus device-name
-                                 (fn [v]
-                                   (m/ap (try
-                                           (let [msg (m/?< v)]
+                      (m/?
+                        (<bus device-name
+                              (fn [v]
+                                (m/ap (try (let [msg (m/?< v)]
                                              (reset! short-messages msg))
                                            (catch missionary.Cancelled c
                                              ;; When the upstream flow is
-- 
cgit v1.2.3