Small updates

Author: ovistoica

src/simulflow/transport.clj

@@ -6,7 +6,8 @@
    [simulflow.transport.in :as in]
    [simulflow.transport.out :as out]
    [simulflow.utils.audio :as audio]
-   [simulflow.utils.core :as u :refer [defaliases]]))
+   [simulflow.utils.core :as u :refer [defaliases]]
+   [taoensso.telemere :as t]))
 
 ;; =============================================================================
 ;; Processors
@@ -68,6 +69,11 @@
                                                :channels 1 ; PCM is mono
                                                :sample-size-bits 16 ; PCM is 16-bit
                                                :duration-ms duration-ms})]
+       (t/log! {:id :audio-splitter
+                :msg "Received audio output. Splitting into chunks"
+                :level :debug
+                :data {:sample-rate sample-rate
+                       :chunk-size chunk-size}})
        (if-let [chunks (split-audio-into-chunks audio chunk-size)]
          ;; Create new frames preserving the sample rate from original frame
          [state {:out (mapv (fn [chunk-audio]

src/simulflow/transport/in.clj

@@ -25,7 +25,7 @@
 
 (defn log-vad-state!
   [prev-vad-state vad-state]
-  (when (not= prev-vad-state vad-state)
+  (when (and prev-vad-state vad-state (not= prev-vad-state vad-state))
     (t/log! {:level :debug
              :id :transport-in
              :msg "Changed vad state"

src/simulflow/transport/out.clj

@@ -57,6 +57,7 @@
     ;; Audio writer process - handles only audio I/O side effects and lazy line opening
     (vthread-loop []
       (when-let [audio-command (<!! audio-write-ch)]
+        (t/log! {:level :debug :id :speakers-out :msg "Playing audio chunk" :data audio-command})
         (when (= (:command audio-command) :write-audio)
           (let [current-time (u/mono-time)
                 delay-until (:delay-until audio-command 0)
@@ -70,6 +71,7 @@
                            new-line))]
             (when (pos? wait-time)
               (<!! (timeout wait-time)))
+
             (sound/write! (:data audio-command) line 0)))
         (recur)))
 
@@ -163,6 +165,7 @@
   [{:keys [transport/serializer] :as state
     ::keys [last-send-time sending-interval]
     :or {last-send-time 0}} frame now]
+  (t/log! {:level :debug :id :speakers-out :sample 0.01 :msg "Received playback frame" :data (dissoc (:frame/data frame) :audio)})
   (let [should-emit-start? (not (::speaking? state))
         maybe-next-send (+ last-send-time sending-interval)
         next-send-time (if (>= now maybe-next-send) now maybe-next-send)
@@ -196,8 +199,7 @@
     :or {now (u/mono-time)}} input-port frame]
   (cond
     ;; Handle incoming audio frames - core business logic moved here
-    (and (= input-port :in)
-         (frame/audio-output-raw? frame))
+    (frame/audio-output-raw? frame)
     (process-realtime-out-audio-frame state frame now)
 
     (and (= input-port :timer-out)

test/simulflow/transport/out_test.clj

@@ -28,7 +28,12 @@
                  ::sut/sending-interval 20}
           frame (frame/audio-output-raw {:audio (byte-array [1 2 3]) :sample-rate 24000})
           current-time 2000
-          [new-state output] (sut/process-realtime-out-audio-frame state frame current-time)]
+          [new-state output] (sut/process-realtime-out-audio-frame state frame current-time)
+          command (first (:audio-write output))]
+      (is (= (update command :data vec) {:command :write-audio
+                                         :data [1, 2, 3]
+                                         :delay-until 2000
+                                         :sample-rate 24000}))
 
       (is (true? (::sut/speaking? new-state)))
       (is (= 1 (count (:audio-write output))))