Small fixes

Author: ovistoica

examples/src/simulflow_examples/twilio_websocket.clj

@@ -167,8 +167,9 @@
 
                ;; Activity monitor connections - basically check if there is
                ;; activity on the pipeline
-               [[:realtime-out :out] [:activity-monitor :in]]
-               [[:transcriptor :out] [:activity-monitor :in]]
+               [[:realtime-out :sys-out] [:activity-monitor :sys-in]]
+               [[:transcriptor :sys-out] [:activity-monitor :sys-in]]
+               [[:transport-in :sys-out] [:activity-monitor :sys-in]]
                [[:activity-monitor :out] [:context-aggregator :in]]
                [[:activity-monitor :out] [:tts :in]]]
               extra-conns)}))

src/simulflow/processors/elevenlabs.clj

@@ -181,17 +181,17 @@
         _ (t/log! {:level :debug :id :elevenlabs} "Connecting to TTS websocket")
         ws-conn @(ws/websocket url conf)]
     (vthread-loop []
-                  (when @alive?
-                    (when-let [msg (a/<!! ws-write)]
-                      (when @alive?
-                        (ws/send! ws-conn msg))
-                      (recur))))
+      (when @alive?
+        (when-let [msg (a/<!! ws-write)]
+          (when @alive?
+            (ws/send! ws-conn msg))
+          (recur))))
     (vthread-loop []
-                  (when @alive?
-                    (a/<!! (a/timeout 3000))
-                    (t/log! {:level :debug :id :elevenlabs} "Sending keep-alive message")
-                    (ws/send! ws-conn keep-alive-message)
-                    (recur)))
+      (when @alive?
+        (a/<!! (a/timeout 3000))
+        (t/log! {:level :debug :id :elevenlabs} "Sending keep-alive message")
+        (ws/send! ws-conn keep-alive-message)
+        (recur)))
     (into args
           {:websocket/conn ws-conn
            :websocket/alive? alive?