use alloc::format;
use base64::{Engine, engine::general_purpose::STANDARD};
use io_http::rfc6750::bearer::HttpAuthBearer;
use log::{debug, trace};
use url::Url;
use crate::{
coroutine::*,
msgraph_try,
v1::{
rest::users::messages::MsgraphMessage,
send::{MSGRAPH_API_BASE, MsgraphSend, MsgraphSendError, MsgraphSendOutput, user_path},
},
};
pub struct MsgraphMessageCreateMime {
send: MsgraphSend<MsgraphMessage>,
}
impl MsgraphMessageCreateMime {
pub fn new(
auth: &HttpAuthBearer,
user_id: &str,
folder: Option<&str>,
raw: &[u8],
) -> Result<Self, MsgraphSendError> {
debug!("prepare microsoft graph message creation (mime)");
trace!("folder: {folder:?}");
trace!("raw len: {}", raw.len());
let user = user_path(user_id);
let path = match folder {
Some(folder) => format!("{user}/mailFolders/{folder}/messages"),
None => format!("{user}/messages"),
};
let url = Url::parse(MSGRAPH_API_BASE)?.join(&path)?;
let body = STANDARD.encode(raw).into_bytes();
let send = MsgraphSend::post_text(auth, url, body);
Ok(Self { send })
}
}
impl MsgraphCoroutine for MsgraphMessageCreateMime {
type Yield = MsgraphYield;
type Return = Result<MsgraphSendOutput<MsgraphMessage>, MsgraphSendError>;
fn resume(&mut self, arg: Option<&[u8]>) -> MsgraphCoroutineState<Self::Yield, Self::Return> {
let out = msgraph_try!(&mut self.send, arg);
debug!("message created (mime)");
trace!("out: {out:?}");
MsgraphCoroutineState::Complete(Ok(out))
}
}