greatbody
/
logseq
mirror of https://github.com/logseq/logseq
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

enhance(rtc): watch schema related attrs when db-listen

experiment/tanstack-table
rcmerci 2024-05-28 16:22:02 +08:00
parent 8fabd7798d
commit fce5adb400
2 changed files with 41 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/frontend/worker/rtc/db_listener.cljs
View File

@ -22,7 +22,8 @@
(def ^:private watched-attrs
#{:block/content :block/created-at :block/updated-at :block/alias
:block/tags :block/type :block/schema :block/link :block/journal-day
:class/parent :class/schema.properties :property/schema.classes})
:class/parent :class/schema.properties :property/schema.classes
:db/ident :db/index :db/valueType :db/cardinality})
(defn- watched-attr?
[attr]

40
src/test/frontend/worker/rtc/db_listener_test.cljs
View File

@ -30,4 +30,42 @@
(tx-data=>e->a->add?->v->t (:tx-data remove-whiteboard-page-block))
(map vec (:tx-data remove-whiteboard-page-block)))]
(is (= [[:remove-page {:block-uuid block-uuid}]]
(map (fn [[op-type _t op-value]] [op-type op-value]) r))))))
(map (fn [[op-type _t op-value]] [op-type op-value]) r)))))
(testing "update-schema op"
(let [conn (d/conn-from-db empty-db)
tx-data [[:db/add 69 :db/index true]
[:db/add 69 :block/uuid #uuid "66558abf-6512-469d-9e83-8f1ba0be9305"]
[:db/add 69 :db/valueType :db.type/ref]
[:db/add 69 :block/updated-at 1716882111476]
[:db/add 69 :block/created-at 1716882111476]
[:db/add 69 :block/schema {:type :number}]
[:db/add 69 :block/format :markdown]
[:db/add 69 :db/cardinality :db.cardinality/one]
[:db/add 69 :db/ident :user.property/qqq]
[:db/add 69 :block/type "property"]
[:db/add 69 :block/order "b0T"]
[:db/add 69 :block/name "qqq"]
[:db/add 69 :block/original-name "qqq"]]
{:keys [db-before db-after tx-data]} (d/transact! conn tx-data)
ops (#'subject/entity-datoms=>ops db-before db-after
(tx-data=>e->a->add?->v->t tx-data)
(map vec tx-data))]
(is (=
[[:move {:block-uuid #uuid "66558abf-6512-469d-9e83-8f1ba0be9305"}]
[:update-page {:block-uuid #uuid "66558abf-6512-469d-9e83-8f1ba0be9305"}]
[:update {:block-uuid #uuid "66558abf-6512-469d-9e83-8f1ba0be9305"
:av-coll
[[:db/index "[\"~#'\",true]"]
[:db/valueType "[\"~#'\",\"~:db.type/ref\"]"]
[:block/updated-at "[\"~#'\",1716882111476]"]
[:block/created-at "[\"~#'\",1716882111476]"]
[:block/schema "[\"^ \",\"~:type\",\"~:number\"]"]
[:db/cardinality "[\"~#'\",\"~:db.cardinality/one\"]"]
[:db/ident "[\"~#'\",\"~:user.property/qqq\"]"]
[:block/type "[\"~#'\",\"property\"]"]]}]]
(map (fn [[op-type _t op-value]]
[op-type (cond-> op-value
(:av-coll op-value)
(assoc :av-coll (map #(take 2 %) (:av-coll op-value))))])
ops))))))