Revision control
Copy as Markdown
Other Tools
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
use std::sync::Arc;
use ms_graph_tb::paths;
use protocol_shared::{
ServerType,
client::DoOperation,
safe_xpcom::{
SafeExchangeSimpleOperationListener, SimpleOperationSuccessArgs, UseLegacyFallback,
},
};
use thin_vec::ThinVec;
use crate::{client::XpComGraphClient, error::XpComGraphError};
pub(super) struct DoDeleteMessages {
pub message_ids: Vec<String>,
}
impl<ServerT: ServerType> DoOperation<XpComGraphClient<ServerT>, XpComGraphError>
for DoDeleteMessages
{
const NAME: &str = "delete messages";
type Okay = ();
type Listener = SafeExchangeSimpleOperationListener;
async fn do_operation(
&mut self,
client: &XpComGraphClient<ServerT>,
) -> Result<Self::Okay, XpComGraphError> {
let requests = self
.message_ids
.iter()
.map(|message_id| {
paths::me::messages::message_id::Delete::new(
client.base_url().to_string(),
message_id.clone(),
)
})
.collect();
client
.send_batch_request_json_response(requests, Default::default())
.await?;
Ok(())
}
fn into_success_arg(
self,
_ok: Self::Okay,
) -> <Self::Listener as protocol_shared::safe_xpcom::SafeListener>::OnSuccessArg {
SimpleOperationSuccessArgs {
new_ids: ThinVec::new(),
use_legacy_fallback: UseLegacyFallback::No,
}
}
fn into_failure_arg(
self,
) -> <Self::Listener as protocol_shared::safe_xpcom::SafeListener>::OnFailureArg {
}
}
impl<ServerT: ServerType> XpComGraphClient<ServerT> {
/// Performs a [delete message] operation for each of the provided message
/// IDs (in a batch).
///
/// [delete message]:
pub(crate) async fn delete_messages(
self: Arc<XpComGraphClient<ServerT>>,
message_ids: Vec<String>,
listener: SafeExchangeSimpleOperationListener,
) {
let operation = DoDeleteMessages { message_ids };
operation.handle_operation(&self, &listener).await;
}
}