From d92cab7adb697252a51eb8dd54128398caabed2d Mon Sep 17 00:00:00 2001
From: "niten\" (aider)" <niten@fudo.org>
Date: Sun, 8 Jun 2025 08:29:08 -0700
Subject: [PATCH] feat: Add structured logging to client.clj using
 clojure.tools.logging

---
 src/milquetoast/client.clj | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/milquetoast/client.clj b/src/milquetoast/client.clj
index 7dbb096..4f6c0ab 100644
--- a/src/milquetoast/client.clj
+++ b/src/milquetoast/client.clj
@@ -1,7 +1,8 @@
 (ns milquetoast.client
   (:require [clojure.core.async :as async :refer [go go-loop <! >! alts!! <!! timeout]]
             [clojure.data.json :as json]
-            [clojure.core.async.impl.runtime])
+            [clojure.core.async.impl.runtime]
+            [clojure.tools.logging :as log])
   (:import [org.eclipse.paho.client.mqttv3 MqttClient MqttConnectOptions MqttMessage IMqttMessageListener]
            org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
            java.time.Instant))
@@ -35,7 +36,7 @@
               (println (format "attempt failed, attempting reconnect")))
             (reconnect)
             (when verbose
-              (println (format "sleeping %s ms" wait-ms)))
+              (log/debug (format "sleeping %s ms" wait-ms)))
             (<!! (timeout wait-ms))
             (recur (wrapped-attempt) (min (* wait-ms 1.25) max-wait)))))))
 
@@ -71,7 +72,7 @@
                    #(.reconnect client)))
   (stop! [_]
     (when verbose
-      (println
+      (log/info
        (str "stopping " (count @open-channels) " channels")))
     (doseq [chan @open-channels]
       (async/close! chan))