From 60e404902df8a0d32a4d31fa3feaedb8696e4688 Mon Sep 17 00:00:00 2001
From: rcmerci <rcmerci@gmail.com>
Date: Fri, 10 Nov 2023 23:48:05 +0800
Subject: [PATCH] fix(rtc): upload-graph

---
 src/main/frontend/db/rtc/const.cljs                      | 2 +-
 src/main/frontend/db/rtc/debug_ui.cljs                   | 6 +++++-
 src/main/frontend/db/rtc/full_upload_download_graph.cljs | 4 +++-
 3 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/src/main/frontend/db/rtc/const.cljs b/src/main/frontend/db/rtc/const.cljs
index 849c0965de..e98985f271 100644
--- a/src/main/frontend/db/rtc/const.cljs
+++ b/src/main/frontend/db/rtc/const.cljs
@@ -14,7 +14,7 @@
    [:tags {:optional true} [:maybe [:sequential :uuid]]]
    [:properties {:optional true} [:maybe :string ; transit-json-string
                                   ]]
-   [:link {:optional true} :uuid]])
+   [:link {:optional true} [:maybe :uuid]]])
 
 (def general-attr-set
   (into #{} (map first) general-attrs-schema-coll))
diff --git a/src/main/frontend/db/rtc/debug_ui.cljs b/src/main/frontend/db/rtc/debug_ui.cljs
index 7ca2df60ec..f02daa4b98 100644
--- a/src/main/frontend/db/rtc/debug_ui.cljs
+++ b/src/main/frontend/db/rtc/debug_ui.cljs
@@ -5,7 +5,9 @@
   (:require [cljs.core.async :as async :refer [<! go]]
             [fipp.edn :as fipp]
             [frontend.db :as db]
+            [frontend.db.conn :as conn]
             [frontend.db.rtc.core :as rtc-core]
+            [frontend.db.rtc.db-listener :as db-listener]
             [frontend.db.rtc.full-upload-download-graph :as full-upload-download-graph]
             [frontend.db.rtc.op-mem-layer :as op-mem-layer]
             [frontend.db.rtc.ws :as ws]
@@ -58,7 +60,9 @@
   (go
     (let [state (<! (rtc-core/<init-state))
           repo (state/get-current-repo)]
-      (<! (full-upload-download-graph/<upload-graph state repo)))))
+      (<! (full-upload-download-graph/<upload-graph state repo))
+      (let [conn (conn/get-db repo false)]
+        (db-listener/listen-db-to-generate-ops repo conn)))))
 
 (rum/defcs ^:large-vars/cleanup-todo rtc-debug-ui <
   rum/reactive
diff --git a/src/main/frontend/db/rtc/full_upload_download_graph.cljs b/src/main/frontend/db/rtc/full_upload_download_graph.cljs
index d7b7c4c799..191ab14f60 100644
--- a/src/main/frontend/db/rtc/full_upload_download_graph.cljs
+++ b/src/main/frontend/db/rtc/full_upload_download_graph.cljs
@@ -51,8 +51,10 @@
         (let [r (<! (get-result-ch))]
           (if-not (:graph-uuid r)
             (ex-info "upload graph failed" r)
-            (do (op-mem-layer/update-graph-uuid! repo (:graph-uuid r))
+            (do (op-mem-layer/init-empty-ops-store! repo)
+                (op-mem-layer/update-graph-uuid! repo (:graph-uuid r))
                 (op-mem-layer/update-local-tx! repo (:t r))
+                (<! (op-mem-layer/<sync-to-idb-layer! repo))
                 r)))))))
 
 (def block-type-ident->str