enhance(rtc.asset): update new-task--upload-assets

feat/asset-sync
rcmerci 2024-07-09 18:19:40 +08:00
parent a0ef7b3407
commit 40a5f12fbd
2 changed files with 9 additions and 6 deletions

View File

@ -52,15 +52,18 @@
{:pre [(every? uuid? asset-uuids)]}
(m/sp
(when (seq asset-uuids)
(let [asset-uuid->url (->> (m/? (ws-util/send&recv get-ws-create-task {:action "get-assets-upload-urls"
(let [asset-uuid->url (->> (m/? (ws-util/send&recv get-ws-create-task
{:action "get-assets-upload-urls"
:graph-uuid graph-uuid
:asset-uuids asset-uuids}))
:asset-uuid->metadata
(into {}
(map (fn [asset-uuid] [asset-uuid {"checksum" "TEST-CHECKSUM"}]))
asset-uuids)}))
:asset-uuid->url)]
(doseq [[asset-uuid put-url] asset-uuid->url]
(assert (uuid? asset-uuid) asset-uuid)
(let [{:keys [status] :as r}
(m/? (c.m/<! (http/put put-url {:headers {"x-amz-meta-checksum" "TEST"}
:body (js/JSON.stringify
(m/? (c.m/<! (http/put put-url {:body (js/JSON.stringify
(clj->js {:TEST-ASSET true
:asset-uuid (str asset-uuid)
:graph-uuid (str graph-uuid)}))

View File

@ -236,7 +236,7 @@
[:req-id :string]
[:action :string]
[:graph-uuid :string]
[:asset-uuids [:sequential :uuid]]]]
[:asset-uuid->metadata [:map-of :uuid [:map-of :string :string]]]]]
["get-assets-download-urls"
[:map
[:req-id :string]