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

throw avet mismatch

Browse Source
This commit is contained in:
Tienson Qin
2026-04-14 16:13:55 +08:00
parent 49ca0e22a9
commit 2b39d5e23d
1 changed files with 25 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/main/frontend/worker/db_listener.cljs
View File

@@ -7,7 +7,9 @@
[frontend.worker.shared-service :as shared-service]
[frontend.worker.state :as worker-state]
[frontend.worker.sync :as db-sync]
[promesa.core :as p]))
[promesa.core :as p]
[clojure.data :as data]
[logseq.db :as ldb]))
(defmulti listen-db-changes
(fn [listen-key & _] listen-key))
@@ -59,6 +61,26 @@
[_ {:keys [repo]} tx-report]
(db-sync/handle-local-tx! repo tx-report))
(defn- ensure-avet-datoms-matched-with-eavt!
[db {:keys [db-before db-after tx-meta tx-data]}]
(let [mismatch (->> (data/diff
(->> (d/datoms db :eavt)
(keep (fn [d] (when (= :block/uuid (:a d))
(:e d))))
set)
(->> (d/datoms db :avet :block/uuid)
(map :e)
set))
first
(map (fn [e]
(d/entity db e))))]
(when (seq mismatch)
(throw (ex-info "avet != eavt"
{:tx-meta tx-meta
:tx-data (ldb/write-transit-str tx-data)
:db-before (ldb/write-transit-str db-before)
:db-after (ldb/write-transit-str db-after)})))))
(defn listen-db-changes!
[repo conn & {:keys [handler-keys]}]
(let [handlers (if (seq handler-keys)
@@ -70,7 +92,8 @@
(d/unlisten! conn ::listen-db-changes!)
(d/listen! conn ::listen-db-changes!
(fn listen-db-changes!-inner
[{:keys [tx-data tx-meta] :as tx-report}]
[{:keys [tx-data tx-meta db-after] :as tx-report}]
(ensure-avet-datoms-matched-with-eavt! db-after tx-report)
(when (seq tx-data)
(when-not (:batch-final-tx-report? tx-meta)
(db-sync/update-local-sync-checksum! repo tx-report))