/*
 * Copyright (C) 2025 Jonni Liljamo <jonni@liljamo.com>
 *
 * This file is licensed under AGPL-3.0-or-later, see NOTICE and LICENSE for
 * more information.
 */

use async_trait::async_trait;
use serde::{Deserialize, Serialize};

use crate::{
    config::{ServiceConfig, deserialize_token},
    routes::message::MessageForm,
};

use super::Service;

#[derive(Clone, Deserialize, Serialize)]
pub struct GotifyConfig {
    pub instance: String,
    #[serde(deserialize_with = "deserialize_token")]
    pub token: String,
}

#[typetag::serde(name = "gotify")]
impl ServiceConfig for GotifyConfig {
    fn as_any(&self) -> &dyn std::any::Any {
        self
    }
}

pub struct GotifyService {
    client: reqwest::Client,
    config: GotifyConfig,
}

impl GotifyService {
    pub fn new(
        client: reqwest::Client,
        config: GotifyConfig,
    ) -> Result<Self, Box<dyn std::error::Error>> {
        Ok(Self { client, config })
    }
}

#[async_trait]
impl Service for GotifyService {
    async fn send(
        &self,
        form: &MessageForm,
    ) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
        let _ = self
            .client
            .post(format!("{}/message", self.config.instance))
            .query(&[("token", &self.config.token)])
            .form(&[("title", &form.title), ("message", &form.message)])
            .send()
            .await?;
        Ok(())
    }
}

#[cfg(test)]
mod tests {
    use crate::config::Config;

    use super::*;

    #[tokio::test]
    async fn config() {
        Config::from_str(
            r#"
        [services.g]
        type = "gotify"
        instance = "gotify.tld"
        token = "secret"
        "#,
        )
        .await
        .unwrap()
        .services["g"]
            .as_any()
            .downcast_ref::<GotifyConfig>()
            .unwrap();
    }
}