🐛 Fix many issues related to exportation process

This commit is contained in:
Andrey Antukh 2022-03-23 13:19:35 +01:00
parent 8fa708d573
commit b3d70f2556
8 changed files with 77 additions and 49 deletions

View file

@ -7,6 +7,7 @@
(ns app.main.data.exports
(:require
[app.common.data.macros :as dm]
[app.common.uuid :as uuid]
[app.main.data.modal :as modal]
[app.main.data.workspace.persistence :as dwp]
[app.main.data.workspace.state-helpers :as wsh]
@ -117,7 +118,7 @@
:filename filename})))))))
(defn- initialize-export-status
[exports filename resource-id query]
[exports filename resource-id query-name]
(ptk/reify ::initialize-export-status
ptk/UpdateEvent
(update [_ state]
@ -131,7 +132,7 @@
:exports exports
:filename filename
:last-update (dt/now)
:query query}))))
:query-name query-name}))))
(defn- update-export-status
[{:keys [progress status resource-id name] :as data}]
@ -163,7 +164,7 @@
(ptk/reify ::request-simple-export
ptk/UpdateEvent
(update [_ state]
(update state :export assoc :in-progress true))
(update state :export assoc :in-progress true :id uuid/zero))
ptk/WatchEvent
(watch [_ state _]
@ -175,11 +176,17 @@
(->> (rp/query! :export-shapes-simple params)
(rx/map (fn [data]
(dom/trigger-download filename data)
(fn [state]
(dissoc state :export))))))))))
(clear-export-state uuid/zero)))
(rx/catch (fn [cause]
(prn "KKKK" cause)
(rx/concat
(rx/of (clear-export-state uuid/zero))
(rx/throw cause))))))))))
(defn request-multiple-export
[{:keys [filename exports query] :as params}]
[{:keys [filename exports query-name]
:or {query-name :export-shapes-multiple}
:as params}]
(ptk/reify ::request-multiple-export
ptk/WatchEvent
(watch [_ state _]
@ -200,9 +207,9 @@
(rx/share))
stoper
(->> progress-stream
(rx/filter #(or (= "ended" (:status %))
(= "error" (:status %)))))]
(rx/filter #(or (= "ended" (:status %))
(= "error" (:status %)))
progress-stream)]
(swap! st/ongoing-tasks conj :export)
@ -212,11 +219,11 @@
;; Launch the exportation process and stores the resource id
;; locally.
(->> (rp/query! query params)
(->> (rp/query! query-name params)
(rx/tap (fn [{:keys [id]}]
(vreset! resource-id id)))
(rx/map (fn [{:keys [id]}]
(initialize-export-status exports filename id query))))
(initialize-export-status exports filename id query-name))))
;; We proceed to update the export state with incoming
;; progress updates. We delay the stoper for give some time
@ -245,6 +252,7 @@
(ptk/reify ::retry-last-export
ptk/WatchEvent
(watch [_ state _]
(let [{:keys [exports filename query]} (:export state)]
(rx/of (request-multiple-export {:exports exports :filename filename :query query}))))))
(let [params (select-keys (:export state) [:filename :exports :query-name])]
(when (seq params)
(rx/of (request-multiple-export params)))))))

View file

@ -126,7 +126,7 @@
[_ params]
(send-export-command :cmd :export-shapes :params params :blob? false))
(defmethod query :export-frames
(defmethod query :export-frames-multiple
[_ params]
(send-export-command :cmd :export-frames :params (assoc params :uri (str base-uri)) :blob? false))

View file

@ -22,7 +22,7 @@
[rumext.alpha :as mf]))
(mf/defc export-multiple-dialog
[{:keys [exports filename title query no-selection]}]
[{:keys [exports filename title query-name no-selection]}]
(let [lstate (mf/deref refs/export)
in-progress? (:in-progress lstate)
@ -43,7 +43,10 @@
(fn [event]
(dom/prevent-default event)
(st/emit! (modal/hide)
(de/request-multiple-export {:filename filename :exports enabled-exports :query query})))
(de/request-multiple-export
{:filename filename
:exports enabled-exports
:query-name query-name})))
on-toggle-enabled
(fn [index]
@ -143,14 +146,23 @@
::mf/register-as :export-shapes}
[{:keys [exports filename]}]
(let [title (tr "dashboard.export-shapes.title")]
(export-multiple-dialog {:exports exports :filename filename :title title :query :export-shapes-multiple :no-selection shapes-no-selection})))
[:& export-multiple-dialog
{:exports exports
:filename filename
:title title
:query-name :export-shapes-multiple
:no-selection shapes-no-selection}]))
(mf/defc export-frames
{::mf/register modal/components
::mf/register-as :export-frames}
[{:keys [exports filename]}]
(let [title (tr "dashboard.export-frames.title")]
(export-multiple-dialog {:exports exports :filename filename :title title :query :export-frames})))
[:& export-multiple-dialog
{:exports exports
:filename filename
:title title
:query-name :export-frames-multiple}]))
(mf/defc export-progress-widget
{::mf/wrap [mf/memo]}