Struct GraphClient 

pub struct GraphClient { /* private fields */ }

Stateful Microsoft Graph client. Holds an AuthClient and a shared HTTP client.

Implementations

impl GraphClient

pub fn new(auth: AuthClient) -> Result<Self, ClientError>

pub fn for_test(auth: AuthClient, base_url: impl Into<String>) -> Self

pub fn auth(&self) -> &AuthClient

pub async fn me(&self, access_token: &str) -> Result<Me, ClientError>

GET /me. Used right after sign-in to learn the user’s email.

pub async fn list_inbox( &self, account: &str, limit: usize, skip: usize, unread_only: bool, ) -> Result<InboxPage, ClientError>

GET /me/mailFolders/inbox/messages for a given account email. Acquires/refreshes a token transparently via AuthClient::get_valid_token.

pub async fn search_messages( &self, account: &str, query: &str, limit: usize, ) -> Result<Vec<Message>, ClientError>

GET /me/messages with $search="<query>" for a given account.

pub async fn mark_unread( &self, account: &str, message_id: &str, ) -> Result<(), ClientError>

PATCH /me/messages/{id} with { "isRead": false }.

pub async fn set_flag( &self, account: &str, message_id: &str, flagged: bool, ) -> Result<(), ClientError>

PATCH /me/messages/{id} with { "flag": { "flagStatus": "flagged"|"notFlagged" } }.

pub async fn move_message( &self, account: &str, message_id: &str, destination: &str, ) -> Result<(), ClientError>

POST /me/messages/{id}/move — move to a folder by ID or well-known name.

pub async fn send_mail( &self, account: &str, message: &Outgoing, ) -> Result<(), ClientError>

POST /me/sendMail — compose-and-send a new message.

pub async fn reply_message( &self, account: &str, message_id: &str, comment: &str, ) -> Result<(), ClientError>

POST /me/messages/{id}/reply.

pub async fn reply_all_message( &self, account: &str, message_id: &str, comment: &str, ) -> Result<(), ClientError>

POST /me/messages/{id}/replyAll.

pub async fn forward_message( &self, account: &str, message_id: &str, to: &[String], comment: &str, ) -> Result<(), ClientError>

POST /me/messages/{id}/forward.

pub async fn list_drafts( &self, account: &str, limit: usize, skip: usize, ) -> Result<InboxPage, ClientError>

GET /me/mailFolders/drafts/messages.

pub async fn create_draft( &self, account: &str, message: &Outgoing, ) -> Result<String, ClientError>

POST /me/messages — create a draft, returning its new message ID.

pub async fn create_reply_draft( &self, account: &str, message_id: &str, comment: &str, ) -> Result<String, ClientError>

POST /me/messages/{id}/createReply.

pub async fn create_reply_all_draft( &self, account: &str, message_id: &str, comment: &str, ) -> Result<String, ClientError>

POST /me/messages/{id}/createReplyAll.

pub async fn create_forward_draft( &self, account: &str, message_id: &str, to: &[String], comment: &str, ) -> Result<String, ClientError>

POST /me/messages/{id}/createForward.

pub async fn send_draft( &self, account: &str, message_id: &str, ) -> Result<(), ClientError>

POST /me/messages/{id}/send — send an existing draft.

pub async fn update_draft( &self, account: &str, message_id: &str, message: &Outgoing, ) -> Result<(), ClientError>

PATCH /me/messages/{id} — overwrite a draft’s editable fields.

pub async fn delete_message( &self, account: &str, message_id: &str, ) -> Result<(), ClientError>

DELETE /me/messages/{id} — moves to Deleted Items. Works for both drafts and inbox messages.

pub async fn add_attachment( &self, account: &str, message_id: &str, name: &str, content_type: &str, bytes: &[u8], ) -> Result<String, ClientError>

POST /me/messages/{id}/attachments — attach a file (simple upload).

pub async fn delete_attachment( &self, account: &str, message_id: &str, attachment_id: &str, ) -> Result<(), ClientError>

DELETE /me/messages/{id}/attachments/{att_id}.

pub async fn get_message( &self, account: &str, message_id: &str, ) -> Result<FullMessage, ClientError>

GET /me/messages/{id} for a given account email.

pub async fn fetch_message_headers( &self, account: &str, message_id: &str, ) -> Result<Vec<(String, String)>, ClientError>

GET /me/messages/{id}?$select=internetMessageHeaders.

pub async fn list_attachments( &self, account: &str, message_id: &str, ) -> Result<Vec<Attachment>, ClientError>

GET /me/messages/{id}/attachments.

pub async fn get_attachment_bytes( &self, account: &str, message_id: &str, attachment_id: &str, ) -> Result<Vec<u8>, ClientError>

GET /me/messages/{id}/attachments/{att_id} returning decoded bytes.

pub async fn mark_read( &self, account: &str, message_id: &str, ) -> Result<(), ClientError>

PATCH /me/messages/{id} with isRead: true.