streaing functions moved into threads

Author: slimslenderslacks

.gitignore

@@ -26,3 +26,4 @@
 .idea
 /catalog.updated.yaml
 claude_desktop_config.json
+/set-secrets.sh

dev/containers.clj

@@ -0,0 +1,19 @@
+(ns containers
+  (:require [docker]))
+
+(->> (docker/containers {})
+     (map #(select-keys % [:Names :Status :State :Id :Image])))
+
+'(:Ports
+  :Image
+  :Labels
+  :Id
+  :Mounts
+  :HostConfig
+  :Command
+  :ImageID
+  :Names
+  :State
+  :Created
+  :NetworkSettings
+  :Status)

docs/content/tools/docs/namespaces.png

@@ -380,7 +380,6 @@
        (string/join " ; ")))
 
 (defn get-secrets [{:keys [secrets]}]
-  (logger/info (format "getting secrets %s" secrets))
   (->> secrets
        (map (fn [[k v]]
               [v (:value (secrets-get (name k)))]))
@@ -424,18 +423,22 @@
         finished-channel (async/promise-chan)]
     (start x)
 
-    (async/go
-      (try
-        (let [s (:body (attach-container-stream-stdout x))]
-          (doseq [line (line-seq (java.io.BufferedReader. (java.io.InputStreamReader. s)))]
-            (cb line)))
-        (catch Throwable e
-          (println e))))
+    (.start ^Thread
+     (Thread.
+      (fn []
+        (try
+          (let [s (:body (attach-container-stream-stdout x))]
+            (doseq [line (line-seq (java.io.BufferedReader. (java.io.InputStreamReader. s)))]
+              (cb line)))
+          (catch Throwable e
+            (logger/error "run-streaming-function" e))))))
 
     ;; watch the container
-    (async/go
-      (wait x)
-      (async/>! finished-channel {:done :exited}))
+    (.start ^Thread
+     (Thread.
+      (fn []
+        (wait x)
+        (async/put! finished-channel {:done :exited}))))
 
     {:container x
      ;; stopped channel

src/docker.clj

@@ -60,29 +60,28 @@
         :unknown)
       (recur (async/<! debounced)))
     ;; watch filesystem
-    (async/thread
-      (let [{x :container}
-            (docker/run-streaming-function-with-no-stdin
-             {:image "vonwig/inotifywait:latest"
-              :labels {"com.docker.desktop.service" "true"}
-              :volumes ["docker-prompts:/prompts"]
-              :command ["-e" "create" "-e" "modify" "-e" "delete" "-q" "-m" "/prompts"]}
-             (fn [line]
-               (let [[_dir _event f] (string/split line #"\s+")]
-                 (async/>!!
-                  change-events-channel
-                  (cond
-                    (= f "registry.yaml")
-                    {:opts opts :f f :type :registry}
-                    (string/ends-with? f ".md")
-                    {:opts opts :f f :type :markdown}
-                    :else
-                    {})))))]
-        (shutdown/schedule-container-shutdown
-         (fn []
-           (logger/info "inotifywait shutting down")
-           (docker/kill-container x)
-           (docker/delete x)))))))
+    (let [{x :container}
+          (docker/run-streaming-function-with-no-stdin
+           {:image "vonwig/inotifywait:latest"
+            :labels {"com.docker.desktop.service" "true"}
+            :volumes ["docker-prompts:/prompts"]
+            :command ["-e" "create" "-e" "modify" "-e" "delete" "-q" "-m" "/prompts"]}
+           (fn [line]
+             (let [[_dir _event f] (string/split line #"\s+")]
+               (async/put!
+                change-events-channel
+                (cond
+                  (= f "registry.yaml")
+                  {:opts opts :f f :type :registry}
+                  (string/ends-with? f ".md")
+                  {:opts opts :f f :type :markdown}
+                  :else
+                  {})))))]
+      (shutdown/schedule-container-shutdown
+       (fn []
+         (logger/info "inotifywait shutting down")
+         (docker/kill-container x)
+         (docker/delete x))))))
 
 (comment
   (repl/setup-stdout-logger)