gmail/request/
messages_import.rs1use serde_json::json;
2use crate::model::*;
3use crate::FluentRequest;
4use serde::{Serialize, Deserialize};
5use httpclient::InMemoryResponseExt;
6use crate::GmailClient;
7#[derive(Debug, Clone, Serialize, Deserialize)]
11pub struct MessagesImportRequest {
12 pub deleted: Option<bool>,
13 pub internal_date_source: Option<String>,
14 pub never_mark_spam: Option<bool>,
15 pub process_for_calendar: Option<bool>,
16 pub user_id: String,
17}
18impl MessagesImportRequest {}
19impl FluentRequest<'_, MessagesImportRequest> {
20 pub fn deleted(mut self, deleted: bool) -> Self {
21 self.params.deleted = Some(deleted);
22 self
23 }
24 pub fn internal_date_source(mut self, internal_date_source: &str) -> Self {
25 self.params.internal_date_source = Some(internal_date_source.to_owned());
26 self
27 }
28 pub fn never_mark_spam(mut self, never_mark_spam: bool) -> Self {
29 self.params.never_mark_spam = Some(never_mark_spam);
30 self
31 }
32 pub fn process_for_calendar(mut self, process_for_calendar: bool) -> Self {
33 self.params.process_for_calendar = Some(process_for_calendar);
34 self
35 }
36}
37impl<'a> ::std::future::IntoFuture for FluentRequest<'a, MessagesImportRequest> {
38 type Output = httpclient::InMemoryResult<Message>;
39 type IntoFuture = ::futures::future::BoxFuture<'a, Self::Output>;
40 fn into_future(self) -> Self::IntoFuture {
41 Box::pin(async move {
42 let url = &format!(
43 "/gmail/v1/users/{user_id}/messages/import", user_id = self.params
44 .user_id
45 );
46 let mut r = self.client.client.post(url);
47 r = r.set_query(self.params);
48 r = self.client.authenticate(r);
49 let res = r.await?;
50 res.json().map_err(Into::into)
51 })
52 }
53}