alpine-protocol-rs 2.0.0

Authenticated Lighting Protocol (alpine): secure control-plane + streaming guard for lighting data.
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

use std::sync::Arc;
use std::time::Duration;

use tokio::sync::Mutex;
use tokio::time;

use super::{HandshakeMessage, HandshakeTransport};
use crate::messages::{Keepalive, MessageType};

/// Spawns a keepalive task that periodically pushes Keepalive frames on the control channel.
pub async fn spawn_keepalive<T>(
    transport: Arc<Mutex<T>>,
    interval: Duration,
    session_id: uuid::Uuid,
) where
    T: HandshakeTransport + Send + 'static,
{
    tokio::spawn(async move {
        let payload = HandshakeMessage::Keepalive(Keepalive {
            message_type: MessageType::Keepalive,
            session_id,
            tick_ms: interval.as_millis() as u64,
        });
        loop {
            time::sleep(interval).await;
            let mut guard = transport.lock().await;
            if let Err(_e) = guard.send(payload.clone()).await {
                // Best-effort; log or trace hook could be added here.
            }
        }
    });
}