clone/logseq
1
0
Fork 0
mirror of https://github.com/logseq/logseq.git synced 2026-05-23 12:14:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

batch rebase

Browse Source
This commit is contained in:
Tienson Qin
2026-03-26 16:17:21 +08:00
parent 13c667dffd
commit 48aed8ca88
1 changed files with 10 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/main/frontend/worker/sync/apply_txs.cljs
View File

@@ -938,25 +938,22 @@
(:tx-data rebase-tx-report)
tx-meta))
;; TODO: batch sync db to main thread
(defn- apply-remote-tx-with-local-changes!
[{:keys [repo conn local-txs remote-txs]}]
(let [batch-tx-meta {:rtc-tx? true
:with-local-changes? true}]
(reverse-local-txs! conn local-txs {:rtc-tx? true})
(ldb/batch-transact!
conn
(assoc batch-tx-meta :reverse-and-apply-remote? true)
(fn [conn]
(reverse-local-txs! conn local-txs {:rtc-tx? true})
(transact-remote-txs! conn remote-txs batch-tx-meta)
(transact-remote-txs! conn remote-txs batch-tx-meta)
;; (ldb/batch-transact!
;; conn
;; (assoc batch-tx-meta :apply-remote? true)
;; (fn [conn]
;; (transact-remote-txs! conn remote-txs batch-tx-meta)))
(remove-pending-txs! repo (map :tx-id local-txs))
(remove-pending-txs! repo (map :tx-id local-txs))
(let [rebase-tx-report (rebase-local-txs! repo conn local-txs
(assoc batch-tx-meta :rebase? true))]
(fix-tx! conn rebase-tx-report {:outliner-op :rebase-fix}))))
(let [rebase-tx-report (rebase-local-txs! repo conn local-txs
(assoc batch-tx-meta :rebase? true))]
(fix-tx! conn rebase-tx-report {:outliner-op :rebase-fix}))))))
(defn- apply-remote-tx-without-local-changes!
[{:keys [conn remote-txs temp-tx-meta]}]