imsg 0.4.0

Read and send iMessages from the command line over Bluetooth MAP/PBAP — no Apple hardware required
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

//! `sync` subcommand — one-shot backfill of the local store from the device.

use std::path::Path;

use anyhow::Result;
use config::Config;
use store::Store;
use transport::iroh::Endpoint;

use crate::cli::{folder_arg_to_folder, FolderArg};
use crate::commands::{broker, conn, contacts};

/// Backfills MAP folders since their per-folder cursor anchors, refreshes the contacts cache,
/// and returns a completion message. Sets `sync_enabled = "true"` on success.
///
/// Hub path: direct MAP connection, then a direct PBAP connection for contacts. RFCOMM path:
/// broker IPC for both. The contacts step is not best-effort — same strict `?` propagation as
/// the MAP steps, so a PBAP failure fails the whole command, same as a MAP failure would.
///
/// # Errors
///
/// Returns an error if the MAP connection, any MAP fetch, the contacts refresh, or any store
/// write fails.
pub(crate) async fn run(
    cfg: &Config,
    spoke: Option<&Endpoint>,
    device: Option<&str>,
    store: &Store,
    folder: Option<FolderArg>,
    config_path: Option<&Path>,
) -> Result<String> {
    let folder_scope = folder.map(folder_arg_to_folder);

    if spoke.is_none() {
        let folder_name = folder_scope.map(|f| f.as_str().to_owned());
        let text = broker::sync(cfg, device, config_path, folder_name).await?;
        let contacts = contacts::run_sync(cfg, spoke, device, store, config_path).await?;
        store.set_meta("sync_enabled", "true").await?;
        return Ok(format!("{text}; {contacts}"));
    }

    let mut client = conn::connect_map(cfg, spoke, device).await?;
    let now = session::util::now_ms();
    session::outbox::drain_outbox(&mut client, store, now).await?;
    session::sync::backfill(&mut client, store, folder_scope).await?;
    let contacts = contacts::run_sync(cfg, spoke, device, store, config_path).await?;
    store.set_meta("sync_enabled", "true").await?;
    Ok(format!("sync complete; {contacts}"))
}