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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
use parking_lot::RwLock;
use serde::{Deserialize, Serialize};
use std::collections::HashMap;
use std::time::{SystemTime, UNIX_EPOCH};
#[derive(Default, Debug, Serialize, Deserialize)]
pub struct FPUser {
key: RwLock<Option<String>>,
attrs: HashMap<String, String>,
}
impl FPUser {
pub fn new() -> Self {
let key = RwLock::new(None);
FPUser {
key,
..Default::default()
}
}
pub fn stable_rollout(mut self, key: String) -> Self {
self.key = RwLock::new(Some(key));
self
}
pub fn with<T: Into<String>>(mut self, k: T, v: T) -> Self {
self.attrs.insert(k.into(), v.into());
self
}
pub fn with_attrs(mut self, attrs: impl Iterator<Item = (String, String)>) -> Self {
self.attrs.extend(attrs);
self
}
pub fn get(&self, k: &str) -> Option<&String> {
self.attrs.get(k)
}
pub fn get_all(&self) -> &HashMap<String, String> {
&self.attrs
}
pub fn key(&self) -> String {
let key = {
let key = self.key.read();
(*key).clone()
};
match key {
Some(key) => key,
None => {
let mut guard = self.key.write();
let key = generate_key();
*guard = Some(key.clone());
key
}
}
}
}
fn generate_key() -> String {
let start = SystemTime::now();
let since_the_epoch = start
.duration_since(UNIX_EPOCH)
.expect("Time went before epoch");
format!("{}", since_the_epoch.as_micros())
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_user_with() {
let u = FPUser::new().with("name", "bob").with("phone", "123");
assert_eq!(u.get("name"), Some(&"bob".to_owned()));
assert_eq!(u.get("phone"), Some(&"123".to_owned()));
assert_eq!(u.get_all().len(), 2);
assert_eq!(u.key(), u.key());
}
#[test]
fn test_user_with_attrs() {
let mut attrs: HashMap<String, String> = Default::default();
attrs.insert("name".to_owned(), "bob".to_owned());
attrs.insert("phone".to_owned(), "123".to_owned());
let u = FPUser::new().with_attrs(attrs.into_iter());
assert_eq!(u.get_all().len(), 2);
}
}