Struct AppState 

pub struct AppState {
    pub config: Arc<AppConfig>,
    pub imessage_repo: Arc<Mutex<MessageRepository>>,
    pub private_api: Option<Arc<PrivateApiService>>,
    pub webhook_service: Option<Arc<WebhookService>>,
    pub findmy_friends_cache: Arc<Mutex<FindMyFriendsCache>>,
    pub findmy_key: Arc<Mutex<Option<[u8; 32]>>>,
    pub send_cache: Arc<Mutex<HashMap<String, Instant>>>,
    pub typing_cache: Arc<Mutex<HashSet<String>>>,
    pub findmy_refresh_lock: Arc<Mutex<()>>,
}

Shared application state. MessageRepository wraps rusqlite::Connection which is not Send+Sync, so we wrap it in a Mutex for thread-safe access.

Fields

config: Arc<AppConfig>

imessage_repo: Arc<Mutex<MessageRepository>>

private_api: Option<Arc<PrivateApiService>>

webhook_service: Option<Arc<WebhookService>>

findmy_friends_cache: Arc<Mutex<FindMyFriendsCache>>

Cached FindMy friends locations (handle -> location JSON) + last refresh time

findmy_key: Arc<Mutex<Option<[u8; 32]>>>

Cached FindMy device decryption key (32 bytes, from Keychain via FindMy.app)

send_cache: Arc<Mutex<HashMap<String, Instant>>>

Send cache for deduplication (tempGuid -> timestamp)

typing_cache: Arc<Mutex<HashSet<String>>>

Typing cache: tracks chats with active typing indicators (auto-stopped before sends)

findmy_refresh_lock: Arc<Mutex<()>>

Mutex to prevent concurrent FindMy device refreshes

Implementations

impl AppState

pub fn new( config: AppConfig, imessage_repo: MessageRepository, private_api: Option<Arc<PrivateApiService>>, webhook_service: Option<Arc<WebhookService>>, ) -> Self

pub fn require_private_api(&self) -> Result<Arc<PrivateApiService>, AppError>

Get a reference to the Private API service, or return an error if not available/ready. Requires the Messages.app dylib to have completed IMCore initialization.

pub fn require_findmy_private_api( &self, ) -> Result<Arc<PrivateApiService>, AppError>

Get a reference to the FindMy Private API service, or return an error if not enabled/ready. Requires the FindMy.app dylib to be connected and ready.

pub fn require_facetime_private_api( &self, ) -> Result<Arc<PrivateApiService>, AppError>

Get a reference to the FaceTime Private API service, or return an error if not enabled/ready. Requires the FaceTime.app dylib to be connected and ready.

pub fn is_send_cached(&self, temp_guid: &str) -> bool

Check if a tempGuid is already in the send cache

pub fn cache_send(&self, temp_guid: String)

Add a tempGuid to the send cache

pub fn uncache_send(&self, temp_guid: &str)

Remove a tempGuid from the send cache

Trait Implementations

impl Clone for AppState

fn clone(&self) -> AppState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.