doido-cable 0.0.11

Action Cable analogue: channels, broadcasts, Turbo-friendly pub/sub backends for Doido.
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

//! ActionCable heartbeat pings. Apps drive a periodic timer (e.g. a tokio
//! interval) and send [`ping_now`] frames to keep connections alive.

use crate::protocol::ServerFrame;
use std::time::{SystemTime, UNIX_EPOCH};

/// A heartbeat ping frame carrying `epoch_secs`.
pub fn ping(epoch_secs: i64) -> ServerFrame {
    ServerFrame::Ping {
        message: epoch_secs,
    }
}

/// A heartbeat ping for the current unix time.
pub fn ping_now() -> ServerFrame {
    ping(unix_now())
}

fn unix_now() -> i64 {
    SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .map(|d| d.as_secs() as i64)
        .unwrap_or(0)
}