Added deref timeouts. Adjusted sleeps.

In order to make the tests more resilient, added timeouts to derefs so
that the tests would not hang.

Adjusted the sleeps so that there was a better chance that the tests
would not be flaky.

Author: bombaywalla

test/eca/features/chat_test.clj

@@ -258,15 +258,16 @@
             :call-tool-mock
             ;; Ensure that the tools complete in the 3-2-1 order by adjusting sleep times
             (fn [name & _others]
+              ;; When this is called, we are already in a future.
               (case name
 
                 "ro_tool_1"
-                (do (deep-sleep 300)
+                (do (deep-sleep 900)
                     {:error false
                      :contents [{:type :text :content "RO tool call 1 result"}]})
 
                 "ro_tool_2"
-                (do (deep-sleep 200)
+                (do (deep-sleep 600)
                     {:error false
                      :contents [{:type :text :content "RO tool call 2 result"}]})
 
@@ -347,8 +348,9 @@
                 (on-prepare-tool-call {:id "call-1" :name "ro_tool_1" :arguments-text ""})
                 (on-prepare-tool-call {:id "call-2" :name "ro_tool_2" :arguments-text ""})
                 (on-prepare-tool-call {:id "call-3" :name "ro_tool_3" :arguments-text ""})
-                (future (Thread/sleep 200)
-                        (deref wait-for-tool3)
+                (future (Thread/sleep 400)
+                        (when (= :timeout (deref wait-for-tool3 10000 :timeout))
+                          (println "tool-calls-with-prompt-stop-test: deref in prompt stop future timed out"))
                         (Thread/sleep 50)
                         (f.chat/prompt-stop {:chat-id chat-id} (h/db*) (h/messenger) (h/metrics))
                         (deliver wait-for-stop true))
@@ -357,23 +359,26 @@
                                   {:id "call-3" :name "ro_tool_3" :arguments {}}])))
             :call-tool-mock
             (fn [name & _others]
+              ;; When this is called, we are already in a future
               (case name
 
                 "ro_tool_1"
-                (do (deep-sleep 350)
-                    (deref wait-for-tool2)
+                (do (deep-sleep 1000)
+                    (when (= :timeout (deref wait-for-tool2 10000 :timeout))
+                      (println "tool-calls-with-prompt-stop-test: deref in tool 1 timed out"))
                     {:error false
                      :contents [{:type :text :content "RO tool call 1 result"}]})
 
                 "ro_tool_2"
-                (do (deep-sleep 300)
-                    (deref wait-for-stop)
+                (do (deep-sleep 800)
+                    (when (= :timeout (deref wait-for-stop 10000 :timeout))
+                      (println "tool-calls-with-prompt-stop-test: deref in tool 2 timed out"))
                     (deliver wait-for-tool2 true)
                     {:error false
                      :contents [{:type :text :content "RO tool call 2 result"}]})
 
                 "ro_tool_3"
-                (do (deep-sleep 100)
+                (do (deep-sleep 200)
                     (deliver wait-for-tool3 true)
                     {:error false
                      :contents [{:type :text :content "RO tool call 3 result"}]})))})]