wechat-protocol 1.4.0-beta.0

Native WeChat transport, authentication and protocol codecs
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

//! Inspect one initial sync page after QR login. No cursor or history is committed.
mod support;

fn main() -> anyhow::Result<()> {
    if std::env::args().skip(1).any(|arg| arg == "--help") {
        println!("sync_once: approve a test-account QR login and summarize one initial sync page.");
        return Ok(());
    }
    let (client, mut state) = support::login()?;
    let batch = client.sync(&mut state, &[])?;
    let mut messages = 0;
    for command in &batch.commands {
        if command.id == 5 {
            let _message =
                wechat_protocol::wire::decode_add_message(&command.payload, &state.own_username)?;
            messages += 1;
        }
    }
    println!(
        "commands={} add_messages={} other_commands={} continuation={}",
        batch.commands.len(),
        messages,
        batch.commands.len() - messages,
        batch.continuation
    );
    // This is a preview, not a sync consumer: all raw commands remain in `batch`,
    // and we never save its returned cursor. A persistent client must retain and
    // handle every required command before committing that cursor.
    println!("Preview only. No history or sync cursor was saved.");
    Ok(())
}