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

fix: Remove unused imports and simplify core.clj

Browse Source
This commit is contained in:
niten
2025-06-08 08:59:23 -07:00
committed by niten
parent f6b8739f93
commit c54e0672a1
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/milquetoast/core.clj
+7 -6
View File
@@ -1,10 +1,11 @@
(ns milquetoast.core (ns milquetoast.core
(:require [clojure.core.async :as async :refer [go go-loop <! >! alts!! <!! timeout]] (:require [clojure.core.async :as async :refer [go >! alts!! <!! timeout]]
[clojure.data.json :as json] [clojure.data.json :as json]
[clojure.tools.logging :as log]) [clojure.tools.logging :as log]
[milquetoast.utils :refer [pipe json-parse-message]])
(:import [org.eclipse.paho.client.mqttv3 MqttClient MqttConnectOptions MqttMessage IMqttMessageListener] (:import [org.eclipse.paho.client.mqttv3 MqttClient MqttConnectOptions MqttMessage IMqttMessageListener]
org.eclipse.paho.client.mqttv3.persist.MemoryPersistence org.eclipse.paho.client.mqttv3.persist.MemoryPersistence))
java.time.Instant))
(defn create-mqtt-client! (defn create-mqtt-client!
"Creates and connects an MQTT client with the provided broker URI, username, and password." "Creates and connects an MQTT client with the provided broker URI, username, and password."
@@ -124,10 +125,10 @@
(add-channel! [_ chan] (add-channel! client chan)) (add-channel! [_ chan] (add-channel! client chan))
(subscribe-topic! [_ topic opts] (subscribe-topic! [_ topic opts]
(pipe (subscribe-topic! client topic opts) (pipe (subscribe-topic! client topic opts)
(map utils/json-parse-message))) (map json-parse-message)))
(get-topic! [_ topic opts] (get-topic! [_ topic opts]
(if-let [msg (get-topic! client topic opts)] (if-let [msg (get-topic! client topic opts)]
(utils/json-parse-message msg) (json-parse-message msg)
nil)) nil))
(get-topic-raw! [_ topic opts] (get-topic-raw! [_ topic opts]
(if-let [msg (get-topic! client topic opts)] (if-let [msg (get-topic! client topic opts)]