lnbits-rs 0.9.2

//! LNbits api

use std::fmt;

use anyhow::{bail, Result};

pub mod invoice;
pub mod payment;
pub mod wallet;
pub mod websocket;

/// LNbits api key type
#[derive(Debug, Clone, Hash)]
pub enum LNBitsRequestKey {
    /// Admin api key
    Admin,
    /// Read invoice api key
    InvoiceRead,
}

/// LNbits endpoints
#[derive(Debug, Clone, Hash)]
pub enum LNBitsEndpoint {
    /// Payments endpoint
    Payments,
    /// Decode payments endpoint
    PaymentsDecode,
    /// Payments endpoint with hash
    PaymentHash(String),
    /// Wallet info endpoint
    Wallet,
}

impl fmt::Display for LNBitsEndpoint {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            LNBitsEndpoint::Payments => write!(f, "api/v1/payments"),
            LNBitsEndpoint::PaymentsDecode => write!(f, "api/v1/payments/decode"),
            LNBitsEndpoint::PaymentHash(hash) => write!(f, "api/v1/payments/{}", hash),
            LNBitsEndpoint::Wallet => write!(f, "api/v1/wallet"),
        }
    }
}

impl crate::LNBitsClient {
    /// Make get request
    pub async fn make_get(
        &self,
        endpoint: LNBitsEndpoint,
        key: LNBitsRequestKey,
    ) -> Result<String> {
        let url = self.lnbits_url.join(&endpoint.to_string())?;
        let response = self
            .reqwest_client
            .get(url)
            .header("x-api-key", {
                match key {
                    LNBitsRequestKey::Admin => self.admin_key.clone(),
                    LNBitsRequestKey::InvoiceRead => self.invoice_read_key.clone(),
                }
            })
            .send()
            .await?;

        if response.status() == reqwest::StatusCode::NOT_FOUND {
            println!("{:?}", response);
            bail!("Not found")
        }

        let body = response.text().await?;

        Ok(body)
    }

    /// Make post request
    pub async fn make_post(
        &self,
        endpoint: LNBitsEndpoint,
        key: LNBitsRequestKey,
        body: &str,
    ) -> Result<String> {
        let url = self.lnbits_url.join(&endpoint.to_string())?;
        let response = self
            .reqwest_client
            .post(url)
            .header("X-Api-Key", {
                match key {
                    LNBitsRequestKey::Admin => self.admin_key.clone(),
                    LNBitsRequestKey::InvoiceRead => self.invoice_read_key.clone(),
                }
            })
            .body(body.to_string())
            .send()
            .await?;

        if response.status() == reqwest::StatusCode::NOT_FOUND {
            println!("{:?}", response);
            println!("{:?}", response.text().await.unwrap());
            bail!("Not Found")
        }

        if response.status() == reqwest::StatusCode::UNAUTHORIZED {
            bail!("Unauthorized")
        }

        let body = response.text().await?;

        Ok(body)
    }
}