whatsapp-rust 0.6.0

Rust client for WhatsApp Web
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

//! Batches unknown-device users during offline sync for deferred usync.
//! WA Web: `OfflinePendingDeviceCache` + `doPendingDeviceSync()`.

use std::collections::HashSet;
use wacore_binary::Jid;

pub(crate) struct PendingDeviceSync {
    pending: async_lock::Mutex<HashSet<Jid>>,
}

impl PendingDeviceSync {
    pub(crate) fn new() -> Self {
        Self {
            pending: async_lock::Mutex::new(HashSet::new()),
        }
    }

    /// Insert a user. Returns `true` if newly inserted, `false` if already present.
    pub(crate) async fn add(&self, jid: Jid) -> bool {
        self.pending.lock().await.insert(jid)
    }

    pub(crate) async fn take_all(&self) -> Vec<Jid> {
        self.pending.lock().await.drain().collect()
    }

    pub(crate) async fn clear(&self) {
        self.pending.lock().await.clear();
    }
}