|
|
@@ -359,26 +359,27 @@
|
|
|
|
|
|
(defn <init-load-from-indexeddb!
|
|
|
[repo]
|
|
|
- (p/let [all-data (op-idb-layer/<read repo)
|
|
|
- all-data-m (into {} all-data)
|
|
|
- local-tx (get all-data-m "local-tx")
|
|
|
- graph-uuid (get all-data-m "graph-uuid")
|
|
|
- ops (->> all-data
|
|
|
- (filter (comp number? first))
|
|
|
- (sort-by first <)
|
|
|
- ops-from-store-coercer
|
|
|
- (map second))
|
|
|
- {:keys [block-uuid->ops epoch->block-uuid-sorted-map]}
|
|
|
- (add-ops-to-block-uuid->ops ops {} (sorted-map-by <))
|
|
|
- r (cond-> {:block-uuid->ops block-uuid->ops
|
|
|
- :epoch->block-uuid-sorted-map epoch->block-uuid-sorted-map}
|
|
|
- graph-uuid (assoc :graph-uuid graph-uuid)
|
|
|
- local-tx (assoc :local-tx local-tx))]
|
|
|
- (assert (ops-validator ops) ops)
|
|
|
- (swap! *ops-store update repo #(-> %
|
|
|
- (assoc :current-branch r)
|
|
|
- (dissoc :old-branch)))
|
|
|
- (prn ::<init-load-from-indexeddb! repo)))
|
|
|
+ (when (state/enable-rtc? repo)
|
|
|
+ (p/let [all-data (op-idb-layer/<read repo)
|
|
|
+ all-data-m (into {} all-data)
|
|
|
+ local-tx (get all-data-m "local-tx")
|
|
|
+ graph-uuid (get all-data-m "graph-uuid")
|
|
|
+ ops (->> all-data
|
|
|
+ (filter (comp number? first))
|
|
|
+ (sort-by first <)
|
|
|
+ ops-from-store-coercer
|
|
|
+ (map second))
|
|
|
+ {:keys [block-uuid->ops epoch->block-uuid-sorted-map]}
|
|
|
+ (add-ops-to-block-uuid->ops ops {} (sorted-map-by <))
|
|
|
+ r (cond-> {:block-uuid->ops block-uuid->ops
|
|
|
+ :epoch->block-uuid-sorted-map epoch->block-uuid-sorted-map}
|
|
|
+ graph-uuid (assoc :graph-uuid graph-uuid)
|
|
|
+ local-tx (assoc :local-tx local-tx))]
|
|
|
+ (assert (ops-validator ops) ops)
|
|
|
+ (swap! *ops-store update repo #(-> %
|
|
|
+ (assoc :current-branch r)
|
|
|
+ (dissoc :old-branch)))
|
|
|
+ (prn ::<init-load-from-indexeddb! repo))))
|
|
|
|
|
|
(defn <sync-to-idb-layer!
|
|
|
[repo]
|