openapi_rs/api/v1/sync/
system_sync_batch_get_task.rs

1use crate::common::define::{
2    AsyncResponseFn, BaseRequest, BaseResponse, HttpBuilder, HttpFn, RequestFn,
3};
4use crate::model::sync::SyncTask;
5use bytes::Bytes;
6use reqwest::{Method, Response};
7use serde::{Deserialize, Serialize};
8
9#[derive(Debug, Default, Clone, Serialize, Deserialize)]
10#[serde(default)]
11pub struct SystemSyncBatchGetTaskRequest {
12    #[serde(rename = "JobIds")]
13    pub job_ids: Option<Vec<String>>,
14}
15
16impl SystemSyncBatchGetTaskRequest {
17    pub fn new() -> Self {
18        Self::default()
19    }
20    pub fn with_job_ids(mut self, job_ids: Vec<String>) -> Self {
21        self.job_ids = Some(job_ids);
22        self
23    }
24}
25
26#[derive(Debug, Default, Clone, Serialize, Deserialize)]
27#[serde(default)]
28pub struct SystemSyncBatchGetTaskResponse {
29    #[serde(flatten)]
30    pub sync_tasks: Vec<SyncTask>,
31}
32
33impl HttpBuilder for SystemSyncBatchGetTaskRequest {
34    type Response = BaseResponse<SystemSyncBatchGetTaskResponse>;
35    fn builder(self) -> HttpFn<Self::Response> {
36        Box::new(move || {
37            let request_fn: RequestFn = Box::new(move || BaseRequest {
38                method: Method::POST,
39                uri: "/system/sync-task/batch".to_string(),
40                body: Bytes::from(serde_json::to_vec(&self).unwrap()),
41                ..Default::default()
42            });
43            let response_fn: AsyncResponseFn<Self::Response> =
44                Box::new(|response: Response| Box::pin(async move { Ok(response.json().await?) }));
45            (request_fn, response_fn)
46        })
47    }
48}
49
50#[cfg(test)]
51mod tests {
52    use super::*;
53    use crate::common::client::OpenApiClient;
54    use crate::common::config::{EndpointType, OpenApiConfig};
55    use tracing::info;
56
57    #[tokio::test]
58    async fn test_system_sync_batch_get_task() -> anyhow::Result<()> {
59        tracing_subscriber::fmt::init();
60        dotenvy::dotenv()?;
61        let config = OpenApiConfig::new().load_from_env()?;
62        let mut client = OpenApiClient::new(config).with_endpoint_type(EndpointType::Sync);
63
64        let http_fn = SystemSyncBatchGetTaskRequest::new()
65            .with_job_ids(vec!["123".to_string()])
66            .builder();
67        let response = client.send(http_fn).await?;
68        info!("response: {:#?}", response);
69
70        Ok(())
71    }
72}
openapi_rs/api/v1/sync/system_sync_batch_get_task.rs

openapi_rs/api/v1/sync/
system_sync_batch_get_task.rs
