diff --git a/src/main/frontend/handler/assets.cljs b/src/main/frontend/handler/assets.cljs
index a56ae54627..50b32ddc82 100644
--- a/src/main/frontend/handler/assets.cljs
+++ b/src/main/frontend/handler/assets.cljs
@@ -1,5 +1,7 @@
 (ns ^:no-doc frontend.handler.assets
-  (:require [clojure.string :as string]
+  (:require [cljs-http.client :as http]
+            [clojure.string :as string]
+            [frontend.common.missionary-util :as c.m]
             [frontend.config :as config]
             [frontend.fs :as fs]
             [frontend.fs.nfs :as nfs]
@@ -10,6 +12,7 @@
             [logseq.common.path :as path]
             [logseq.common.util :as common-util]
             [medley.core :as medley]
+            [missionary.core :as m]
             [promesa.core :as p]))
 
 (defn alias-enabled?
@@ -248,6 +251,25 @@
                                   (str asset-block-id-str "." asset-type))]
     (fs/write-file! repo repo-dir file-path data {})))
 
+(defn new-task--rtc-upload-asset
+  [repo asset-block-uuid-str asset-type put-url]
+  (m/sp
+    (let [asset-file (c.m/<? (<read-asset repo asset-block-uuid-str asset-type))
+          {:keys [status] :as r}
+          (c.m/<? (http/put put-url {:headers {"x-amz-meta-checksum" "TODO-CHECKSUM-HERE"}
+                                     :body asset-file
+                                     :with-credentials? false}))]
+      (when-not (http/unexceptional-status? status)
+        (throw (ex-info "upload asset failed" {:type :rtc.exception/upload-asset-failed :data r}))))))
+
+(defn new-task--rtc-download-asset
+  [repo asset-block-uuid-str asset-type get-url]
+  (m/sp
+    (let [{:keys [status body] :as r} (c.m/<? (http/get get-url {:with-credentials? false}))]
+      (when-not (http/unexceptional-status? status)
+        (throw (ex-info "download asset failed" {:type :rtc.exception/download-asset-failed :data r})))
+      (c.m/<? (<write-asset repo asset-block-uuid-str asset-type body)))))
+
 (comment
   ;; read asset
   (p/let [repo "logseq_db_demo"
diff --git a/src/main/frontend/persist_db/browser.cljs b/src/main/frontend/persist_db/browser.cljs
index 3fb80668d5..612f101001 100644
--- a/src/main/frontend/persist_db/browser.cljs
+++ b/src/main/frontend/persist_db/browser.cljs
@@ -85,12 +85,24 @@
                  (ldb/write-transit-str context))
       (notification/show! "Latest change was not saved! Please restart the application." :error))))
 
+(defn- with-write-transit-str
+  [p]
+  (p/chain p ldb/write-transit-str))
+
 (deftype Main []
   Object
   (readAsset [_this repo asset-block-id asset-type]
     (assets-handler/<read-asset repo asset-block-id asset-type))
   (writeAsset [_this repo asset-block-id asset-type data]
     (assets-handler/<write-asset repo asset-block-id asset-type data))
+  (rtc-upload-asset [_this repo asset-block-uuid-str asset-type put-url]
+    (with-write-transit-str
+      (js/Promise.
+       (assets-handler/new-task--rtc-upload-asset repo asset-block-uuid-str asset-type put-url))))
+  (rtc-download-asset [_this repo asset-block-uuid-str asset-type get-url]
+    (with-write-transit-str
+      (js/Promise.
+       (assets-handler/new-task--rtc-download-asset repo asset-block-uuid-str asset-type get-url))))
   (testFn [_this]
     (prn :debug :works)))