test(rtc): update fixtures

src/rtc_e2e_test/download_upload_test.cljs

@@ -8,14 +8,17 @@
             [helper]
             [missionary.core :as m]))
 
-(t/use-fixtures :each fixture/install-example-db-fixture)
+(t/use-fixtures :once
+  fixture/install-some-consts
+  fixture/install-example-db-fixture
+  fixture/clear-test-remote-graphs-fixture)
 
 (deftest upload-graph-test
   (t/async
    done
    (c.m/run-task
     (m/sp
-      (let [{:keys [graph-uuid]} (m/? (helper/new-task--upload-example-graph))]
+      (let [{:keys [graph-uuid]} (m/? helper/new-task--upload-example-graph)]
         (m/? (helper/new-task--wait-creating-graph graph-uuid)))
       (done))
     :upload-graph-test)))

src/rtc_e2e_test/fixture.cljs

@@ -1,14 +1,22 @@
 (ns fixture
-  (:require [const]
+  (:require [cljs.test :as t]
+            [const]
             [datascript.core :as d]
             [example]
+            [frontend.common.missionary-util :as c.m]
             [frontend.worker.rtc.client-op :as client-op]
-            [frontend.worker.state :as worker-state]))
+            [frontend.worker.state :as worker-state]
+            [helper]
+            [missionary.core :as m]))
+
+(def install-some-consts
+  {:before
+   (fn []
+     (reset! worker-state/*rtc-ws-url "wss://ws-dev.logseq.com/rtc-sync?token=%s"))})
 
 (def install-example-db-fixture
   {:before
    (fn []
-     (reset! worker-state/*rtc-ws-url "wss://ws-dev.logseq.com/rtc-sync?token=%s")
      (swap! worker-state/*client-ops-conns assoc const/test-repo (d/create-conn client-op/schema-in-db))
      (let [conn (d/conn-from-db example/example-db)]
        (swap! worker-state/*datascript-conns assoc const/test-repo conn)))
@@ -16,3 +24,13 @@
    (fn []
      (swap! worker-state/*datascript-conns dissoc const/test-repo)
      (swap! worker-state/*client-ops-conns dissoc const/test-repo))})
+
+(def clear-test-remote-graphs-fixture
+  {:before
+   #(t/async
+     done
+     (c.m/run-task
+      (m/sp
+       (m/? helper/new-task--clear-all-test-remote-graphs)
+       (done))
+      :clear-test-remote-graphs))})

src/rtc_e2e_test/helper.cljs

@@ -4,8 +4,7 @@
             [frontend.worker.rtc.core :as rtc.core]
             [missionary.core :as m]))
 
-(defn new-task--upload-example-graph
-  []
+(def new-task--upload-example-graph
   (rtc.core/new-task--upload-graph const/test-token const/test-repo const/test-repo))
 
 (defn new-task--wait-creating-graph
@@ -20,3 +19,13 @@
        (prn "waiting for graph " graph-uuid " finish creating")
        (when (= "creating" (:graph-status graph))
          (throw (ex-info "wait creating-graph" {:missionary/retry true})))))))
+
+(def new-task--clear-all-test-remote-graphs
+  (m/sp
+    (let [graphs (m/? (rtc.core/new-task--get-graphs const/test-token))
+          test-graphs (filter (fn [graph]
+                                (and (= const/test-repo (:graph-name graph))
+                                     (not= "deleting" (:graph-status graph))))
+                              graphs)]
+      (doseq [graph test-graphs]
+        (m/? (rtc.core/new-task--delete-graph const/test-token (:graph-uuid graph)))))))