Upload profile pic to nostr.build

mutiny-core/Cargo.toml

@@ -35,7 +35,7 @@ lightning-transaction-sync = { version = "0.0.118", features = ["esplora-async-h
 lightning-liquidity = { git = "https://github.com/johncantrell97/ldk-lsp-client.git", rev = "9e01757d20c04aa31c28de8c4ffab5442d547edc" }
 chrono = "0.4.22"
 futures-util = { version = "0.3", default-features = false }
-reqwest = { version = "0.11", default-features = false, features = ["json"] }
+reqwest = { version = "0.11", default-features = false, features = ["multipart", "json"] }
 async-trait = "0.1.68"
 url = { version = "2.3.1", features = ["serde"] }
 nostr = { version = "0.27.0", default-features = false, features = ["nip04", "nip05", "nip47", "nip57"] }

mutiny-core/src/lib.rs

@@ -87,6 +87,7 @@ use lightning::{log_error, log_info, log_warn};
 use lightning_invoice::{Bolt11Invoice, Bolt11InvoiceDescription};
 use lnurl::{lnurl::LnUrl, AsyncClient as LnUrlClient, LnUrlResponse, Response};
 use nostr_sdk::{Client, RelayPoolNotification};
+use reqwest::multipart::{Form, Part};
 use serde::{Deserialize, Serialize};
 use serde_json::{json, Value};
 use std::sync::Arc;
@@ -1384,6 +1385,42 @@ impl<S: MutinyStorage> MutinyWallet<S> {
         Ok(())
     }
 
+    /// Uploads a profile pic to nostr.build and returns the uploaded file's URL
+    pub async fn upload_profile_pic(&self, image_bytes: Vec<u8>) -> Result<String, MutinyError> {
+        let client = reqwest::Client::new();
+
+        let form = Form::new().part("fileToUpload", Part::bytes(image_bytes));
+        let res: NostrBuildResult = client
+            .post("https://nostr.build/api/v2/upload/profile")
+            .multipart(form)
+            .send()
+            .await
+            .map_err(|_| MutinyError::NostrError)?
+            .json()
+            .await
+            .map_err(|_| MutinyError::NostrError)?;
+
+        if res.status != "success" {
+            log_error!(
+                self.logger,
+                "Error uploading profile picture: {}",
+                res.message
+            );
+            return Err(MutinyError::NostrError);
+        }
+
+        // get url from response body
+        if let Some(value) = res.data.first() {
+            return value
+                .get("url")
+                .and_then(|v| v.as_str())
+                .map(|s| s.to_string())
+                .ok_or(MutinyError::NostrError);
+        }
+
+        Err(MutinyError::NostrError)
+    }
+
     /// Makes a request to the primal api
     async fn primal_request(
         client: &reqwest::Client,
@@ -2106,6 +2143,13 @@ pub(crate) async fn create_new_federation<S: MutinyStorage>(
     })
 }
 
+#[derive(Deserialize)]
+struct NostrBuildResult {
+    status: String,
+    message: String,
+    data: Vec<Value>,
+}
+
 #[cfg(test)]
 mod tests {
     use crate::{

mutiny-wasm/Cargo.toml

@@ -43,6 +43,7 @@ urlencoding = "2.1.2"
 once_cell = "1.18.0"
 payjoin = { version = "0.13.0", features = ["send", "base64"] }
 fedimint-core = "0.2.1"
+base64 = "0.13.0"
 
 # The `console_error_panic_hook` crate provides better debugging of panics by
 # logging them with `console.error`. This is great for development, but requires

mutiny-wasm/src/error.rs

@@ -232,6 +232,12 @@ impl From<MutinyStorageError> for MutinyJsError {
     }
 }
 
+impl From<base64::DecodeError> for MutinyJsError {
+    fn from(_e: base64::DecodeError) -> Self {
+        Self::InvalidArgumentsError
+    }
+}
+
 impl From<bip39::Error> for MutinyJsError {
     fn from(_e: bip39::Error) -> Self {
         Self::InvalidMnemonic

mutiny-wasm/src/lib.rs

@@ -1674,6 +1674,12 @@ impl MutinyWallet {
         Ok(event_id.to_hex())
     }
 
+    /// Uploads a profile pic to nostr.build and returns the uploaded file's URL
+    pub async fn upload_profile_pic(&self, img_base64: String) -> Result<String, MutinyJsError> {
+        let bytes = base64::decode(&img_base64)?;
+        Ok(self.inner.upload_profile_pic(bytes).await?)
+    }
+
     /// Resets the scorer and network graph. This can be useful if you get stuck in a bad state.
     #[wasm_bindgen]
     pub async fn reset_router(&self) -> Result<(), MutinyJsError> {