Add Websocket broadcast test

r_place_backend/project.clj

@@ -6,4 +6,5 @@
   :dependencies [[org.clojure/clojure "1.11.1"]
                  [compojure "1.7.1"]
                  [http-kit "2.8.0"]]
+  :profiles {:dev {:dependencies [[stylefruits/gniazdo "1.2.2"]]}}
   :repl-options {:init-ns r-place-backend.core})

r_place_backend/test/r_place_backend/core_test.clj

@@ -1,7 +1,40 @@
 (ns r-place-backend.core-test
   (:require [clojure.test :refer :all]
+            [gniazdo.core :as ws]
             [r-place-backend.core :refer :all]))
 
 (deftest a-test
   (testing "FIXME, I fail."
     (is (= 0 1))))
+
+
+(comment
+
+  ;; @TODO Server setup for test
+  (let [b-socket (ws/connect
+                     "ws://localhost:8080/ws"
+                     :on-receive #(prn 'received %))
+        socket-xs (mapv (fn [_]
+                          (let [a (atom nil)]
+                            {:socket (ws/connect
+                                         "ws://localhost:8080/ws"
+                                         :on-receive #(reset! a %))
+                             :data-received a}))
+                        (range 10))
+        test-data {:column (rand-int 20)
+                   :row (rand-int 20), 
+                   :color (rand-nth ["red" "blue" "green" "cyan"])}]
+    (ws/send-msg b-socket (pr-str test-data))
+
+    (ws/close b-socket)
+    (doseq [s (map :socket socket-xs)]
+      (ws/close s))
+
+    (every? (fn [x]
+              (= (read-string x)
+                 ["pixel" test-data]))
+            (map (comp deref :data-received)
+                 socket-xs)))
+  ;; Setup multiple connections to listen to the broadcast
+  ;; Assert that the broadcast is successful
+  )