From 632788e8e3e9849f6b0c9da867a1bf5c8f938e57 Mon Sep 17 00:00:00 2001
From: rcmerci <rcmerci@gmail.com>
Date: Tue, 3 Dec 2024 17:17:14 +0800
Subject: [PATCH] fix(rtc): delete-graph return a promise now

---
 src/main/frontend/common/async_util.cljc | 87 ++++++++++++++----------
 src/main/frontend/components/repo.cljs   | 19 +++---
 2 files changed, 61 insertions(+), 45 deletions(-)

diff --git a/src/main/frontend/common/async_util.cljc b/src/main/frontend/common/async_util.cljc
index 0487204ae1a..2d5b1dd60f5 100644
--- a/src/main/frontend/common/async_util.cljc
+++ b/src/main/frontend/common/async_util.cljc
@@ -3,7 +3,8 @@
    namespaces. See also: https://gist.github.com/vvvvalvalval/f1250cec76d3719a8343"
   #?(:cljs (:require [cljs.core.async.impl.channels :refer [ManyToManyChannel]]
                      [clojure.core.async :as async]
-                     [logseq.common.util :as common-util])))
+                     [logseq.common.util :as common-util]
+                     [promesa.core :as p])))
 
 #?(:cljs
    (defn throw-err
@@ -14,6 +15,20 @@
   [port]
   `(throw-err (cljs.core.async/<! ~port)))
 
+#?(:cljs
+   (defn c->p
+     "Converts a Core.async channel to a Promise"
+     [chan]
+     (let [d (p/deferred)]
+       (if chan
+         (async/go
+           (let [result (async/<! chan)]
+             (if (instance? ExceptionInfo result)
+               (p/reject! d result)
+               (p/resolve! d result))))
+         (p/resolve! d nil))
+       d)))
+
 #?(:cljs
    (defn drain-chan
      "drop all stuffs in CH, and return all of them"
@@ -23,7 +38,7 @@
 
 #?(:cljs
    (defn <ratelimit
-       "return a channel CH,
+     "return a channel CH,
   ratelimit flush items in in-ch every max-duration(ms),
   opts:
   - :filter-fn filter item before putting items into returned CH, (filter-fn item)
@@ -34,42 +49,42 @@
   - :chan-buffer buffer of return CH, default use (async/chan 1000)
   - :flush-now-ch flush the content in the queue immediately
   - :refresh-timeout-ch refresh (timeout max-duration)"
-       [in-ch max-duration & {:keys [filter-fn flush-fn stop-ch distinct-key-fn chan-buffer flush-now-ch refresh-timeout-ch]}]
-       (let [ch (if chan-buffer (async/chan chan-buffer) (async/chan 1000))
-             stop-ch* (or stop-ch (async/chan))
-             flush-now-ch* (or flush-now-ch (async/chan))
-             refresh-timeout-ch* (or refresh-timeout-ch (async/chan))]
-         (async/go-loop [timeout-ch (async/timeout max-duration) coll []]
-           (let [{:keys [refresh-timeout timeout e stop flush-now]}
-                 (async/alt! refresh-timeout-ch* {:refresh-timeout true}
-                             timeout-ch {:timeout true}
-                             in-ch ([e] {:e e})
-                             stop-ch* {:stop true}
-                             flush-now-ch* {:flush-now true})]
-             (cond
-               refresh-timeout
-               (recur (async/timeout max-duration) coll)
+     [in-ch max-duration & {:keys [filter-fn flush-fn stop-ch distinct-key-fn chan-buffer flush-now-ch refresh-timeout-ch]}]
+     (let [ch (if chan-buffer (async/chan chan-buffer) (async/chan 1000))
+           stop-ch* (or stop-ch (async/chan))
+           flush-now-ch* (or flush-now-ch (async/chan))
+           refresh-timeout-ch* (or refresh-timeout-ch (async/chan))]
+       (async/go-loop [timeout-ch (async/timeout max-duration) coll []]
+         (let [{:keys [refresh-timeout timeout e stop flush-now]}
+               (async/alt! refresh-timeout-ch* {:refresh-timeout true}
+                           timeout-ch {:timeout true}
+                           in-ch ([e] {:e e})
+                           stop-ch* {:stop true}
+                           flush-now-ch* {:flush-now true})]
+           (cond
+             refresh-timeout
+             (recur (async/timeout max-duration) coll)
 
-               (or flush-now timeout)
-               (do (async/onto-chan! ch coll false)
-                   (flush-fn coll)
-                   (drain-chan flush-now-ch*)
-                   (recur (async/timeout max-duration) []))
+             (or flush-now timeout)
+             (do (async/onto-chan! ch coll false)
+                 (flush-fn coll)
+                 (drain-chan flush-now-ch*)
+                 (recur (async/timeout max-duration) []))
 
-               (some? e)
-               (let [filter-v (filter-fn e)
-                     filter-v* (if (instance? ManyToManyChannel filter-v)
-                                 (async/<! filter-v)
-                                 filter-v)]
-                 (if filter-v*
-                   (recur timeout-ch (cond->> (conj coll e)
-                                       distinct-key-fn (common-util/distinct-by distinct-key-fn)
-                                       true vec))
-                   (recur timeout-ch coll)))
+             (some? e)
+             (let [filter-v (filter-fn e)
+                   filter-v* (if (instance? ManyToManyChannel filter-v)
+                               (async/<! filter-v)
+                               filter-v)]
+               (if filter-v*
+                 (recur timeout-ch (cond->> (conj coll e)
+                                     distinct-key-fn (common-util/distinct-by distinct-key-fn)
+                                     true vec))
+                 (recur timeout-ch coll)))
 
-               (or stop
+             (or stop
                  ;; got nil from in-ch, means in-ch is closed
                  ;; so we stop the whole go-loop
-                   (nil? e))
-               (async/close! ch))))
-         ch)))
+                 (nil? e))
+             (async/close! ch))))
+       ch)))
diff --git a/src/main/frontend/components/repo.cljs b/src/main/frontend/components/repo.cljs
index 6797fa3264a..1c1ff1e9026 100644
--- a/src/main/frontend/components/repo.cljs
+++ b/src/main/frontend/components/repo.cljs
@@ -1,7 +1,7 @@
 (ns frontend.components.repo
-  (:require [cljs.core.async :as async :refer [<! go]]
-            [clojure.string :as string]
+  (:require [clojure.string :as string]
             [electron.ipc :as ipc]
+            [frontend.common.async-util :as async-util]
             [frontend.config :as config]
             [frontend.context.i18n :refer [t]]
             [frontend.db :as db]
@@ -119,14 +119,15 @@
                                action-confirm-fn! (if only-cloud?
                                                     (fn []
                                                       (when (or manager? (not db-graph?))
-                                                        (let [delete-graph (if db-graph?
-                                                                             rtc-handler/<rtc-delete-graph!
-                                                                             file-sync/<delete-graph)]
+                                                        (let [<delete-graph (if db-graph?
+                                                                              rtc-handler/<rtc-delete-graph!
+                                                                              (fn [graph-uuid]
+                                                                                (async-util/c->p (file-sync/<delete-graph graph-uuid))))]
                                                           (state/set-state! [:file-sync/remote-graphs :loading] true)
-                                                          (go (<! (delete-graph GraphUUID))
-                                                              (state/delete-repo! repo)
-                                                              (state/delete-remote-graph! repo)
-                                                              (state/set-state! [:file-sync/remote-graphs :loading] false)))))
+                                                          (p/do! (<delete-graph GraphUUID)
+                                                                 (state/delete-repo! repo)
+                                                                 (state/delete-remote-graph! repo)
+                                                                 (state/set-state! [:file-sync/remote-graphs :loading] false)))))
                                                     unlink-or-remote-fn!)
                                confirm-fn!
                                (fn []