sessions 0.7.0

General sessions module for web services
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
46
47
48
49
50
51
52
53
54
55
56
57

#![cfg(all(feature = "redis", feature = "session"))]

use std::sync::atomic::Ordering;
use std::sync::Arc;

use anyhow::Result;
use redis::{aio::ConnectionManager, Client};

use sessions::*;

#[tokio::test]
async fn redis() -> Result<()> {
    let config = Arc::new(Store::new(
        RedisStorage::new(ConnectionManager::new(Client::open("unix:///tmp/redis.sock")?).await?),
        nano_id::base64::<32>,
        |sid: &str| sid.len() == 32,
    ));

    let id = (config.generate)();

    assert!(id.len() == 32);
    assert!((config.verify)(&id));

    let session = Session::new(Data::new());
    assert!(session.status().load(Ordering::Acquire) == sessions::UNCHANGED);

    assert!(session
        .set::<String>("crate", "sessions".to_string())
        .is_ok());
    assert!(session.status().load(Ordering::Acquire) == sessions::CHANGED);

    assert_eq!(session.get("crate")?, Some("sessions".to_string()));

    assert_eq!(session.remove("crate"), Some("sessions".into()));
    assert!(session.status().load(Ordering::Acquire) == sessions::CHANGED);

    assert_eq!(session.remove_as::<String>("crate"), None);
    assert!(session.status().load(Ordering::Acquire) == sessions::CHANGED);

    assert_eq!(session.get::<String>("crate")?, None);

    session.clear();
    assert!(session.status().load(Ordering::Acquire) == sessions::CHANGED);
    session.clear();
    assert!(session.status().load(Ordering::Acquire) == sessions::CHANGED);

    let session = Session::new(Data::new());
    assert!(session.status().load(Ordering::Acquire) == sessions::UNCHANGED);

    session.renew();
    assert!(session.status().load(Ordering::Acquire) == sessions::RENEWED);

    session.purge();
    assert!(session.status().load(Ordering::Acquire) == sessions::PURGED);

    Ok(())
}