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
use std::{collections::HashMap, ops::Deref};
use serde::Deserialize;
type ClientSdkKey = String;
type ServerSdkKey = String;
#[derive(Deserialize, Debug, Default, Clone)]
pub struct SecretMapping {
version: u128,
mapping: HashMap<ClientSdkKey, ServerSdkKey>,
#[serde(skip)]
reverse: HashMap<ServerSdkKey, ClientSdkKey>,
}
impl SecretMapping {
#[cfg(test)]
pub fn new(version: u128, mapping: HashMap<ClientSdkKey, ServerSdkKey>) -> Self {
let mut reverse = HashMap::new();
for (k, v) in &mapping {
reverse.insert(v.clone(), k.clone());
}
Self {
version,
mapping,
reverse,
}
}
pub fn version(&self) -> u128 {
self.version
}
pub fn update_mapping(&mut self, new: SecretMapping) {
if new.version > self.version {
self.version = new.version;
self.mapping = new.mapping;
let mut reverse = HashMap::new();
for (k, v) in &self.mapping {
reverse.insert(v.clone(), k.clone());
}
self.reverse = reverse;
}
}
pub fn client_sdk_key(&self, server_sdk_key: &str) -> Option<&String> {
self.reverse.get(server_sdk_key)
}
pub fn server_sdk_key(&self, client_sdk_key: &str) -> Option<&String> {
self.mapping.get(client_sdk_key)
}
pub fn server_sdk_keys(&self) -> Vec<&String> {
self.reverse.keys().into_iter().collect()
}
pub fn mapping_clone(&self) -> HashMap<String, String> {
self.mapping.clone()
}
pub fn insert(&mut self, client_sdk_key: String, server_sdk_key: String, version: u128) {
self.version = version;
self.mapping
.insert(client_sdk_key.clone(), server_sdk_key.clone());
self.reverse.insert(server_sdk_key, client_sdk_key);
}
pub fn contains_server_sdk_key(&self, server_sdk_key: &str) -> bool {
self.reverse.contains_key(server_sdk_key)
}
}
impl Deref for SecretMapping {
type Target = HashMap<ClientSdkKey, ServerSdkKey>;
fn deref(&self) -> &Self::Target {
&self.mapping
}
}