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::{OperationBody, paths::me, types::mail_folder::MailFolder};
use protocol_shared::{
ServerType,
client::DoOperation,
safe_xpcom::{SafeEwsSimpleOperationListener, UseLegacyFallback},
};
use crate::{client::XpComGraphClient, error::XpComGraphError};
struct DoUpdateFolder {
folder_id: String,
folder_name: String,
}
impl<ServerT: ServerType> DoOperation<XpComGraphClient<ServerT>, XpComGraphError>
for DoUpdateFolder
{
const NAME: &str = "update folder";
type Okay = ();
type Listener = SafeEwsSimpleOperationListener;
async fn do_operation(
&mut self,
client: &XpComGraphClient<ServerT>,
) -> Result<Self::Okay, XpComGraphError> {
let patch_body = MailFolder::new().set_display_name(Some(self.folder_name.clone()));
let request = me::mail_folders::mail_folder_id::Patch::new(
client.base_url().to_string(),
self.folder_id.clone(),
OperationBody::JSON(patch_body),
);
// The folder IDs appear to be stable through a rename, so nothing needs
// to be done with the response here.
let _ = client
.send_request_json_response(request, Default::default())
.await?;
Ok(())
}
fn into_success_arg(
self,
_ok: Self::Okay,
) -> <Self::Listener as protocol_shared::safe_xpcom::SafeListener>::OnSuccessArg {
(std::iter::empty::<String>(), UseLegacyFallback::No).into()
}
fn into_failure_arg(
self,
) -> <Self::Listener as protocol_shared::safe_xpcom::SafeListener>::OnFailureArg {
}
}
impl<ServerT: ServerType> XpComGraphClient<ServerT> {
/// Perform an operation to update a graph folder.
///
/// Note that the only supported attribute to update is currently
/// the folder's display name.
///
pub(crate) async fn update_folder(
self: Arc<XpComGraphClient<ServerT>>,
folder_id: String,
folder_name: String,
listener: SafeEwsSimpleOperationListener,
) {
let operation = DoUpdateFolder {
folder_id,
folder_name,
};
operation.handle_operation(&self, &listener).await;
}
}