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 ews::{
delete_item::DeleteItem,
response::{ResponseCode, ResponseError},
BaseItemId, DeleteType, Operation, OperationResponse,
};
use mailnews_ui_glue::UserInteractiveServer;
use nsstring::nsCString;
use thin_vec::ThinVec;
use xpcom::RefCounted;
use super::{
process_response_message_class, validate_response_message_count, DoOperation, XpComEwsClient,
XpComEwsError,
};
use crate::{
authentication::credentials::AuthenticationProvider,
safe_xpcom::{SafeEwsSimpleOperationListener, SafeListener},
};
struct DoDeleteMessages {
pub ews_ids: ThinVec<nsCString>,
}
impl DoOperation for DoDeleteMessages {
const NAME: &'static str = DeleteItem::NAME;
type Okay = ();
type Listener = SafeEwsSimpleOperationListener;
async fn do_operation<ServerT>(
&mut self,
client: &XpComEwsClient<ServerT>,
) -> Result<Self::Okay, XpComEwsError>
where
ServerT: AuthenticationProvider + UserInteractiveServer + RefCounted,
{
let item_ids: Vec<BaseItemId> = self
.ews_ids
.iter()
.map(|raw_id| BaseItemId::ItemId {
id: raw_id.to_string(),
change_key: None,
})
.collect();
let delete_item = DeleteItem {
item_ids,
delete_type: DeleteType::HardDelete,
send_meeting_cancellations: None,
affected_task_occurrences: None,
suppress_read_receipts: None,
};
let response = client
.make_operation_request(delete_item, Default::default())
.await?;
// Make sure we got the amount of response messages matches the amount
// of messages we requested to have deleted.
let response_messages = response.into_response_messages();
validate_response_message_count(&response_messages, self.ews_ids.len())?;
// Check every response message for an error.
response_messages
.into_iter()
.zip(self.ews_ids.iter())
.try_for_each(|(response_message, ews_id)| {
if let Err(err) = process_response_message_class(
DeleteItem::NAME,
response_message
) {
if matches!(err, XpComEwsError::ResponseError( ResponseError { response_code: ResponseCode::ErrorItemNotFound, .. })) {
// Something happened in a previous attempt that caused
// the message to be deleted on the EWS server but not
// in the database. In this case, we don't want to force
// a zombie message in the folder, so we ignore the
// error and move on with the local deletion.
log::warn!("found message that was deleted from the EWS server but not the local db: {ews_id}");
Ok(())
} else {
// We've already checked that there are as many elements in
// `response_messages` as in `message_ews_ids`, so we
// shouldn't be able to get out of bounds here.
Err(XpComEwsError::Processing {
message: format!(
"error while attempting to delete message {ews_id}: {err:?}"
),
})
}
} else {
Ok(())
}
})?;
Ok(())
}
fn into_success_arg(self, _ok: Self::Okay) -> <Self::Listener as SafeListener>::OnSuccessArg {
(std::iter::empty::<String>(), false).into()
}
fn into_failure_arg(self) {}
}
impl<ServerT> XpComEwsClient<ServerT>
where
ServerT: AuthenticationProvider + UserInteractiveServer + RefCounted,
{
pub async fn delete_messages(
self,
listener: SafeEwsSimpleOperationListener,
ews_ids: ThinVec<nsCString>,
) {
let operation = DoDeleteMessages { ews_ids };
operation.handle_operation(&self, &listener).await;
}
}