cig 0.1.2

Simplify TCP/IP applications with a transparential, persistent-mode and data-driven protocol
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

use std::time::{Duration, SystemTime};

use serde::{Deserialize, Serialize};

use crate::PeerID;

#[derive(Debug, Deserialize, Serialize)]
pub enum PkgData<T> {
    Close,
    SetPeers(Vec<Option<String>>),
    SetPeer(PeerID),
    Data(T, PeerID), // unique
    GlobalData(T),   // to everyone
}

#[derive(Debug, Deserialize, Serialize)]
pub struct Pkg<T> {
    pub sender: PeerID,
    pub time: Duration, // for Instant = UNIX_EPOCH + Duration
    pub data: PkgData<T>,
}

impl<T> Pkg<T> {
    pub fn is_from_server(&self) -> bool {
        self.sender == 0
    }

    pub fn new(sender: PeerID, data: PkgData<T>) -> Self {
        Self {
            sender,
            time: SystemTime::now()
                .duration_since(std::time::UNIX_EPOCH)
                .unwrap(),
            data,
        }
    }

    pub fn as_data(&self) -> &T {
        match self.data {
            PkgData::Data(ref d, _) => d,
            PkgData::GlobalData(ref d) => d,
            _ => panic!("it isn't data"),
        }
    }
}