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_folder::DeleteFolder,
response::{ResponseCode, ResponseError},
BaseFolderId, DeleteType, Operation, OperationResponse,
};
use mailnews_ui_glue::UserInteractiveServer;
use xpcom::RefCounted;
use super::{process_response_message_class, DoOperation, XpComEwsClient, XpComEwsError};
use crate::{
authentication::credentials::AuthenticationProvider,
safe_xpcom::{SafeEwsSimpleOperationListener, SafeListener},
};
struct DoDeleteFolder {
pub folder_ids: Vec<String>,
}
impl DoOperation for DoDeleteFolder {
const NAME: &'static str = DeleteFolder::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 folder_ids = self
.folder_ids
.iter()
.map(|id| BaseFolderId::FolderId {
id: id.clone(),
change_key: None,
})
.collect();
let delete_folder = DeleteFolder {
delete_type: DeleteType::HardDelete,
folder_ids,
};
let response = client
.make_operation_request(delete_folder, Default::default())
.await?;
let response_messages = response.into_response_messages();
for response_message in response_messages {
if let Err(err) = process_response_message_class(Self::NAME, response_message) {
match err {
XpComEwsError::ResponseError(ResponseError {
response_code: ResponseCode::ErrorItemNotFound,
..
}) => {
// Something happened in a previous attempt that caused the
// folder to be deleted on the EWS server but not in the
// database. In this case, we don't want to force a zombie
// folder in the account, so we ignore the error and move on
// with the local deletion.
log::warn!("found folder that was deleted from the EWS server but not the local db");
}
_ => return Err(err),
}
}
}
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_folder(
self,
listener: SafeEwsSimpleOperationListener,
folder_ids: Vec<String>,
) {
let operation = DoDeleteFolder { folder_ids };
operation.handle_operation(&self, &listener).await;
}
}