wx-sdk 0.0.9

use crate::{access_token::AccessTokenProvider, error::CommonResponse};
use crate::{wechat::WxApiRequestBuilder, SdkResult, WxSdk};
use serde::{de::DeserializeOwned, Deserialize, Serialize};

pub mod ad;
pub mod cloudbase;
pub mod content_security;
pub mod customer_message;
pub mod datacube;
pub mod img;
pub mod immediate_delivery;
pub mod internet;
pub mod live_broadcast;
pub mod logistics;
pub mod nearby_poi;
pub mod ocr;
pub mod operation;
pub mod phone_number;
pub mod plugin_manage;
pub mod qrcode;
pub mod redpacket_cover;
pub mod risk_control;
pub mod search;
pub mod service_market;
pub mod short_link;
pub mod soter;
pub mod subscribe_message;
pub mod uniform_message;
pub mod updatable_message;
pub mod url_link;
pub mod url_scheme;

#[derive(Debug, Serialize, Deserialize)]
pub struct DateRange {
    /// 开始日期。格式为 yyyymmdd
    pub begin_date: String,
    /// 结束日期，限定查询1天数据，允许设置的最大值为昨日。格式为 yyyymmdd
    pub end_date: String,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct TimestampRange {
    /// 开始日期时间戳
    pub begin_timestamp: String,
    /// 结束日期时间戳
    pub end_timestamp: String,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct ListRes<T> {
    /// 数据列表
    pub list: Vec<T>,
}

/// A single "part" of a multipart/form-data body. <br/>
/// Yielded from the `FormData` stream.
pub struct Part {
    pub name: String,
    pub filename: String,
    pub content_type: String,
    pub data: Vec<u8>,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct LoginResult {
    /// 用户唯一标识
    pub openid: String,
    /// 会话密钥
    #[serde(skip_serializing)]
    pub session_key: String,
    /// 用户在开放平台的唯一标识符，若当前小程序已绑定到微信开放平台帐号下会返回，详见 UnionID 机制说明。
    pub unionid: String,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct CheckEncryptedResult {
    /// 是否是合法的数据
    pub vaild: bool,
    /// 加密数据生成的时间戳
    pub create_time: i64,
}

#[derive(Debug, Serialize)]
pub struct QueryPaidUnionId {
    /// 支付用户唯一标识
    pub openid: String,
    /// 微信支付订单号
    #[serde(default)]
    pub transaction_id: Option<String>,
    /// 微信支付分配的商户号，和商户订单号配合使用
    #[serde(default)]
    pub mch_id: Option<String>,
    /// 微信支付商户订单号，和商户号配合使用
    #[serde(default)]
    pub out_trade_no: Option<String>,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct UnionId {
    /// 用户唯一标识，调用成功后返回
    pub unionid: String,
}

async fn get_send<'a, A: WxApiRequestBuilder, R: DeserializeOwned, P: Serialize>(
    api_builder: &'a A,
    url: &'static str,
    param: &'a P,
) -> SdkResult<R> {
    let builder = api_builder.wx_get(url).await?.query(param);
    let res = builder.send().await?.json::<R>().await?;
    Ok(res)
}

async fn post_send<'a, A: WxApiRequestBuilder, R: DeserializeOwned, D: Serialize>(
    api_builder: &'a A,
    url: &'static str,
    post_data: &'a D,
) -> SdkResult<R> {
    let builder = api_builder.wx_post(url).await?.json(post_data);
    let res = builder.send().await?.json::<CommonResponse<R>>().await?;
    res.into()
}

/// 小程序接口SDK，由于 Rust Doc 中还无法搜索中文，请直接搜索相关请求 url 中的关键信息。
#[derive(Clone)]
pub struct WxaSdk<T: AccessTokenProvider> {
    pub(crate) sdk: crate::WxSdk<T>,
}

impl<T: AccessTokenProvider> WxaSdk<T> {
    pub async fn code_to_session(&self, js_code: &str) -> SdkResult<LoginResult> {
        let url = "https://api.weixin.qq.com/sns/jscode2session?grant_type=authorization_code";
        let query = &serde_json::json!({
            "js_code": js_code,
            "appid": &self.sdk.app_id,
            "secret": &self.sdk.app_secret,
        });
        get_send(&self.sdk, url, query).await
    }

    pub async fn check_encrypted_data(
        &self,
        encrypted_msg_hash: &str,
    ) -> SdkResult<CheckEncryptedResult> {
        let url = "https://api.weixin.qq.com/wxa/business/checkencryptedmsg";
        let post_data = &serde_json::json!({ "encrypted_msg_hash": encrypted_msg_hash });
        post_send(&self.sdk, url, post_data).await
    }

    pub async fn get_paid_unionid(&self, query: &QueryPaidUnionId) -> SdkResult<UnionId> {
        let url = "https://api.weixin.qq.com/wxa/getpaidunionid";
        post_send(&self.sdk, url, &query).await
    }

    /// Data analysis 数据分析模块
    pub fn datacube(&self) -> datacube::DataCubeModule<WxSdk<T>> {
        datacube::DataCubeModule(&self.sdk)
    }

    /// Customer Service message 客服消息
    pub fn customer_message(&self) -> customer_message::CustomerMessageModule<WxSdk<T>> {
        customer_message::CustomerMessageModule(&self.sdk)
    }

    /// Uniform Service Message 统一服务消息
    pub fn uniform_message(&self) -> uniform_message::UniformMessageModule<WxSdk<T>> {
        uniform_message::UniformMessageModule(&self.sdk)
    }

    /// Uniform Service Message 统一服务消息
    pub fn updatable_message(&self) -> updatable_message::UpdatableMessageModule<WxSdk<T>> {
        updatable_message::UpdatableMessageModule(&self.sdk)
    }

    /// Plugin Manager 插件管理
    pub fn plugin_mangage(&self) -> plugin_manage::PluginManageModule<WxSdk<T>> {
        plugin_manage::PluginManageModule(&self.sdk)
    }

    /// Mini Programs Nearby 附近的小程序
    pub fn nearby_poi(&self) -> nearby_poi::NearbyPoiModule<WxSdk<T>> {
        nearby_poi::NearbyPoiModule(&self.sdk)
    }

    /// Mini Program Code 小程序码
    pub fn qrcode(&self) -> qrcode::QrcodeModule<WxSdk<T>> {
        qrcode::QrcodeModule(&self.sdk)
    }

    /// Url Scheme
    pub fn url_scheme(&self) -> url_scheme::UrlSchemeModule<WxSdk<T>> {
        url_scheme::UrlSchemeModule(&self.sdk)
    }

    /// Url Link
    pub fn url_link(&self) -> url_link::UrlLinkModule<WxSdk<T>> {
        url_link::UrlLinkModule(&self.sdk)
    }

    /// Content Security 内容安全
    pub fn content_security(&self) -> content_security::ContentSecurityModule<WxSdk<T>> {
        content_security::ContentSecurityModule(&self.sdk)
    }

    /// Redpacket Cover 微信红包封面
    pub fn redpacket_cover(&self) -> redpacket_cover::RedpacketCoverModule<WxSdk<T>> {
        redpacket_cover::RedpacketCoverModule(&self.sdk)
    }

    /// Cloudbase 云开发
    pub fn cloudbase(&self) -> cloudbase::CloudbaseModule<WxSdk<T>> {
        cloudbase::CloudbaseModule(&self.sdk)
    }

    /// Img 图像处理
    pub fn img(&self) -> img::ImgModule<WxSdk<T>> {
        img::ImgModule(&self.sdk)
    }

    /// Immediate Delivery 即使配送
    pub fn immediate_delivery(&self) -> immediate_delivery::ImmediateDeliveryModule<WxSdk<T>> {
        immediate_delivery::ImmediateDeliveryModule(&self.sdk)
    }

    /// Internet 网络
    pub fn internet(&self) -> internet::InternetModule<WxSdk<T>> {
        internet::InternetModule(&self.sdk)
    }

    /// Live Broadcast 直播
    pub fn live_broadcast(&self) -> live_broadcast::LiveBroadcastModule<WxSdk<T>> {
        live_broadcast::LiveBroadcastModule(&self.sdk)
    }

    /// logistics 物流助手
    pub fn logistics(&self) -> logistics::LogisticsModule<WxSdk<T>> {
        logistics::LogisticsModule(&self.sdk)
    }

    /// OCR
    pub fn ocr(&self) -> ocr::OcrModule<WxSdk<T>> {
        ocr::OcrModule(&self.sdk)
    }

    /// Operation 运维中心
    pub fn operation(&self) -> operation::OperationModule<WxSdk<T>> {
        operation::OperationModule(&self.sdk)
    }

    /// Phone Number 手机号
    pub fn phone_number(&self) -> phone_number::PhoneNumberModule<WxSdk<T>> {
        phone_number::PhoneNumberModule(&self.sdk)
    }

    /// Risk Control 安全风控
    pub fn risk_control(&self) -> risk_control::RiskControlModule<WxSdk<T>> {
        risk_control::RiskControlModule(&self.sdk)
    }

    /// Search 搜索
    pub fn search(&self) -> search::SearchModule<WxSdk<T>> {
        search::SearchModule(&self.sdk)
    }

    /// Service Market 服务市场
    pub fn service_market(&self) -> service_market::ServiceMarketModule<WxSdk<T>> {
        service_market::ServiceMarketModule(&self.sdk)
    }

    /// Short Link
    pub fn short_link(&self) -> short_link::ShortLinkModule<WxSdk<T>> {
        short_link::ShortLinkModule(&self.sdk)
    }

    /// soter 生物认证
    pub fn soter(&self) -> soter::SoterModule<WxSdk<T>> {
        soter::SoterModule(&self.sdk)
    }

    /// Subscribe Message 订阅消息
    pub fn subscribe_message(&self) -> subscribe_message::SubscribeMessageModule<WxSdk<T>> {
        subscribe_message::SubscribeMessageModule(&self.sdk)
    }
}

// #[test]
// fn test_query_data_option() {
//     #[derive(Serialize, Deserialize, Debug)]
//     pub struct Data {
//         pub aid: String,
//         pub key: Option<String>,
//     }
//     let data = &Data { aid: "aaaa".into(), key: None };
//     let builder = reqwest::Client::new().get("https://a.b.com/").query(&data);
//     println!("{:?}", &builder); // query: Some("aid=aaaa")
//
//     let data = &Data { aid: "aaaa".into(), key: Some("".into()) };
//     let builder = reqwest::Client::new().get("https://a.b.com/").query(&data);
//     println!("{:?}", &builder); // query: Some("aid=aaaa&key=")
// }

// #[test]
// fn test_query_data_array() { // 不支持数组
//     #[derive(Serialize, Deserialize, Debug)]
//     pub struct Data {
//         pub keys: Vec<i32>,
//     }
//     let data = &Data { keys: vec![1, 2, 3, 4] };
//     let builder = reqwest::Client::new().get("https://b.com/").query(&data);
//     println!("{:?}", &builder); //
// }

// #[test]
// fn test_query_data_unit() {
//     let data = &();
//     let builder = reqwest::Client::new().get("https://b.com/").query(&data);
//     println!("{:?}", &builder); // query: None
// }