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
50
51
52
53
54
55
56
57
58
59
60
61

//! Cached PBAP contact reads — direct `Store` queries, no network at all.
//!
//! `--get`'s key is the cached UID here, not a PBAP handle — the store never caches those (see
//! `render.rs`'s `EntryView` doc) — matching whatever `--list` prints in this mode.

use anyhow::Result;
use store::Store;

use super::render::{
    offset_of, render_contact_view, render_contacts_view, render_entries_view, ContactView,
    EntryView,
};
use super::ContactsOpts;

/// Reads cached phonebook data from the local store, with a freshness footer. Never opens a
/// Bluetooth connection. Exactly one of `--lookup`/`--get`/`--list`/pull-all (the default) runs,
/// per `opts`.
///
/// # Errors
///
/// Returns an error if the store read or `contacts_synced_at` query fails, or (for `--get`) if
/// `uid` isn't cached.
pub(crate) async fn run(opts: &ContactsOpts, store: &Store) -> Result<String> {
    let mut out = render(opts, store).await?;
    if !out.ends_with('\n') {
        out.push('\n');
    }
    out.push_str(&crate::commands::freshness_line(store.contacts_synced_at().await?));
    Ok(out)
}

async fn render(opts: &ContactsOpts, store: &Store) -> Result<String> {
    if let Some(number) = &opts.lookup {
        // Already normalised by the dispatcher (crate::commands::dispatch::run_contacts), before
        // the store/live fork.
        return Ok(store.lookup_contact(number).await?.map_or_else(
            || format!("no contact found for {number}"),
            |c| render_contact_view(&ContactView::from_row(&c), opts.raw),
        ));
    }
    if let Some(uid) = &opts.get {
        let row = store
            .get_contact(uid)
            .await?
            .ok_or_else(|| anyhow::anyhow!("contact {uid} not found in local store"))?;
        return Ok(render_contact_view(&ContactView::from_row(&row), opts.raw));
    }
    let offset = offset_of(opts.limit, opts.page);
    let limit = opts.limit.unwrap_or(u16::MAX);
    if opts.list {
        let entries = store.list_contacts(limit, offset).await?;
        let views: Vec<EntryView> = entries.iter().map(EntryView::from_row).collect();
        return Ok(render_entries_view(&views));
    }
    let contacts = store.all_contacts(limit, offset).await?;
    if contacts.is_empty() {
        return Ok("(no contacts)".to_owned());
    }
    let views: Vec<ContactView> = contacts.iter().map(ContactView::from_row).collect();
    Ok(render_contacts_view(&views, opts.raw))
}