Struct MessageRepository 

pub struct MessageRepository { /* private fields */ }

The iMessage database repository.

Implementations

impl MessageRepository

pub fn open(db_path: PathBuf) -> Result<Self>

Open the iMessage database in read-only mode and detect its schema.

pub fn schema(&self) -> &DetectedSchema

Get the detected schema.

pub fn get_message_count(&self, params: &MessageCountParams) -> Result<i64>

Count all messages, with optional filters.

pub fn get_chat_count(&self) -> Result<i64>

Count all chats.

pub fn get_handle_count(&self, address: Option<&str>) -> Result<i64>

Count all handles, optionally filtered by address.

pub fn get_attachment_count(&self) -> Result<i64>

Count all attachments.

pub fn get_message( &self, guid: &str, with_chats: bool, with_attachments: bool, ) -> Result<Option<Message>>

Get a single message by GUID, optionally with chats and attachments.

pub fn get_attachment( &self, attachment_guid: &str, ) -> Result<Option<Attachment>>

Get a single attachment by GUID (handles prefix stripping).

pub fn get_imessage_account(&self) -> Result<Option<String>>

Get the iMessage account login string.

pub fn get_chat_last_message(&self, chat_guid: &str) -> Result<Option<Message>>

Get the last message in a chat by GUID.

pub fn get_messages( &self, params: &MessageQueryParams, ) -> Result<(Vec<Message>, i64)>

Get messages with pagination and filters. Returns (messages, total_count).

pub fn get_updated_messages( &self, params: &UpdatedMessageQueryParams, ) -> Result<Vec<Message>>

Get updated messages (delivered, read, edited, retracted since a date).

pub fn get_chats(&self, params: &ChatQueryParams) -> Result<(Vec<Chat>, i64)>

Get chats with pagination and filters. Returns (chats, total_count).

pub fn get_handles( &self, params: &HandleQueryParams, ) -> Result<(Vec<Handle>, i64)>

Get handles with pagination. Returns (handles, total_count).

pub fn get_attachments_for_message( &self, message_rowid: i64, ) -> Result<Vec<Attachment>>

Get all attachments for a message by message ROWID.

pub fn get_chats_read_since(&self, after_apple_ts: i64) -> Result<Vec<Chat>>

Get chats whose last_read_message_timestamp >= the given Apple timestamp. Used by the chat update poller to detect read status changes.

pub fn get_media_counts( &self, media_type: &str, after: Option<i64>, ) -> Result<i64>

Get media counts (total across all chats).

pub fn get_media_counts_by_chat( &self, chat_guid: &str, media_type: &str, ) -> Result<i64>

Get media counts scoped to a specific chat.