use openlark_core::{
SDKResult, api::ApiRequest, config::Config, http::Transport, req_option::RequestOption,
};
use std::sync::Arc;
#[derive(Debug, Clone)]
pub struct UserSubscriptionRequest {
config: Arc<Config>,
}
impl UserSubscriptionRequest {
pub fn new(config: Arc<Config>) -> Self {
Self { config }
}
pub async fn execute(self, body: serde_json::Value) -> SDKResult<serde_json::Value> {
self.execute_with_options(body, RequestOption::default())
.await
}
pub async fn execute_with_options(
self,
body: serde_json::Value,
option: RequestOption,
) -> SDKResult<serde_json::Value> {
let path = "/open-apis/drive/v1/user/subscription".to_string();
let req: ApiRequest<serde_json::Value> = ApiRequest::post(path).body(body);
let resp = Transport::request(req, &self.config, Some(option)).await?;
resp.data.ok_or_else(|| {
openlark_core::error::validation_error("订阅用户云文档事件", "响应数据为空")
})
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn builder_initializes() {
let config = Arc::new(Config::default());
let _request = UserSubscriptionRequest::new(config);
}
}