imsg-session 0.4.0

Session lifecycle — RFCOMM/iroh connect, OBEX handshake, reconnect, and MNS relay
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

//! Cases driven by the metadata-only probe: no-op, wipe-vs-no-wipe on `PbapMeta` changes.

use store::{NewContact, PbapMeta, PhoneField};

use super::{body_rsp, fake_store, hex16, list_body, metadata_rsp, run_sync, vcard};
use super::{Refresh, SyncReport, A, B, C, D};

#[tokio::test]
async fn noop_when_metadata_unchanged() -> anyhow::Result<()> {
    let (db, _dir) = fake_store().await?;
    db.set_pbap_meta(&PbapMeta {
        database_id: Some(hex16(A)),
        primary_version: Some(hex16(B)),
        secondary_version: Some(hex16(C)),
    })
    .await?;
    let report = run_sync(&db, &[metadata_rsp(A, B, C)?]).await?;
    assert_eq!(report?, SyncReport::UpToDate);
    assert_eq!(db.get_meta("contacts_synced").await?.as_deref(), Some("true"));
    assert!(db.contacts_synced_at().await?.is_some());
    Ok(())
}

#[tokio::test]
async fn refreshes_without_wipe_when_only_counters_change() -> anyhow::Result<()> {
    let (db, _dir) = fake_store().await?;
    db.upsert_contacts(vec![NewContact {
        uid: "uid-old".to_owned(),
        display_name: Some("Old".to_owned()),
        phones: vec![PhoneField::new("+15559999", None)],
    }])
    .await?;
    db.set_pbap_meta(&PbapMeta {
        database_id: Some(hex16(A)),
        primary_version: Some(hex16(B)),
        secondary_version: Some(hex16(C)),
    })
    .await?;
    let report = run_sync(
        &db,
        &[
            metadata_rsp(A, D, D)?,
            body_rsp(&list_body(&["1.vcf"]))?,
            body_rsp(&vcard(Some("uid-new"), "New", "+15550002"))?,
        ],
    )
    .await?;
    assert_eq!(
        report?,
        SyncReport::Refreshed(Refresh {
            listed: 1,
            pull_failed: 0,
            no_uid: 0,
            written: 1,
            wiped: false,
        })
    );
    assert!(db.get_contact("uid-old").await?.is_some(), "no-wipe path must preserve old contact");
    assert!(db.get_contact("uid-new").await?.is_some());
    assert_eq!(db.get_meta("contacts_synced").await?.as_deref(), Some("true"));
    assert!(db.contacts_synced_at().await?.is_some());
    Ok(())
}

#[tokio::test]
async fn wipes_when_database_id_changes() -> anyhow::Result<()> {
    let (db, _dir) = fake_store().await?;
    db.upsert_contacts(vec![NewContact {
        uid: "uid-stale".to_owned(),
        display_name: Some("Stale".to_owned()),
        phones: vec![PhoneField::new("+15559999", None)],
    }])
    .await?;
    db.set_pbap_meta(&PbapMeta {
        database_id: Some(hex16(A)),
        primary_version: Some(hex16(B)),
        secondary_version: Some(hex16(C)),
    })
    .await?;
    let report = run_sync(
        &db,
        &[
            metadata_rsp(D, D, D)?,
            body_rsp(&list_body(&["1.vcf"]))?,
            body_rsp(&vcard(Some("uid-new"), "New", "+15550002"))?,
        ],
    )
    .await?;
    assert_eq!(
        report?,
        SyncReport::Refreshed(Refresh {
            listed: 1,
            pull_failed: 0,
            no_uid: 0,
            written: 1,
            wiped: true,
        })
    );
    assert!(db.get_contact("uid-stale").await?.is_none(), "changed database_id must wipe cache");
    assert!(db.get_contact("uid-new").await?.is_some());
    assert_eq!(db.get_meta("contacts_synced").await?.as_deref(), Some("true"));
    assert!(db.contacts_synced_at().await?.is_some());
    Ok(())
}