Improved history refresh mechanism.

src/uxbox/data/history.cljs

@@ -89,14 +89,37 @@
 (defrecord CleanPageHistory []
   rs/UpdateEvent
   (-apply-update [_ state]
-    (-> state
+    (println "CleanPageHistory")
-        (assoc-in [:workspace :history :items] nil)
+    (assoc-in state [:workspace :history] {})))
-        (assoc-in [:workspace :history :selected] nil))))
 
 (defn clean-page-history
   []
   (CleanPageHistory.))
 
+(defn clean-page-history?
+  [v]
+  (instance? CleanPageHistory v))
+
+;; --- Watch Page Changes
+
+(defrecord WatchPageChanges []
+  rs/WatchEvent
+  (-apply-watch [_ state s]
+    (println "WatchPageChanges")
+    (let [stoper (->> (rx/filter clean-page-history? s)
+                      (rx/take 1))]
+      (->> (rx/filter udp/page-synced? s)
+           (rx/take-until stoper)
+           (rx/map (comp :id :page))
+           (rx/pr-log "watcher:")
+           (rx/mapcat #(rx/of
+                        (fetch-page-history %)
+                        (fetch-pinned-page-history %)))))))
+
+(defn watch-page-changes
+  []
+  (WatchPageChanges.))
+
 ;; --- Select Page History
 
 (defrecord SelectPageHistory [item]

src/uxbox/data/pages.cljs

@@ -119,9 +119,6 @@
 
 ;; --- Update Page
 
-(declare fetch-page-history)
-(declare fetch-pinned-page-history)
-
 (defrecord UpdatePage [id]
   rs/WatchEvent
   (-apply-watch [this state s]
@@ -129,12 +126,11 @@
     (let [page (get-in state [:pages-by-id id])]
       (if (:history page)
         (rx/empty)
-        (rx/merge
+        (rx/of (sync-page id))))))
-         (rx/of (sync-page id))
+
-         (->> (rx/filter page-synced? s)
+(defn update-page?
-              (rx/take 1)
+  [v]
-              (rx/mapcat #(rx/of (fetch-page-history id)
+  (instance? UpdatePage v))
-                                 (fetch-pinned-page-history id)))))))))
 
 (defn update-page
   [id]

src/uxbox/ui/users.cljs

@@ -55,7 +55,6 @@
   [own]
   (let [profile (rum/react profile-l)
         local (:rum/local own)]
-    (println "user-render" profile)
     (html
      [:div.user-zone {:on-mouse-enter #(swap! local assoc :open true)
                       :on-mouse-leave #(swap! local assoc :open false)}

src/uxbox/ui/workspace.cljs

@@ -35,6 +35,7 @@
   (let [[projectid pageid] (:rum/props own)]
     (rs/emit! (dw/initialize projectid pageid)
               (udp/fetch-pages projectid)
+              (udh/watch-page-changes)
               (udh/fetch-page-history pageid)
               (udh/fetch-pinned-page-history pageid))
     own))
@@ -78,6 +79,7 @@
 
 (defn- workspace-will-unmount
   [own]
+  (rs/emit! (udh/clean-page-history))
   (let [sub1 (::sub1 own)
         sub2 (::sub2 own)]
     (.close sub1)