|
@@ -416,15 +416,16 @@
|
|
|
vals
|
|
vals
|
|
|
(mapcat vals)))
|
|
(mapcat vals)))
|
|
|
|
|
|
|
|
-(defn get-min-epoch-asset-ops
|
|
|
|
|
- [repo]
|
|
|
|
|
- (let [repo-ops-store (get @*ops-store repo)
|
|
|
|
|
- {:keys [epoch->asset-uuid-sorted-map asset-uuid->ops]} (:current-branch repo-ops-store)]
|
|
|
|
|
- (assert (contains? repo-ops-store :current-branch) repo)
|
|
|
|
|
- (when-let [[_epoch asset-uuid] (first epoch->asset-uuid-sorted-map)]
|
|
|
|
|
- (assert (contains? asset-uuid->ops asset-uuid))
|
|
|
|
|
- {:asset-uuid asset-uuid
|
|
|
|
|
- :ops (asset-uuid->ops asset-uuid)})))
|
|
|
|
|
|
|
+(comment
|
|
|
|
|
+ (defn get-min-epoch-asset-ops
|
|
|
|
|
+ [repo]
|
|
|
|
|
+ (let [repo-ops-store (get @*ops-store repo)
|
|
|
|
|
+ {:keys [epoch->asset-uuid-sorted-map asset-uuid->ops]} (:current-branch repo-ops-store)]
|
|
|
|
|
+ (assert (contains? repo-ops-store :current-branch) repo)
|
|
|
|
|
+ (when-let [[_epoch asset-uuid] (first epoch->asset-uuid-sorted-map)]
|
|
|
|
|
+ (assert (contains? asset-uuid->ops asset-uuid))
|
|
|
|
|
+ {:asset-uuid asset-uuid
|
|
|
|
|
+ :ops (asset-uuid->ops asset-uuid)}))))
|
|
|
|
|
|
|
|
(comment
|
|
(comment
|
|
|
(defn get-asset-ops
|
|
(defn get-asset-ops
|
|
@@ -450,13 +451,14 @@
|
|
|
count)
|
|
count)
|
|
|
0))
|
|
0))
|
|
|
|
|
|
|
|
-(defn get-unpushed-asset-update-count
|
|
|
|
|
- [repo]
|
|
|
|
|
- (some-> (get @*ops-store repo)
|
|
|
|
|
- :current-branch
|
|
|
|
|
- :asset-uuid->ops
|
|
|
|
|
- keys
|
|
|
|
|
- count))
|
|
|
|
|
|
|
+(comment
|
|
|
|
|
+ (defn get-unpushed-asset-update-count
|
|
|
|
|
+ [repo]
|
|
|
|
|
+ (some-> (get @*ops-store repo)
|
|
|
|
|
+ :current-branch
|
|
|
|
|
+ :asset-uuid->ops
|
|
|
|
|
+ keys
|
|
|
|
|
+ count)))
|
|
|
|
|
|
|
|
(defn intersection-block-uuids
|
|
(defn intersection-block-uuids
|
|
|
[repo block-uuid-coll]
|
|
[repo block-uuid-coll]
|
|
@@ -479,16 +481,17 @@
|
|
|
:block-uuid->ops (dissoc block-uuid->ops block-uuid)
|
|
:block-uuid->ops (dissoc block-uuid->ops block-uuid)
|
|
|
:epoch->block-uuid-sorted-map (dissoc epoch->block-uuid-sorted-map min-epoch)))))
|
|
:epoch->block-uuid-sorted-map (dissoc epoch->block-uuid-sorted-map min-epoch)))))
|
|
|
|
|
|
|
|
-(defn remove-asset-ops!
|
|
|
|
|
- [repo asset-uuid]
|
|
|
|
|
- {:pre [(uuid? asset-uuid)]}
|
|
|
|
|
- (let [repo-ops-store (get @*ops-store repo)
|
|
|
|
|
- {:keys [epoch->asset-uuid-sorted-map asset-uuid->ops]} (:current-branch repo-ops-store)]
|
|
|
|
|
- (assert (contains? repo-ops-store :current-branch) repo)
|
|
|
|
|
- (let [min-epoch (asset-uuid->min-epoch asset-uuid->ops asset-uuid)]
|
|
|
|
|
- (swap! *ops-store update-in [repo :current-branch] assoc
|
|
|
|
|
- :asset-uuid->ops (dissoc asset-uuid->ops asset-uuid)
|
|
|
|
|
- :epoch->asset-uuid-sorted-map (dissoc epoch->asset-uuid-sorted-map min-epoch)))))
|
|
|
|
|
|
|
+(comment
|
|
|
|
|
+ (defn remove-asset-ops!
|
|
|
|
|
+ [repo asset-uuid]
|
|
|
|
|
+ {:pre [(uuid? asset-uuid)]}
|
|
|
|
|
+ (let [repo-ops-store (get @*ops-store repo)
|
|
|
|
|
+ {:keys [epoch->asset-uuid-sorted-map asset-uuid->ops]} (:current-branch repo-ops-store)]
|
|
|
|
|
+ (assert (contains? repo-ops-store :current-branch) repo)
|
|
|
|
|
+ (let [min-epoch (asset-uuid->min-epoch asset-uuid->ops asset-uuid)]
|
|
|
|
|
+ (swap! *ops-store update-in [repo :current-branch] assoc
|
|
|
|
|
+ :asset-uuid->ops (dissoc asset-uuid->ops asset-uuid)
|
|
|
|
|
+ :epoch->asset-uuid-sorted-map (dissoc epoch->asset-uuid-sorted-map min-epoch))))))
|
|
|
|
|
|
|
|
|
|
|
|
|
(defn <init-load-from-indexeddb!
|
|
(defn <init-load-from-indexeddb!
|