clone/logseq
1
0
Fork 0
mirror of https://github.com/logseq/logseq.git synced 2026-05-03 02:16:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(sync): start-sync loop

Browse Source
This commit is contained in:
Andelf
2023-09-07 20:34:45 +08:00
parent 0e4e42ac2b
commit c346116639
1 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/main/frontend/fs/sync.cljs
View File

@@ -3384,10 +3384,21 @@
"Avoid running multiple sync instances simultaneously."
(atom false))
(defn- <should-start-sync?
[]
(go
(and (state/enable-sync?)
@network-online-cursor ;; is online
(user/has-refresh-token?) ;; has refresh token, should bring up sync
(or (= ::stop (:state (state/get-file-sync-state))) ;; state=stopped
(nil? (state/get-file-sync-state))) ;; the whole sync state not inited yet, happens when app starts without network
(<! (p->c (persist-var/-load graphs-txid)))))) ;; not a sync graph))
(defn <sync-start
[]
(go
(when-not @*sync-starting
(when (and (not @*sync-starting)
(<! (<should-start-sync?)))
(reset! *sync-starting true)
(if-not (and (state/enable-sync?)
(or (nil? (state/get-file-sync-state))
@@ -3508,11 +3519,7 @@
;; try to re-start sync when state=stopped every 1min
(go-loop []
(<! (timeout 60000))
(when (and (state/enable-sync?)
@network-online-cursor ;; is online
(user/has-refresh-token?) ;; has refresh token, user should be logged in
(or (= ::stop (:state (state/get-file-sync-state))) ;; state=stopped
(nil? (state/get-file-sync-state)))) ;; the whole sync state not inited yet, happens when app starts without network
(when (<! (<should-start-sync?))
(println "trying to restart sync..." (tc/to-string (t/now)))
(<sync-start))
(recur))