open-lark 0.13.0

Enterprise-grade Lark/Feishu Open API SDK with comprehensive Chinese documentation and advanced error handling
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

use reqwest::Method;

use crate::{
    core::{
        api_req::ApiRequest, api_resp::BaseResponse, config::Config, constants::AccessTokenType,
        http::Transport, req_option::RequestOption, SDKResult,
    },
    service::security_and_compliance::models::{OpenapiLogListRequest, OpenapiLogListResponse},
};

/// OpenAPI 审计日志服务
pub struct OpenapiLogService {
    pub config: Config,
}

impl OpenapiLogService {
    pub fn new(config: Config) -> Self {
        Self { config }
    }

    /// 获取 OpenAPI 审计日志数据
    ///
    /// 用于获取企业的 OpenAPI 调用记录，支持按时间范围、应用 ID、API 接口等条件筛选
    ///
    /// # 参数
    /// - `request`: 查询参数
    /// - `option`: 请求选项
    ///
    /// # 返回
    /// - `Ok(OpenapiLogListResponse)`: 成功返回审计日志列表
    /// - `Err(LarkError)`: 请求失败
    pub async fn list_data(
        &self,
        request: OpenapiLogListRequest,
        option: Option<RequestOption>,
    ) -> SDKResult<BaseResponse<OpenapiLogListResponse>> {
        let mut api_req = ApiRequest {
            http_method: Method::GET,
            api_path: "/open-apis/security_and_compliance/v1/openapi_logs/list_data".to_string(),
            supported_access_token_types: vec![AccessTokenType::Tenant, AccessTokenType::User],
            body: vec![],
            ..Default::default()
        };

        // 添加查询参数
        if let Some(page_token) = request.page_token {
            api_req
                .query_params
                .insert("page_token".to_string(), page_token);
        }

        if let Some(page_size) = request.page_size {
            api_req
                .query_params
                .insert("page_size".to_string(), page_size.to_string());
        }

        if let Some(start_time) = request.start_time {
            api_req
                .query_params
                .insert("start_time".to_string(), start_time.to_string());
        }

        if let Some(end_time) = request.end_time {
            api_req
                .query_params
                .insert("end_time".to_string(), end_time.to_string());
        }

        if let Some(app_ids) = request.app_ids {
            api_req.query_params.insert("app_ids".to_string(), app_ids);
        }

        if let Some(apis) = request.apis {
            api_req.query_params.insert("apis".to_string(), apis);
        }

        if let Some(response_codes) = request.response_codes {
            api_req
                .query_params
                .insert("response_codes".to_string(), response_codes);
        }

        Transport::request(api_req, &self.config, option).await
    }
}