enhance(rtc): add dev-mode? option in rtc-state

src/main/frontend/db/rtc/debug_ui.cljs

@@ -1,15 +1,16 @@
 (ns frontend.db.rtc.debug-ui
   "Debug UI for rtc module"
-  (:require [fipp.edn :as fipp]
+  (:require [cljs-bean.core :as bean]
+            [fipp.edn :as fipp]
+            [frontend.config :as config]
             [frontend.db :as db]
             [frontend.handler.user :as user]
+            [frontend.persist-db.browser :as db-browser]
             [frontend.state :as state]
             [frontend.ui :as ui]
             [frontend.util :as util]
-            [rum.core :as rum]
-            [frontend.persist-db.browser :as db-browser]
             [promesa.core :as p]
-            [cljs-bean.core :as bean]))
+            [rum.core :as rum]))
 
 (defonce debug-state (atom nil))
 
@@ -70,7 +71,9 @@
                            :on-click (fn []
                                        (let [token (state/get-auth-id-token)
                                              ^object worker @db-browser/*worker]
-                                         (.rtc-start worker (state/get-current-repo) token)))})
+                                         (.rtc-start worker (state/get-current-repo) token
+                                                     (and config/dev?
+                                                          (state/sub [:ui/developer-mode?])))))})
 
        [:div.my-2.flex
         [:div.mr-2 (ui/button (str "send pending ops")

src/main/frontend/db_worker.cljs

@@ -541,9 +541,9 @@
 
   ;; RTC
   (rtc-start
-   [this repo token]
+   [this repo token dev-mode?]
    (when-let [conn (worker-state/get-datascript-conn repo)]
-     (rtc-core/<start-rtc repo conn token)
+     (rtc-core/<start-rtc repo conn token dev-mode?)
      nil))
 
   (rtc-stop

src/main/frontend/worker/rtc/core.cljs

@@ -79,7 +79,8 @@
    [:toggle-auto-push-client-ops-chan :any]
    [:*auto-push-client-ops? :any]
    [:force-push-client-ops-chan :any]
-   [:counter :any]])
+   [:counter :any]
+   [:dev-mode? :boolean]])
 
 (def state-validator
   (let [validator (m/validator state-schema)]
@@ -932,7 +933,7 @@
 ;;                                    :block-uuids [page-block-uuid]})))))
 
 (defn init-state
-  [ws data-from-ws-chan repo token]
+  [ws data-from-ws-chan repo token dev-mode?]
   ;; {:post [(m/validate state-schema %)]}
   {:*rtc-state (atom :closed :validator rtc-state-validator)
    :*graph-uuid (atom nil)
@@ -947,7 +948,7 @@
    :*stop-rtc-loop-chan (atom nil)
    :force-push-client-ops-chan (chan (async/sliding-buffer 1))
    :*ws (atom ws)
-
+   :dev-mode? dev-mode?
    ;; used to trigger state watch
    :counter 0})
 
@@ -971,22 +972,23 @@
 
 ;; FIXME: token might be expired
 (defn <init-state
-  [repo token reset-*state?]
+  [repo token reset-*state? & {:keys [dev-mode?]
+                               :or {dev-mode? false}}]
   (go
     (let [data-from-ws-chan (chan (async/sliding-buffer 100))
           ws-opened-ch (chan)
           ws (ws/ws-listen token data-from-ws-chan ws-opened-ch)]
       (<! ws-opened-ch)
-      (let [state (init-state ws data-from-ws-chan repo token)]
+      (let [state (init-state ws data-from-ws-chan repo token dev-mode?)]
         (when reset-*state?
           (reset! *state state)
           (swap! *state update :counter inc))
         state))))
 
 (defn <start-rtc
-  [repo conn token]
+  [repo conn token dev-mode?]
   (go
-    (let [state (<! (<init-state repo token true))
+    (let [state (<! (<init-state repo token true {:dev-mode? dev-mode?}))
           state-for-asset-sync (asset-sync/init-state-from-rtc-state state)
           _ (reset! asset-sync/*asset-sync-state state-for-asset-sync)
           config (worker-state/get-config repo)]

src/test/frontend/worker/rtc/fixture.cljs

@@ -21,14 +21,14 @@
   []
   (let [data-from-ws-chan (chan (async/sliding-buffer 100))
         ws (rtc-mock/mock-websocket data-from-ws-chan)]
-    (assoc (rtc-core/init-state ws data-from-ws-chan test-helper/test-db-name-db-version "")
+    (assoc (rtc-core/init-state ws data-from-ws-chan test-helper/test-db-name-db-version "" true)
            :*auto-push-client-ops? (atom false))))
 
 (defn- init-state-helper-for-asset-sync-loop
   []
   (let [data-from-ws-chan (chan (async/sliding-buffer 100))
         ws (rtc-mock/mock-websocket data-from-ws-chan)
-        rtc-state (rtc-core/init-state ws data-from-ws-chan test-helper/test-db-name-db-version "")]
+        rtc-state (rtc-core/init-state ws data-from-ws-chan test-helper/test-db-name-db-version "" true)]
     (assoc (asset-sync/init-state-from-rtc-state rtc-state)
            :*auto-push-assets-update-ops? (atom false))))