wacore 0.7.0

Core WhatsApp protocol implementation without runtime dependencies
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

use crate::client::context::{GroupInfo, SendContextResolver};
use crate::libsignal::protocol::{
    CiphertextMessage, IdentityChange, ProtocolAddress, SenderKeyMessage, SenderKeyStore,
    UsePQRatchet, message_encrypt, process_prekey_bundle,
};
use crate::libsignal::store::sender_key_name::SenderKeyName;
use crate::messages::MessageUtils;
use crate::reporting_token::{
    build_reporting_node, generate_reporting_token, generate_reporting_token_from_encoded,
    reporting_context_info,
};
use crate::runtime::{AbortHandle, Runtime};
use crate::types::jid::JidExt;
use crate::types::jid::make_sender_key_name;
use crate::types::message::PeerMessageOptions;
use anyhow::{Result, anyhow, bail};
use futures::stream::{FuturesUnordered, StreamExt};
use rand::{CryptoRng, Rng};
use std::collections::HashSet;
use std::future::Future;
use wacore_binary::Node;
use wacore_binary::builder::NodeBuilder;
use wacore_binary::{CompactString, Jid, JidExt as _};
use waproto::whatsapp as wa;

/// Wire-format constants (MsgCreateDeviceStanza.js).
pub(crate) mod stanza {
    pub const ENC_VERSION: &str = "2";
    pub const MSG_TYPE_TEXT: &str = "text";
    pub const MSG_TYPE_MEDIA: &str = "media";
    pub const MSG_TYPE_REACTION: &str = "reaction";
    pub const MSG_TYPE_POLL: &str = "poll";
    pub const MSG_TYPE_EVENT: &str = "event";
    pub const ENC_TYPE_MSG: &str = "msg";
    pub const ENC_TYPE_PKMSG: &str = "pkmsg";
    pub const ENC_TYPE_SKMSG: &str = "skmsg";
    pub const MSG_TYPE_PAY: &str = "pay";
}

/// Type-safe `<message type="...">` value for the send-time override.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum StanzaType {
    Text,
    Media,
    Reaction,
    Poll,
    Event,
    Pay,
}

impl StanzaType {
    pub fn as_wire(self) -> &'static str {
        match self {
            Self::Text => stanza::MSG_TYPE_TEXT,
            Self::Media => stanza::MSG_TYPE_MEDIA,
            Self::Reaction => stanza::MSG_TYPE_REACTION,
            Self::Poll => stanza::MSG_TYPE_POLL,
            Self::Event => stanza::MSG_TYPE_EVENT,
            Self::Pay => stanza::MSG_TYPE_PAY,
        }
    }
}

mod classify;
mod dm;
mod encrypt;
mod group;
mod peer;
mod resolved_devices;
mod status;

pub use classify::*;
#[cfg(test)]
pub(crate) use dm::partition_dm_devices;
pub use dm::*;
pub use encrypt::*;
pub use group::*;
pub use peer::*;
pub use resolved_devices::{ResolvedDmDevices, ResolvedGroupDevices};
pub use status::*;

#[cfg(test)]
mod tests;