bright-lightning 0.1.6

use base64::prelude::*;
use lightning_invoice::Bolt11Invoice;
use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq, Hash)]
pub struct LnAddressPaymentRequest {
    pub pr: String,
}
impl LnAddressPaymentRequest {
    #[cfg(not(target_arch = "wasm32"))]
    pub async fn new(
        address: &LightningAddress,
        millisatoshis: u64,
        client: &reqwest::Client,
    ) -> anyhow::Result<Self> {
        let confirmation = LnAddressConfirmation::new(address, client).await?;
        tracing::info!("Confirmation: {:?}", confirmation);
        if millisatoshis < confirmation.min_sendable {
            return Err(anyhow::anyhow!("Amount too low"));
        }
        let pr_url = format!("{}?amount={}", confirmation.callback, millisatoshis);
        let pay_request_fetch = client.get(&pr_url).send().await?.text().await?;
        tracing::debug!("Pay request: {}", pay_request_fetch);
        Self::try_from(pay_request_fetch)
    }
    pub fn r_hash(&self) -> anyhow::Result<String> {
        let r_hash_b = self
            .pr
            .parse::<Bolt11Invoice>()
            .map_err(|e| anyhow::anyhow!(e.to_string()))?;
        let r_hash = BASE64_STANDARD.encode(r_hash_b.payment_hash());
        Ok(r_hash)
    }
    pub fn r_hash_url_safe(&self) -> anyhow::Result<String> {
        let r_hash = self
            .pr
            .parse::<Bolt11Invoice>()
            .map_err(|e| anyhow::anyhow!(e.to_string()))?;
        let url_safe = BASE64_URL_SAFE.encode(r_hash.payment_hash());
        Ok(url_safe)
    }
}
impl std::fmt::Display for LnAddressPaymentRequest {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "{}", serde_json::to_string(self).unwrap_or_default())
    }
}
impl TryFrom<String> for LnAddressPaymentRequest {
    type Error = anyhow::Error;
    fn try_from(value: String) -> Result<Self, Self::Error> {
        Ok(serde_json::from_str(&value)?)
    }
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct LnAddressConfirmation {
    pub callback: String,
    #[serde(rename = "minSendable")]
    pub min_sendable: u64,
    #[serde(rename = "maxSendable")]
    pub max_sendable: u64,
}
impl LnAddressConfirmation {
    #[cfg(not(target_arch = "wasm32"))]
    pub async fn new(address: &LightningAddress, client: &reqwest::Client) -> anyhow::Result<Self> {
        let (user, domain) = address
            .0
            .split_once('@')
            .ok_or_else(|| anyhow::anyhow!("Invalid address"))?;
        let url = format!("https://{domain}/.well-known/lnurlp/{user}");
        let response = client.get(&url).send().await?.text().await?;
        Self::try_from(response)
    }
}
impl std::fmt::Display for LnAddressConfirmation {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "{}", serde_json::to_string(self).unwrap_or_default())
    }
}
impl TryFrom<String> for LnAddressConfirmation {
    type Error = anyhow::Error;
    fn try_from(value: String) -> Result<Self, Self::Error> {
        Ok(serde_json::from_str(&value)?)
    }
}

pub struct LightningAddress(pub &'static str);
impl LightningAddress {
    #[cfg(not(target_arch = "wasm32"))]
    pub async fn get_invoice(
        &self,
        client: &reqwest::Client,
        millisatoshis: u64,
    ) -> anyhow::Result<LnAddressPaymentRequest> {
        LnAddressPaymentRequest::new(self, millisatoshis, client).await
    }
}

#[cfg(test)]
mod tests {

    use super::*;

    #[tokio::test]
    #[tracing_test::traced_test]
    pub async fn get_ln_url_invoice() -> Result<(), anyhow::Error> {
        let client = reqwest::Client::new();
        let address = LightningAddress("42pupusas@blink.sv");
        let invoice = address.get_invoice(&client, 1000).await?;
        tracing::info!("Invoice: {:?}", invoice);
        Ok(())
    }
}