3pp-mirror/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2025-05-25 22:06:11 +02:00
Code Issues Projects Releases Packages Wiki Activity

✨ Add minor improvements to comp-v2 migration srepl helper

Browse source
This commit is contained in:
Andrey Antukh 2024-01-30 13:30:48 +01:00
parent 26f4082b5f
commit 7c0a63c7da
1 changed files with 28 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

40
backend/src/app/srepl/components_v2.clj
View file

@ -188,17 +188,27 @@
;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;; ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
(defn migrate-file! (defn migrate-file!
[file-id & {:keys [rollback? validate? label] :or {rollback? true validate? false}}] [file-id & {:keys [rollback? validate? label cache skip-on-graphic-error?]
:or {rollback? true
validate? false
skip-on-graphic-error? true}}]
(l/dbg :hint "migrate:start" :rollback rollback?) (l/dbg :hint "migrate:start" :rollback rollback?)
(let [tpoint (dt/tpoint) (let [tpoint (dt/tpoint)
file-id (if (string? file-id) file-id (if (string? file-id)
(parse-uuid file-id) (parse-uuid file-id)
file-id)] file-id)
(binding [feat/*stats* (atom {})] cache (if (int? cache)
(cache/create :executor (::wrk/executor main/system)
:max-items cache)
nil)]
(binding [feat/*stats* (atom {})
feat/*cache* cache]
(try (try
(-> (assoc main/system ::db/rollback rollback?) (-> (assoc main/system ::db/rollback rollback?)
(feat/migrate-file! file-id (feat/migrate-file! file-id
:validate? validate? :validate? validate?
:skip-on-graphic-error? skip-on-graphic-error?
:label label)) :label label))
(-> (deref feat/*stats*) (-> (deref feat/*stats*)
@ -212,22 +222,28 @@
(l/dbg :hint "migrate:end" :rollback rollback? :elapsed elapsed))))))) (l/dbg :hint "migrate:end" :rollback rollback? :elapsed elapsed)))))))
(defn migrate-team! (defn migrate-team!
[team-id & {:keys [rollback? skip-on-graphic-error? validate? label] [team-id & {:keys [rollback? skip-on-graphic-error? validate? label cache]
:or {rollback? true :or {rollback? true
validate? true validate? true
skip-on-graphic-error? false}}] skip-on-graphic-error? true}}]
(l/dbg :hint "migrate:start" :rollback rollback?) (l/dbg :hint "migrate:start" :rollback rollback?)
(let [team-id (if (string? team-id) (let [team-id (if (string? team-id)
(parse-uuid team-id) (parse-uuid team-id)
team-id) team-id)
stats (atom {}) stats (atom {})
tpoint (dt/tpoint)] tpoint (dt/tpoint)
cache (if (int? cache)
(cache/create :executor (::wrk/executor main/system)
:max-items cache)
nil)]
(add-watch stats :progress-report (report-progress-files tpoint)) (add-watch stats :progress-report (report-progress-files tpoint))
(binding [feat/*stats* stats] (binding [feat/*stats* stats
feat/*cache* cache]
(try (try
(-> (assoc main/system ::db/rollback rollback?) (-> (assoc main/system ::db/rollback rollback?)
(feat/migrate-team! team-id (feat/migrate-team! team-id