|
|
@@ -18,92 +18,92 @@
|
|
|
(rum/defcs indicator <
|
|
|
rum/reactive
|
|
|
[_state]
|
|
|
- (let [_ (state/sub :auth/id-token)
|
|
|
- toggling? (state/sub :file-sync/toggling?)
|
|
|
- current-repo (state/get-current-repo)
|
|
|
- sync-state (state/sub [:file-sync/sync-state current-repo])
|
|
|
- _ (rum/react file-sync-handler/refresh-file-sync-component)
|
|
|
+ (let [_ (state/sub :auth/id-token)
|
|
|
+ toggling? (state/sub :file-sync/toggling?)
|
|
|
+ current-repo (state/get-current-repo)
|
|
|
+ sync-state (state/sub [:file-sync/sync-state current-repo])
|
|
|
+ _ (rum/react file-sync-handler/refresh-file-sync-component)
|
|
|
graph-txid-exists? (file-sync-handler/graph-txid-exists?)
|
|
|
- uploading-files (:current-local->remote-files sync-state)
|
|
|
- downloading-files (:current-remote->local-files sync-state)
|
|
|
- queuing-files (:queued-local->remote-files sync-state)
|
|
|
-
|
|
|
- status (:state sync-state)
|
|
|
- status (or (nil? status) (keyword (name status)))
|
|
|
- off? (or (nil? sync-state) (fs-sync/sync-state--stopped? sync-state))
|
|
|
- full-syncing? (contains? #{:local->remote-full-sync :remote->local-full-sync} status)
|
|
|
- syncing? (or full-syncing? (contains? #{:local->remote :remote->local} status))
|
|
|
- idle? (contains? #{:idle} status)
|
|
|
- need-password? (contains? #{:need-password} status)
|
|
|
- queuing? (and idle? (boolean (seq queuing-files)))
|
|
|
-
|
|
|
- turn-on #(when-not toggling?
|
|
|
- (state/set-state! :file-sync/toggling? true)
|
|
|
- (if-not graph-txid-exists?
|
|
|
- (as/go
|
|
|
- (notifications/show! "Going to init a remote graph!" :warn)
|
|
|
- (let [repo (state/get-current-repo)
|
|
|
- GraphName (util/node-path.basename repo)]
|
|
|
- (when-let [GraphUUID (get (as/<! (file-sync-handler/create-graph GraphName)) 2)]
|
|
|
- (as/<! (fs-sync/sync-start))
|
|
|
- ;; update existing repo
|
|
|
- (state/set-repos! (map (fn [r]
|
|
|
- (if (= (:url r) repo)
|
|
|
- (assoc r :GraphUUID GraphUUID
|
|
|
- :GraphName GraphName
|
|
|
- :remote? true)
|
|
|
- r))
|
|
|
- (state/get-repos))))))
|
|
|
- (fs-sync/sync-start)))
|
|
|
-
|
|
|
- _ (when (and (not off?) toggling?) (state/set-state! :file-sync/toggling? false))]
|
|
|
+ uploading-files (:current-local->remote-files sync-state)
|
|
|
+ downloading-files (:current-remote->local-files sync-state)
|
|
|
+ queuing-files (:queued-local->remote-files sync-state)
|
|
|
+
|
|
|
+ status (:state sync-state)
|
|
|
+ status (or (nil? status) (keyword (name status)))
|
|
|
+ off? (or (nil? sync-state) (fs-sync/sync-state--stopped? sync-state))
|
|
|
+ full-syncing? (contains? #{:local->remote-full-sync :remote->local-full-sync} status)
|
|
|
+ syncing? (or full-syncing? (contains? #{:local->remote :remote->local} status))
|
|
|
+ idle? (contains? #{:idle} status)
|
|
|
+ need-password? (contains? #{:need-password} status)
|
|
|
+ queuing? (and idle? (boolean (seq queuing-files)))
|
|
|
+
|
|
|
+ turn-on #(when-not toggling?
|
|
|
+ (state/set-state! :file-sync/toggling? true)
|
|
|
+ (if-not graph-txid-exists?
|
|
|
+ (as/go
|
|
|
+ (notifications/show! "Going to init a remote graph!" :warn)
|
|
|
+ (let [repo (state/get-current-repo)
|
|
|
+ GraphName (util/node-path.basename repo)]
|
|
|
+ (when-let [GraphUUID (get (as/<! (file-sync-handler/create-graph GraphName)) 2)]
|
|
|
+ (as/<! (fs-sync/sync-start))
|
|
|
+ ;; update existing repo
|
|
|
+ (state/set-repos! (map (fn [r]
|
|
|
+ (if (= (:url r) repo)
|
|
|
+ (assoc r :GraphUUID GraphUUID
|
|
|
+ :GraphName GraphName
|
|
|
+ :remote? true)
|
|
|
+ r))
|
|
|
+ (state/get-repos))))))
|
|
|
+ (fs-sync/sync-start)))
|
|
|
+
|
|
|
+ _ (when (and (not off?) toggling?) (state/set-state! :file-sync/toggling? false))]
|
|
|
|
|
|
[:div.cp__file-sync-indicator
|
|
|
(when (and (not config/publishing?)
|
|
|
(user-handler/logged-in?))
|
|
|
|
|
|
(ui/dropdown-with-links
|
|
|
- (fn [{:keys [toggle-fn]}]
|
|
|
- (if (or (true? toggling?) (not off?))
|
|
|
- [:a.button.cloud.on
|
|
|
- {:on-click toggle-fn
|
|
|
- :class (util/classnames [{:syncing syncing?
|
|
|
- :is-full full-syncing?
|
|
|
- :queuing queuing?
|
|
|
- :idle (and (not queuing?) idle?)}])}
|
|
|
- [:span.flex.items-center
|
|
|
- (ui/icon "cloud"
|
|
|
- {:style {:fontSize ui/icon-size}})]
|
|
|
- (when full-syncing? [:small.full-loading.animate-spin (ui/icon "rotate-clockwise")])]
|
|
|
-
|
|
|
- [:a.button.cloud.off
|
|
|
- {:on-click turn-on}
|
|
|
- (ui/icon "cloud-off" {:style {:fontSize ui/icon-size}})]))
|
|
|
-
|
|
|
- (cond-> []
|
|
|
- need-password?
|
|
|
- (conj {:title [:strong "Set a password to start"]
|
|
|
- :icon (ui/icon "lock-off")
|
|
|
- :options {:on-click #(let [current-graph (repo-handler/get-detail-graph-info current-repo)]
|
|
|
- (state/pub-event!
|
|
|
- [:modal/remote-encryption-input-pw-dialog current-repo current-graph
|
|
|
- :input-pwd-remote (fn [] (fs-sync/restore-pwd! (:GraphUUID current-graph)))]))}})
|
|
|
-
|
|
|
- graph-txid-exists?
|
|
|
- (concat
|
|
|
- (map (fn [f] {:title [:div.file-item f]
|
|
|
- :icon (ui/icon "point")}) queuing-files)
|
|
|
- (map (fn [f] {:title [:div.file-item f]
|
|
|
- :icon (ui/icon "arrow-narrow-up")}) uploading-files)
|
|
|
- (map (fn [f] {:title [:div.file-item f]
|
|
|
- :icon (ui/icon "arrow-narrow-down")}) downloading-files)
|
|
|
- (when sync-state
|
|
|
- (map-indexed (fn [i f] (:time f)
|
|
|
- {:title [:div {:key i} [:div (:path f)] [:div.opacity-50 (util/time-ago (:time f))]]})
|
|
|
- (take 10 (:history sync-state))))))
|
|
|
-
|
|
|
- {:links-header
|
|
|
- [:strong.debug-status (str status)]}))]))
|
|
|
+ (fn [{:keys [toggle-fn]}]
|
|
|
+ (if (or (true? toggling?) (not off?))
|
|
|
+ [:a.button.cloud.on
|
|
|
+ {:on-click toggle-fn
|
|
|
+ :class (util/classnames [{:syncing syncing?
|
|
|
+ :is-full full-syncing?
|
|
|
+ :queuing queuing?
|
|
|
+ :idle (and (not queuing?) idle?)}])}
|
|
|
+ [:span.flex.items-center
|
|
|
+ (ui/icon "cloud"
|
|
|
+ {:style {:fontSize ui/icon-size}})]
|
|
|
+ (when full-syncing? [:small.full-loading.animate-spin (ui/icon "rotate-clockwise")])]
|
|
|
+
|
|
|
+ [:a.button.cloud.off
|
|
|
+ {:on-click turn-on}
|
|
|
+ (ui/icon "cloud-off" {:style {:fontSize ui/icon-size}})]))
|
|
|
+
|
|
|
+ (cond-> []
|
|
|
+ need-password?
|
|
|
+ (conj {:title [:strong "Set a password to start"]
|
|
|
+ :icon (ui/icon "lock-off")
|
|
|
+ :options {:on-click #(let [current-graph (repo-handler/get-detail-graph-info current-repo)]
|
|
|
+ (state/pub-event!
|
|
|
+ [:modal/remote-encryption-input-pw-dialog current-repo current-graph
|
|
|
+ :input-pwd-remote (fn [] (fs-sync/restore-pwd! (:GraphUUID current-graph)))]))}})
|
|
|
+
|
|
|
+ graph-txid-exists?
|
|
|
+ (concat
|
|
|
+ (map (fn [f] {:title [:div.file-item f]
|
|
|
+ :icon (ui/icon "point")}) queuing-files)
|
|
|
+ (map (fn [f] {:title [:div.file-item f]
|
|
|
+ :icon (ui/icon "arrow-narrow-up")}) uploading-files)
|
|
|
+ (map (fn [f] {:title [:div.file-item f]
|
|
|
+ :icon (ui/icon "arrow-narrow-down")}) downloading-files)
|
|
|
+ (when sync-state
|
|
|
+ (map-indexed (fn [i f] (:time f)
|
|
|
+ {:title [:div {:key i} [:div (:path f)] [:div.opacity-50 (util/time-ago (:time f))]]})
|
|
|
+ (take 10 (:history sync-state))))))
|
|
|
+
|
|
|
+ {:links-header
|
|
|
+ [:strong.debug-status (str status)]}))]))
|
|
|
|
|
|
(rum/defc pick-local-graph-for-sync [graph]
|
|
|
(rum/use-effect!
|
|
|
@@ -122,38 +122,38 @@
|
|
|
|
|
|
[:div
|
|
|
(ui/button
|
|
|
- (str "Open a local directory")
|
|
|
- :on-click #(-> (page-handler/ls-dir-files!
|
|
|
- (fn [{:keys [url]}]
|
|
|
- (file-sync-handler/init-remote-graph url)
|
|
|
- ;; TODO: wait for switch done
|
|
|
- (js/setTimeout (fn [] (repo-handler/refresh-repos!)) 200))
|
|
|
-
|
|
|
- {:empty-dir?-or-pred
|
|
|
- (fn [ret]
|
|
|
- (let [empty-dir? (nil? (second ret))]
|
|
|
- (if-let [root (first ret)]
|
|
|
-
|
|
|
- ;; verify directory
|
|
|
- (-> (if empty-dir?
|
|
|
- (p/resolved nil)
|
|
|
- (if (util/electron?)
|
|
|
- (ipc/ipc :readGraphTxIdInfo root)
|
|
|
- (fs-util/read-graph-txid-info root)))
|
|
|
-
|
|
|
- (p/then (fn [^js info]
|
|
|
- (when (and (not empty-dir?)
|
|
|
- (or (nil? info)
|
|
|
- (nil? (second info))
|
|
|
- (not= (second info) (:GraphUUID graph))))
|
|
|
- (throw (js/Error. "AssertDirectoryError"))))))
|
|
|
-
|
|
|
- ;; cancel pick a directory
|
|
|
- (throw (js/Error. nil)))))})
|
|
|
-
|
|
|
- (p/catch (fn [^js e]
|
|
|
- (when (= "AssertDirectoryError" (.-message e))
|
|
|
- (notifications/show! "Please select an empty directory or an existing remote graph!" :error))))))
|
|
|
+ (str "Open a local directory")
|
|
|
+ :on-click #(-> (page-handler/ls-dir-files!
|
|
|
+ (fn [{:keys [url]}]
|
|
|
+ (file-sync-handler/init-remote-graph url)
|
|
|
+ ;; TODO: wait for switch done
|
|
|
+ (js/setTimeout (fn [] (repo-handler/refresh-repos!)) 200))
|
|
|
+
|
|
|
+ {:empty-dir?-or-pred
|
|
|
+ (fn [ret]
|
|
|
+ (let [empty-dir? (nil? (second ret))]
|
|
|
+ (if-let [root (first ret)]
|
|
|
+
|
|
|
+ ;; verify directory
|
|
|
+ (-> (if empty-dir?
|
|
|
+ (p/resolved nil)
|
|
|
+ (if (util/electron?)
|
|
|
+ (ipc/ipc :readGraphTxIdInfo root)
|
|
|
+ (fs-util/read-graph-txid-info root)))
|
|
|
+
|
|
|
+ (p/then (fn [^js info]
|
|
|
+ (when (and (not empty-dir?)
|
|
|
+ (or (nil? info)
|
|
|
+ (nil? (second info))
|
|
|
+ (not= (second info) (:GraphUUID graph))))
|
|
|
+ (throw (js/Error. "AssertDirectoryError"))))))
|
|
|
+
|
|
|
+ ;; cancel pick a directory
|
|
|
+ (throw (js/Error. nil)))))})
|
|
|
+
|
|
|
+ (p/catch (fn [^js e]
|
|
|
+ (when (= "AssertDirectoryError" (.-message e))
|
|
|
+ (notifications/show! "Please select an empty directory or an existing remote graph!" :error))))))
|
|
|
[:p.text-xs.opacity-50.px-1 (ui/icon "alert-circle") " An empty directory or an existing remote graph!"]]]])
|
|
|
|
|
|
(defn pick-dest-to-sync-panel [graph]
|
charlie