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.

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 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, ) -> Result<(), ClientError>

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

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.

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

GET /me/events?$search=“”.