Penpot/penpot
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2025-01-22 22:49:01 -05:00
Code Issues Activity

✨ Allow to analyze files with a function that needs libs

Browse source
This commit is contained in:
Andrés Moya 2023-11-13 15:31:18 +01:00 • committed by Andrey Antukh
parent 099f9c074d
commit 3dfd54d8e2
1 changed files with 13 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
backend/src/app/srepl/helpers.clj
View file

@ -24,6 +24,7 @@
[app.db.sql :as sql] [app.db.sql :as sql]
[app.main :refer [system]] [app.main :refer [system]]
[app.rpc.commands.files :as files] [app.rpc.commands.files :as files]
[app.rpc.commands.files-update :as files-update]
[app.util.blob :as blob] [app.util.blob :as blob]
[app.util.objects-map :as omap] [app.util.objects-map :as omap]
[app.util.pointer-map :as pmap] [app.util.pointer-map :as pmap]
@ -134,7 +135,7 @@
The `on-file` parameter should be a function that receives the file The `on-file` parameter should be a function that receives the file
and the previous state and returns the new state." and the previous state and returns the new state."
[system & {:keys [chunk-size max-items start-at on-file on-error on-end on-init] [system & {:keys [chunk-size max-items start-at on-file on-error on-end on-init with-libraries?]
:or {chunk-size 10 max-items Long/MAX_VALUE}}] :or {chunk-size 10 max-items Long/MAX_VALUE}}]
(letfn [(get-chunk [conn cursor] (letfn [(get-chunk [conn cursor]
(let [rows (db/exec! conn [sql:retrieve-files-chunk cursor chunk-size])] (let [rows (db/exec! conn [sql:retrieve-files-chunk cursor chunk-size])]
@ -165,10 +166,17 @@
(if (contains? (:features file) "fdata/pointer-map") pmap/wrap identity) (if (contains? (:features file) "fdata/pointer-map") pmap/wrap identity)
cfeat/*wrap-with-objects-map-fn* cfeat/*wrap-with-objects-map-fn*
(if (contains? (:features file) "fdata/objects-map") omap/wrap identity)] (if (contains? (:features file) "fdata/objects-map") omap/wrap identity)]
(try (let [libraries (when with-libraries?
(on-file file) (->> (files/get-file-libraries conn (:id file))
(catch Throwable cause (map #(files-update/get-file conn (:id %)))
((or on-error on-error*) cause file)))))) (map #(update % :data blob/decode))
(d/index-by :id)))]
(try
(if with-libraries?
(on-file file libraries)
(on-file file))
(catch Throwable cause
((or on-error on-error*) cause file)))))))
(when (fn? on-end) (on-end)))) (when (fn? on-end) (on-end))))