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 list_folder( &self, account: &str, folder_id: &str, limit: usize, skip: usize, unread_only: bool, ) -> Result<InboxPage, ClientError>

GET /me/mailFolders/{folder_id}/messages: list a custom folder.

pub async fn mail_delta_bootstrap( &self, account: &str, folder: &str, ) -> Result<(Vec<Message>, String), ClientError>

GET /me/messages with $search="<query>" for a given account. Bootstrap a mail delta stream for a folder: (current messages, deltaLink).

pub async fn mail_delta( &self, account: &str, delta_link: &str, ) -> Result<(Vec<MailDeltaEvent>, String), ClientError>

Poll a mail deltaLink for changes.

pub async fn calendar_delta_bootstrap( &self, account: &str, start: DateTime<Utc>, end: DateTime<Utc>, ) -> Result<(Vec<Event>, String), ClientError>

Bootstrap a calendar delta stream over a window: (current events, deltaLink).

pub async fn calendar_delta( &self, account: &str, delta_link: &str, ) -> Result<(Vec<CalendarDeltaEvent>, String), ClientError>

Poll a calendar deltaLink for changes.

pub async fn batch_all( &self, account: &str, requests: Vec<BatchRequest>, ) -> Result<Vec<BatchResponse>, ClientError>

Run a set of batch sub-requests for one account.

pub async fn list_conversation( &self, account: &str, conversation_id: &str, ) -> Result<Vec<Message>, ClientError>

Fetch every message in a conversation (thread), oldest first.

pub async fn list_messages_at( &self, account: &str, url: &str, ) -> Result<InboxPage, ClientError>

Fetch a page of messages at an absolute Graph continuation URL.

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

pub async fn search_folder( &self, account: &str, folder: &str, query: &str, limit: usize, ) -> Result<InboxPage, ClientError>

$search within one folder (well-known name or folder id).

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 get_categories( &self, account: &str, message_id: &str, ) -> Result<Vec<String>, ClientError>

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

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

PATCH /me/messages/{id} categories.

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 list_mail_folders( &self, account: &str, ) -> Result<Vec<MailFolder>, ClientError>

GET /me/mailFolders: list the account’s top-level folders.

pub async fn create_mail_folder( &self, account: &str, display_name: &str, ) -> Result<MailFolder, ClientError>

POST /me/mailFolders: create a top-level folder, returning it.

pub async fn list_child_folders( &self, account: &str, parent_id: &str, ) -> Result<Vec<MailFolder>, ClientError>

GET /me/mailFolders/{parent_id}/childFolders: list a folder’s children.

pub async fn create_child_folder( &self, account: &str, parent_id: &str, display_name: &str, ) -> Result<MailFolder, ClientError>

POST /me/mailFolders/{parent_id}/childFolders: create a child folder.

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

DELETE /me/mailFolders/{id}: delete a folder (contents move to Deleted Items).

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 update_draft_recipients( &self, account: &str, message_id: &str, to: Option<&[String]>, cc: Option<&[String]>, bcc: Option<&[String]>, ) -> Result<(), ClientError>

PATCH /me/messages/{id}: replace only the given recipient lists.

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 unsubscribe_one_click(&self, url: &str) -> Result<(), ClientError>

POST a List-Unsubscribe=One-Click form body (RFC 8058) to a third-party unsubscribe URL. No bearer token; the URL belongs to the sender, not Microsoft.

Only https to a public host; see mail::unsubscribe_one_click. A Self::for_test client also reaches a loopback mock server.

pub async fn list_people( &self, account: &str, top: usize, ) -> Result<Vec<Person>, ClientError>

GET /me/people?$top={top}&$select=displayName,scoredEmailAddresses: Outlook’s ranked “people I interact with” list.

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.

pub async fn list_calendars( &self, account: &str, ) -> Result<Vec<Calendar>, ClientError>

GET /me/calendars.

pub async fn list_calendar_view( &self, account: &str, calendar_id: Option<&str>, start: DateTime<Utc>, end: DateTime<Utc>, limit: usize, ) -> Result<EventsPage, ClientError>

GET /me/calendarView (or /me/calendars/{id}/calendarView).

pub async fn list_events_at( &self, account: &str, url: &str, ) -> Result<EventsPage, ClientError>

Fetch a page of calendar events at an absolute Graph continuation URL.

pub async fn get_event( &self, account: &str, event_id: &str, ) -> Result<Event, ClientError>

GET /me/events/{id}.

pub async fn create_event( &self, account: &str, calendar_id: Option<&str>, new_event: &NewEvent, ) -> Result<String, ClientError>

POST /me/calendar/events (or /me/calendars/{id}/events).

pub async fn update_event( &self, account: &str, event_id: &str, new_event: &NewEvent, ) -> Result<(), ClientError>

PATCH /me/events/{id}: overwrite editable fields.

pub async fn move_time( &self, account: &str, event_id: &str, start: DateTime<Utc>, end: DateTime<Utc>, tz: &str, ) -> Result<(), ClientError>

PATCH /me/events/{id}: change only start + end.

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

DELETE /me/events/{id}: silent removal.

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

POST /me/events/{id}/cancel: organizer-only.

pub async fn rsvp_event( &self, account: &str, event_id: &str, kind: RsvpKind, comment: &str, send_response: bool, proposed: Option<&ProposedTime>, ) -> Result<(), ClientError>

POST /me/events/{id}/accept | /tentativelyAccept | /decline.

proposed carries a counter-proposed time; Graph only honors it on tentativelyAccept and decline (ignored for Accept).

pub async fn move_event_to_calendar( &self, account: &str, event_id: &str, destination_calendar_id: &str, ) -> Result<(), ClientError>

PATCH /me/events/{id} with calendar@odata.bind: move between calendars.