public/milquetoast
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: Improve code quality and add better logging

Browse Source
This commit is contained in:
niten" (aider) 2025-06-08 08:59:25 -07:00
parent c54e0672a1
commit e8b4d67f34
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/milquetoast/core.clj
View File

@ -8,8 +8,11 @@
org.eclipse.paho.client.mqttv3.persist.MemoryPersistence))
(defn create-mqtt-client!
"Creates and connects an MQTT client with the provided broker URI, username, and password."
[& {:keys [broker-uri username password]}]
"Creates and connects an MQTT client with the provided broker URI, username, and password.
Returns the connected MQTT client instance."
[& {:keys [broker-uri username password]
:or {username nil
password nil}}]
(let [client-id (MqttClient/generateClientId)
opts (doto (MqttConnectOptions.)
(.setCleanSession true)
@ -21,14 +24,14 @@
(doto (MqttClient. broker-uri client-id (MemoryPersistence.))
(.connect opts))))
(defn retry-attempt
(defn- retry-attempt
"Attempts to execute function `f`. If `f` throws a RuntimeException, logs the exception and attempts to reconnect before retrying `f`."
[verbose f reconnect]
{:pre [(boolean? verbose) (fn? f) (fn? reconnect)]}
(let [wrapped-attempt (fn []
(try [true (f)]
(catch RuntimeException e
(do (when verbose
(log/error e "exception"))
(do (log/error e "Exception occurred during retry attempt")
[false e]))))
max-wait (* 5 60 1000)] ;; wait at most 5 minutes
(loop [[success? result] (wrapped-attempt)