dev(rtc): refactor debug-log, only record rtc related tx-data

src/main/frontend/worker/db_listener.cljs

@@ -4,7 +4,6 @@
             [datascript.core :as d]
             [frontend.common.thread-api :as thread-api]
             [frontend.worker.pipeline :as worker-pipeline]
-            [frontend.worker.rtc.debug-log :as rtc-debug-log]
             [frontend.worker.rtc.gen-client-op :as gen-client-op]
             [frontend.worker.search :as search]
             [frontend.worker.shared-service :as shared-service]
@@ -85,7 +84,6 @@
       (d/listen! conn ::listen-db-changes!
                  (fn listen-db-changes!-inner
                    [{:keys [tx-data _db-before _db-after tx-meta] :as tx-report}]
-                   (rtc-debug-log/log-tx! repo tx-data tx-meta)
                    (remove-old-embeddings-and-reset-new-updates! conn tx-data tx-meta)
 
                    (let [tx-meta (merge (batch-tx/get-batch-opts) tx-meta)

src/main/frontend/worker/rtc/db_listener.cljs

@@ -2,6 +2,7 @@
   "listen datascript changes, infer operations from the db tx-report"
   (:require [frontend.worker.db-listener :as db-listener]
             [frontend.worker.rtc.client-op :as client-op]
+            [frontend.worker.rtc.debug-log :as rtc-debug-log]
             [frontend.worker.rtc.gen-client-op :as gen-client-op]))
 
 (comment
@@ -12,9 +13,10 @@
 (defmethod db-listener/listen-db-changes :gen-rtc-ops
   [_
    {:keys [repo same-entity-datoms-coll id->same-entity-datoms]}
-   {:keys [_tx-data tx-meta db-before db-after]}]
+   {:keys [tx-data tx-meta db-before db-after]}]
   (when (and (client-op/rtc-db-graph? repo)
              (:persist-op? tx-meta true))
+    (rtc-debug-log/log-tx! repo tx-data tx-meta)
     (let [e->a->add?->v->t (update-vals
                             id->same-entity-datoms
                             gen-client-op/entity-datoms=>a->add?->v->t)

src/main/frontend/worker/rtc/debug_log.cljs

@@ -1,8 +1,7 @@
 (ns frontend.worker.rtc.debug-log
   "RTC debug logging stored in per-graph sqlite db."
   (:require [frontend.worker.state :as worker-state]
-            [lambdaisland.glogi :as log]
-            [logseq.db :as ldb]))
+            [lambdaisland.glogi :as log]))
 
 (defn create-tables!
   [^js db]
@@ -27,13 +26,6 @@
           (log/error :rtc-debug-log-gc-failed {:table table :error e}))))
     (.exec db "VACUUM")))
 
-(defn- enabled?
-  [repo]
-  (some-> (worker-state/get-datascript-conn repo)
-          deref
-          ldb/get-graph-rtc-uuid
-          some?))
-
 (defn- safe-str
   [value]
   (try
@@ -51,7 +43,7 @@
 
 (defn log-tx!
   [repo tx-data tx-meta]
-  (when (and repo (enabled? repo))
+  (when repo
     (when-let [db (worker-state/get-sqlite-conn repo :debug-log)]
       (insert! db
                "INSERT INTO tx_log (tx_data, tx_meta) VALUES (?1, ?2)"