websocket.clj

(defn websocket-effect
  [{:keys [uri on-message on-error on-success on-failure websocket]}]
  (if websocket
    (rf/dispatch (conj on-success websocket))
    (let [websocket (js/WebSocket. uri)]
      (log/info "Starting new websocket.")
      (set! (.-onmessage websocket) #(rf/dispatch (conj on-message %)))
      (set! (.-onerror websocket) #(rf/dispatch (conj on-failure %)))
      (set! (.-onopen websocket) (fn on-open []
                                   (set! (.-onerror websocket) #(rf/dispatch (conj on-error %)))
                                   (rf/dispatch (conj on-success websocket)))))))

(defn websocket-message-effect
  [{:keys [websocket message]}]
  (if websocket
    (.send websocket message)
    (throw (js/Error. "No websocket provided."))))

(rf/reg-fx :websocket websocket-effect)
(rf/reg-fx :websocket-message websocket-effect)