From 8f2e31cafac6945d025cf325799ade833782155b Mon Sep 17 00:00:00 2001
From: Andrey Antukh <niwi@niwi.nz>
Date: Tue, 10 Mar 2020 11:44:57 +0100
Subject: [PATCH] :sparkles: Add public function for enable event stream
 debugging.

---
 frontend/src/uxbox/main.cljs       |  5 +++++
 frontend/src/uxbox/main/store.cljs | 17 ++++++++++-------
 2 files changed, 15 insertions(+), 7 deletions(-)

diff --git a/frontend/src/uxbox/main.cljs b/frontend/src/uxbox/main.cljs
index 698a8bd41..47bfd8ead 100644
--- a/frontend/src/uxbox/main.cljs
+++ b/frontend/src/uxbox/main.cljs
@@ -84,3 +84,8 @@
   []
   (when (= "main" (unchecked-get js/window app-sym))
     (reinit)))
+
+(defn ^:export toggle-debug
+  []
+  (swap! st/*debug* not))
+
diff --git a/frontend/src/uxbox/main/store.cljs b/frontend/src/uxbox/main/store.cljs
index 561605d9e..e0c1520a8 100644
--- a/frontend/src/uxbox/main/store.cljs
+++ b/frontend/src/uxbox/main/store.cljs
@@ -21,7 +21,7 @@
 (defonce store (ptk/store {:on-error #(*on-error* %)}))
 (defonce stream (ptk/input-stream store))
 
-(defn repr-event
+(defn- repr-event
   [event]
   (cond
     (satisfies? ptk/Event event)
@@ -34,12 +34,15 @@
     :else
     (str "unk: " (pr-str event))))
 
-(defonce debug (as-> stream $
-                 (rx/filter ptk/event? $)
-                 ;; Comment this line if you want full debug.
-                 (rx/ignore $)
-                 (rx/subscribe $ (fn [event]
-                                   (println "[stream]: " (repr-event event))))))
+(defonce ^:dynamic *debug* (atom false))
+
+(when *assert*
+  (defonce debug-subscription
+    (as-> stream $
+      (rx/filter ptk/event? $)
+      (rx/filter (fn [s] (deref *debug*)) $)
+      (rx/subscribe $ (fn [event]
+                        (println "[stream]: " (repr-event event)))))))
 
 (def auth-ref
   (-> (l/key :auth)