swindon 0.7.8

An HTTP edge (frontend) server with smart websockets support 
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

use std::sync::Arc;
use std::collections::{HashSet, HashMap};
use std::time::SystemTime;

use serde_json::Value as Json;

use chat::Cid;
use intern::{Lattice, SessionId};

pub struct UsersLattice {
    pub(in chat::processor) connections: HashSet<Cid>,
    pub(in chat::processor) peers: HashSet<SessionId>,
}

pub struct Session {
    pub(in chat::processor) status_timestamp: SystemTime,
    pub(in chat::processor) connections: HashSet<Cid>,
    pub(in chat::processor) lattices: HashMap<Lattice, HashSet<Cid>>,
    pub(in chat::processor) users_lattice: UsersLattice,
    pub(in chat::processor) metadata: Arc<Json>,
}

impl Session {
    pub fn new() -> Session {
        Session {
            status_timestamp: SystemTime::now(),
            connections: HashSet::new(),
            lattices: HashMap::new(),
            users_lattice: UsersLattice {
                connections: HashSet::new(),
                peers: HashSet::new(),
            },
            metadata: Arc::new(json!({})),
        }
    }
}