esteria-api-client 0.0.20

use chrono::{DateTime, Utc};
use reqwest::Client;
use std::collections::HashMap;
use thiserror::Error;

/// Error types for SMS operations
#[derive(Error, Debug)]
pub enum SmsError {
    #[error("SMS sending failed to: {number}, {message}")]
    SendFailed { number: String, message: String },
    #[error("HTTP request failed: {0}")]
    RequestFailed(#[from] reqwest::Error),
}

bitflags::bitflags! {
    /// Flags for SMS sending options
    #[derive(Debug, Clone, Copy, Default, PartialEq, Eq)]
    pub struct SmsFlags: u32 {
        /// Enable debug mode
        const DEBUG   = 0b0000_0001;
        /// Disable logging
        const NOLOG   = 0b0000_0010;
        /// Send as flash SMS
        const FLASH   = 0b0000_0100;
        /// Test mode (don't actually send)
        const TEST    = 0b0000_1000;
        /// No blacklist check
        const NOBL    = 0b0001_0000;
        /// Convert characters
        const CONVERT = 0b0010_0000;
    }
}

/// SMS encoding options
#[derive(Debug, Clone, Copy)]
pub enum Encoding {
    /// Default encoding
    Default,
    /// 8-bit encoding
    EightBit,
    /// User Data Header encoding
    Udh,
}

/// SMS API client for Esteria
pub struct SmsClient {
    api_base_url: String,
    client: Client,
}

/// Request structure for sending SMS
pub struct SmsRequest<'a> {
    pub api_key: &'a str,
    pub sender: &'a str,
    pub number: &'a str,
    pub text: &'a str,
    pub time: Option<DateTime<Utc>>,
    pub dlr_url: Option<&'a str>,
    pub expired: Option<i32>,
    pub flags: SmsFlags,
    pub user_key: Option<&'a str>,
    pub encoding: Encoding,
}

impl<'a> SmsRequest<'a> {
    /// Create a new SMS request with required parameters
    #[must_use]
    pub fn new(api_key: &'a str, sender: &'a str, number: &'a str, text: &'a str) -> Self {
        Self {
            api_key,
            sender,
            number,
            text,
            time: None,
            dlr_url: None,
            expired: None,
            flags: SmsFlags::empty(),
            user_key: None,
            encoding: Encoding::EightBit,
        }
    }

    /// Set scheduled delivery time
    #[must_use]
    pub fn with_time(mut self, time: DateTime<Utc>) -> Self {
        self.time = Some(time);
        self
    }

    /// Set delivery report URL
    #[must_use]
    pub fn with_dlr_url(mut self, dlr_url: &'a str) -> Self {
        self.dlr_url = Some(dlr_url);
        self
    }

    /// Set expiration time in minutes
    #[must_use]
    pub fn with_expired(mut self, expired: i32) -> Self {
        self.expired = Some(expired);
        self
    }

    /// Set SMS flags
    #[must_use]
    pub fn with_flags(mut self, flags: SmsFlags) -> Self {
        self.flags = flags;
        self
    }

    /// Set user key for tracking
    #[must_use]
    pub fn with_user_key(mut self, user_key: &'a str) -> Self {
        self.user_key = Some(user_key);
        self
    }

    /// Set encoding
    #[must_use]
    pub fn with_encoding(mut self, encoding: Encoding) -> Self {
        self.encoding = encoding;
        self
    }
}

impl Default for SmsClient {
    fn default() -> Self {
        Self::with_api_base_url("https://api.esteria.eu")
    }
}

impl SmsClient {
    /// Create a new SMS client using the default API base URL
    #[allow(dead_code)]
    #[must_use]
    pub fn new() -> Self {
        Self::default()
    }

    /// Create a new SMS client with a custom API base URL
    #[must_use]
    pub fn with_api_base_url(api_base_url: impl Into<String>) -> Self {
        Self {
            api_base_url: api_base_url.into(),
            client: Client::new(),
        }
    }

    /// Send an SMS message
    ///
    /// Returns the message ID on success (> 100)
    ///
    /// # Errors
    ///
    /// Returns `SmsError::SendFailed` if the API returns an error code (< 100)
    /// or `SmsError::RequestFailed` if the HTTP request fails
    pub async fn send_sms(&self, request: SmsRequest<'_>) -> Result<String, SmsError> {
        let mut params: HashMap<&str, String> = HashMap::new();

        params.insert("api-key", request.api_key.to_string());
        params.insert("sender", request.sender.to_string());
        params.insert("number", request.number.trim_start_matches('+').to_string());
        params.insert("text", request.text.to_string());

        if let Some(time) = request.time {
            params.insert("time", time.format("%Y-%m-%dT%H:%M:%S").to_string());
        }

        if let Some(dlr_url) = request.dlr_url {
            params.insert("dlr-url", dlr_url.to_string());
        }

        if let Some(expired) = request.expired {
            params.insert("expired", expired.to_string());
        }

        if request.flags.contains(SmsFlags::DEBUG) {
            params.insert("flag-debug", "1".to_string());
        }

        if request.flags.contains(SmsFlags::NOLOG) {
            params.insert("flag-nolog", "3".to_string());
        }

        if request.flags.contains(SmsFlags::FLASH) {
            params.insert("flag-flash", "1".to_string());
        }

        if request.flags.contains(SmsFlags::TEST) {
            params.insert("flag-test", "1".to_string());
        }

        if request.flags.contains(SmsFlags::NOBL) {
            params.insert("flag-nobl", "1".to_string());
        }

        if request.flags.contains(SmsFlags::CONVERT) {
            params.insert("flag-convert", "1".to_string());
        }

        if let Some(user_key) = request.user_key {
            params.insert("user-key", user_key.to_string());
        }

        match request.encoding {
            Encoding::Udh => {
                params.insert("udh", "1".to_string());
                params.insert("coding", "1".to_string());
            }
            Encoding::EightBit => {
                params.insert("coding", "1".to_string());
            }
            Encoding::Default => {}
        }

        let url = format!("{}/send", self.api_base_url);
        let response = self.client.get(&url).query(&params).send().await?;

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

        let result = resp_text.trim().parse::<i128>().ok();

        if let Some(code) = result {
            if code > 100 {
                return Ok(resp_text);
            }

            let error_msg = get_response_code_message(code);
            log::error!("SMS sending failed to: {}, {}", request.number, error_msg);

            return Err(SmsError::SendFailed {
                number: request.number.to_string(),
                message: error_msg.to_string(),
            });
        }

        log::error!("SMS sending failed to: {}, unknown error", request.number);
        Err(SmsError::SendFailed {
            number: request.number.to_string(),
            message: "unknown error".to_string(),
        })
    }
}

fn get_response_code_message(code: i128) -> &'static str {
    match code {
        1 => "system internal error",
        2 => "missing PARAM_NAME parameter",
        3 => "unable to authenticate",
        4 => "IP ADDRESS is not allowed",
        5 => "invalid SENDER parameter",
        6 => "SENDER is not allowed",
        7 => "invalid NUMBER parameter",
        8 => "invalid CODING parameter",
        9 => "unable to convert TEXT",
        10 => "length of UDH and TEXT too long",
        11 => "empty TEXT parameter",
        12 => "invalid TIME parameter",
        13 => "invalid EXPIRED parameter",
        14 => "invalid DLR-URL parameter",
        15 => "Invalid FLAG-FLASH parameter",
        16 => "invalid FLAG-NOLOG parameter",
        17 => "invalid FLAG-TEST parameter",
        18 => "invalid FLAG-NOBL parameter",
        19 => "invalid FLAG-CONVERT parameter",
        _ => "unknown error",
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use chrono::TimeZone;
    use httpmock::prelude::*;

    fn base_request<'a>() -> SmsRequest<'a> {
        SmsRequest::new("k", "Alice", "+1234567890", "Hello")
    }

    #[tokio::test]
    async fn send_sms_success_and_params() {
        let server = MockServer::start();

        // Build flags and encoding to verify query mapping
        let mut flags = SmsFlags::empty();
        flags |= SmsFlags::DEBUG
            | SmsFlags::NOLOG
            | SmsFlags::FLASH
            | SmsFlags::TEST
            | SmsFlags::NOBL
            | SmsFlags::CONVERT;

        let time = Utc.with_ymd_and_hms(2025, 1, 2, 3, 4, 5).unwrap();

        let req = base_request()
            .with_time(time)
            .with_dlr_url("https://example.com/dlr")
            .with_expired(60)
            .with_flags(flags)
            .with_user_key("ukey")
            .with_encoding(Encoding::Udh);

        // Expect all query params and return success code (>100)
        let m = server.mock(|when, then| {
            when.method(GET)
                .path("/send")
                .query_param("api-key", "k")
                .query_param("sender", "Alice")
                .query_param("number", "1234567890") // plus sign trimmed
                .query_param("text", "Hello")
                .query_param("time", "2025-01-02T03:04:05")
                .query_param("dlr-url", "https://example.com/dlr")
                .query_param("expired", "60")
                .query_param("flag-debug", "1")
                .query_param("flag-nolog", "3")
                .query_param("flag-flash", "1")
                .query_param("flag-test", "1")
                .query_param("flag-nobl", "1")
                .query_param("flag-convert", "1")
                .query_param("user-key", "ukey")
                .query_param("udh", "1")
                .query_param("coding", "1");
            then.status(200).body("1234");
        });

        let client = SmsClient::with_api_base_url(server.base_url());
        let code = client.send_sms(req).await.unwrap();
        assert_eq!(code, "1234");
        m.assert();
    }

    #[tokio::test]
    async fn send_sms_api_error_mapped() {
        let server = MockServer::start();
        let m = server.mock(|when, then| {
            when.method(GET).path("/send");
            then.status(200).body("3"); // 3 => unable to authenticate
        });

        let client = SmsClient::with_api_base_url(server.base_url());
        let err = client.send_sms(base_request()).await.unwrap_err();
        match err {
            SmsError::SendFailed { number, message } => {
                assert_eq!(number, "+1234567890");
                assert_eq!(message, "unable to authenticate");
            }
            SmsError::RequestFailed(err) => panic!("Unexpected error type: {err}"),
        }
        m.assert();
    }

    #[tokio::test]
    async fn send_sms_unknown_text_maps_to_unknown_error() {
        let server = MockServer::start();
        let m = server.mock(|when, then| {
            when.method(GET).path("/send");
            then.status(200).body("not-a-number");
        });

        let client = SmsClient::with_api_base_url(server.base_url());
        let err = client.send_sms(base_request()).await.unwrap_err();
        match err {
            SmsError::SendFailed { number, message } => {
                assert_eq!(number, "+1234567890");
                assert_eq!(message, "unknown error");
            }
            SmsError::RequestFailed(err) => panic!("Unexpected error type: {err}"),
        }
        m.assert();
    }

    #[tokio::test]
    async fn send_sms_http_failure_is_request_failed() {
        // Use a non-routable private address to provoke connection error
        let client = SmsClient::with_api_base_url("http://10.255.255.1".to_string());
        let err = client.send_sms(base_request()).await.unwrap_err();
        matches!(err, SmsError::RequestFailed(_));
    }

    #[test]
    fn builder_sets_fields_and_defaults() {
        let req = SmsRequest::new("key", "S", "N", "T");
        assert!(req.time.is_none());
        assert!(req.dlr_url.is_none());
        assert!(req.expired.is_none());
        assert!(req.user_key.is_none());
        assert_eq!(req.flags, SmsFlags::empty());
        matches!(req.encoding, Encoding::EightBit);
    }

    #[test]
    fn get_response_code_message_works() {
        assert_eq!(get_response_code_message(1), "system internal error");
        assert_eq!(
            get_response_code_message(19),
            "invalid FLAG-CONVERT parameter"
        );
        assert_eq!(get_response_code_message(999), "unknown error");
    }
}