Clojurians Log v2

(def end-call-judge
  "Process that judges when the AI should end the call."
  (flow/process
    {:describe (fn [] {:ins {:in "Channel for frames containing what the assistant is saying"}
                       :params {:openai/api-key "Api key for llm"
                                :end-phrases "Dictionary of phrases that when the assistant says, the call should be ended"}})

     :init
     (fn [params]
       (let [llm-write (a/chan 100)
             end-time-speech (atom nil)
             end-call-f (atom (:end-call-f params))
             total-assistant-messages (atom "")
             write-to-llm
             #(loop []
                ;; ‼️ IMPORTANT: Errors in this loop are not reported on `flow` `error-chan`
                (when-let [frame (a/ (openai/normal-chat-completion
                                                        {:api-key (:openai/api-key params)
                                                         :messages [{:role :system
                                                                     :content (str "You are a ending call judge. You will oversee the output of an LLM assistant and judge when the call should be ended. When the assistant says any of the end-call phrases you should end the call. Here are the end-call phrases: " (str/join ", " (:end-phrases params)))}
                                                                    {:role :user
                                                                     :content (str "Assistant message:" @total-assistant-messages)}]
                                                         :response-format response-format})
                                                       :body
                                                       u/parse-if-json
                                                       content
                                                       u/parse-if-json)]

                          (t/log! :debug ["SHOULD END " should_end "FOR " @total-assistant-messages])
                          (if should_end
                            (let [now (mono-time)
                                  diff (- @end-time-speech now)]
                              (t/log! :debug ["ENDING CALL IN " diff "FOR " @total-assistant-messages])
                              (a/