u-sdk 0.6.3

use super::utils::{de_option_empty_string_as_none, parse_json_response};
use super::{Client, Error, OPENAPI_STYLE, OPENAPI_VERSION};
use bon::Builder;
use serde::{Deserialize, Serialize, Serializer};
use std::collections::HashMap;
use time::OffsetDateTime;
use u_sdk_common::helper::into_header_map;
use u_sdk_common::open_api_sign::{SignParams, get_openapi_request_header};

//region ListSites request
/// [ListSites](https://help.aliyun.com/zh/edge-security-acceleration/esa/api-esa-2024-09-10-listsites)
#[serde_with::skip_serializing_none]
#[derive(Builder, Serialize)]
#[serde(rename_all = "PascalCase")]
pub struct ListSites<'a> {
    #[builder(start_fn)]
    #[serde(skip_serializing)]
    pub(crate) client: &'a Client,

    /// 标签过滤规则。 (Key, Value)
    #[builder(field)]
    #[serde(
        skip_serializing_if = "Vec::is_empty",
        serialize_with = "serialize_tag_filter_as_json_string"
    )]
    tag_filter: Vec<(Option<&'a str>, Option<&'a str>)>,

    /// 站点名称。用于查询的过滤条件。
    site_name: Option<&'a str>,

    /// 站点名称的搜索匹配模式。默认为精确匹配。
    site_search_type: Option<SiteSearchType>,

    /// 页码。默认值：1。
    page_number: Option<i32>,

    /// 分页大小。默认值：500。
    page_size: Option<i32>,

    /// 资源组 ID。用于查询的过滤条件。
    resource_group_id: Option<&'a str>,

    /// 站点状态。用于查询的过滤条件。
    status: Option<&'a str>,

    /// 仅企业版，传 true 时代表仅查询企业版的站点。
    only_enterprise: Option<bool>,

    /// 套餐订阅类型。
    plan_subscribe_type: Option<PlanSubscribeType>,

    /// 加速区域。
    coverage: Option<Coverage>,

    /// 接入类型。
    access_type: Option<AccessType>,

    /// 排序字段，默认按照创建时间排序。
    order_by: Option<OrderBy>,
}

impl<'a, S: list_sites_builder::State> ListSitesBuilder<'a, S> {
    /// 添加标签过滤规则
    pub fn tag_filter(mut self, item: (Option<&'a str>, Option<&'a str>)) -> Self {
        self.tag_filter.push(item);
        self
    }

    /// 批量添加标签过滤规则
    pub fn tag_filters(
        mut self,
        items: impl IntoIterator<Item = (Option<&'a str>, Option<&'a str>)>,
    ) -> Self {
        self.tag_filter.extend(items);
        self
    }
}

#[serde_with::skip_serializing_none]
#[derive(Serialize)]
#[serde(rename_all = "PascalCase")]
struct TagFilterItem<'a> {
    key: Option<&'a str>,
    value: Option<&'a str>,
}

pub fn serialize_tag_filter_as_json_string<'a, S>(
    tag_filter: &Vec<(Option<&'a str>, Option<&'a str>)>,
    serializer: S,
) -> Result<S::Ok, S::Error>
where
    S: Serializer,
{
    // 过滤掉 (None, None)，避免出现 "{}"
    let items: Vec<TagFilterItem<'a>> = tag_filter
        .iter()
        .filter(|(k, v)| k.is_some() || v.is_some())
        .map(|(k, v)| TagFilterItem { key: *k, value: *v })
        .collect();

    // 生成 JSON 字符串
    let json = serde_json::to_string(&items).map_err(serde::ser::Error::custom)?;

    // 按“字符串”序列化出去
    serializer.serialize_str(&json)
}

/// 站点名称搜索匹配模式：prefix/suffix/exact/fuzzy
#[derive(Serialize, Clone)]
#[serde(rename_all = "lowercase")]
pub enum SiteSearchType {
    Prefix,
    Suffix,
    Exact,
    Fuzzy,
}

/// 套餐订阅类型：basicplan/standardplan/advancedplan/enterpriseplan
#[derive(Serialize, Clone)]
pub enum PlanSubscribeType {
    #[serde(rename = "basicplan")]
    Basic,
    #[serde(rename = "standardplan")]
    Standard,
    #[serde(rename = "advancedplan")]
    Advanced,
    #[serde(rename = "enterpriseplan")]
    Enterprise,
}

/// 加速区域：domestic/global/overseas
#[derive(Serialize, Clone, Debug, Deserialize)]
#[serde(rename_all = "lowercase")]
pub enum Coverage {
    Domestic,
    Global,
    Overseas,
}

/// 接入类型：NS/CNAME（注意：API 值大小写敏感时建议按原样）
#[derive(Serialize, Clone, Debug, Deserialize)]
#[serde(rename_all = "UPPERCASE")]
pub enum AccessType {
    NS,
    CName,
}

/// 排序字段：gmtCreate/visitTime
#[derive(Serialize, Clone)]
#[serde(rename_all = "camelCase")]
pub enum OrderBy {
    GmtCreate,
    VisitTime,
}
//endregion

//region ListSites response
#[derive(Debug, Clone, Deserialize)]
#[serde(rename_all = "PascalCase")]
pub struct ListSitesResponse {
    /// 请求 ID
    pub request_id: String,

    /// 返回数据的页码
    pub page_number: i32,

    /// 每页显示的站点个数
    pub page_size: i32,

    /// 总站点数量
    pub total_count: i32,

    /// 查询到的站点信息列表
    pub sites: Vec<SiteInfo>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(rename_all = "PascalCase")]
pub struct SiteInfo {
    /// 站点接入类型
    pub access_type: AccessType,

    /// 站点的 CNAME 后缀
    pub cname_zone: String,

    /// 站点加速区域
    pub coverage: Coverage,

    /// 站点创建时间（ISO8601, UTC）
    #[serde(with = "time::serde::iso8601")]
    pub create_time: OffsetDateTime,

    /// 站点更新时间（ISO8601, UTC）
    #[serde(with = "time::serde::iso8601")]
    pub update_time: OffsetDateTime,

    /// 站点绑定的套餐实例 ID
    pub instance_id: String,

    /// 站点分配的 NS 列表，逗号分隔
    pub name_server_list: String,

    /// 套餐名称
    pub plan_name: String,

    /// 套餐规格名称
    pub plan_spec_name: Option<String>,

    /// 资源组 ID
    pub resource_group_id: String,

    /// 站点 ID
    pub site_id: i64,

    /// 站点名称
    pub site_name: String,

    /// 站点状态
    pub status: SiteStatus,

    /// 站点标签（Key-Value 形式）
    pub tags: Option<HashMap<String, String>>,

    /// 站点归属校验码（CNAME 接入时使用）
    pub verify_code: String,

    /// 站点访问时间（ISO8601, UTC）
    #[serde(with = "time::serde::iso8601")]
    pub visit_time: OffsetDateTime,

    /// 站点停用原因
    #[serde(deserialize_with = "de_option_empty_string_as_none")]
    pub offline_reason: Option<OfflineReason>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(rename_all = "lowercase")]
pub enum SiteStatus {
    Pending,
    Active,
    Offline,
    Moved,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum OfflineReason {
    ExpirationArrears,
    InternallyDisabled,
    MissingIcp,
    ContentViolation,
    ProactivelyDisabled,
}

//endregion

impl Client {
    pub fn list_sites(&self) -> ListSitesBuilder<'_> {
        ListSites::builder(self)
    }
}

impl ListSites<'_> {
    pub async fn send(&self) -> Result<ListSitesResponse, Error> {
        let client = self.client;
        let creds = client.credentials_provider.load().await?;

        let sign_params = SignParams {
            req_method: "GET",
            host: &client.host,
            query_map: self,
            x_acs_action: "ListSites",
            x_acs_version: OPENAPI_VERSION,
            x_acs_security_token: creds.sts_security_token.as_deref(),
            request_body: None,
            style: &OPENAPI_STYLE,
        };

        let (common_headers, url_) =
            get_openapi_request_header(&creds.access_key_secret, &creds.access_key_id, sign_params)
                .map_err(|e| {
                    Error::Common(format!("failed to get openapi request header: {}", e))
                })?;
        let header_map = into_header_map(common_headers);

        let resp = client
            .http_client
            .get(url_)
            .headers(header_map)
            .send()
            .await?;

        let data = parse_json_response(resp).await?;
        Ok(data)
    }
}