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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
#![warn(rust_2018_idioms)]
#![deny(
missing_copy_implementations,
missing_debug_implementations,
)]
#![allow(clippy::use_self)]
#![cfg_attr(docsrs, feature(doc_cfg))]
use std::num::NonZeroU8;
#[cfg(feature = "serde")]
use serde::de::{self, Deserialize as _, Deserializer, Unexpected};
#[doc(inline)]
pub use crate::{error::Error, server_name::is_valid_server_name};
#[macro_use]
mod macros;
mod error;
mod server_name;
pub mod device_id;
pub mod event_id;
pub mod room_alias_id;
pub mod room_id;
pub mod room_id_or_room_alias_id;
pub mod room_version_id;
pub mod user_id;
pub type EventId<'a> = event_id::EventId<&'a str>;
pub type EventIdBox = event_id::EventId<Box<str>>;
pub type RoomAliasId<'a> = room_alias_id::RoomAliasId<&'a str>;
pub type RoomAliasIdBox = room_alias_id::RoomAliasId<Box<str>>;
pub type RoomId<'a> = room_id::RoomId<&'a str>;
pub type RoomIdBox = room_id::RoomId<Box<str>>;
pub type RoomIdOrAliasId<'a> = room_id_or_room_alias_id::RoomIdOrAliasId<&'a str>;
pub type RoomIdOrAliasIdBox = room_id_or_room_alias_id::RoomIdOrAliasId<Box<str>>;
pub type RoomVersionId<'a> = room_version_id::RoomVersionId<&'a str>;
pub type RoomVersionIdBox = room_version_id::RoomVersionId<Box<str>>;
pub type UserId<'a> = user_id::UserId<&'a str>;
pub type UserIdBox = user_id::UserId<Box<str>>;
const MAX_BYTES: usize = 255;
const MIN_CHARS: usize = 4;
#[cfg(feature = "rand")]
fn generate_localpart(length: usize) -> String {
use rand::Rng as _;
rand::thread_rng()
.sample_iter(&rand::distributions::Alphanumeric)
.take(length)
.collect()
}
fn validate_id(id: &str, valid_sigils: &[char]) -> Result<(), Error> {
if id.len() > MAX_BYTES {
return Err(Error::MaximumLengthExceeded);
}
if id.len() < MIN_CHARS {
return Err(Error::MinimumLengthNotSatisfied);
}
if !valid_sigils.contains(&id.chars().next().unwrap()) {
return Err(Error::MissingSigil);
}
Ok(())
}
fn parse_id(id: &str, valid_sigils: &[char]) -> Result<NonZeroU8, Error> {
validate_id(id, valid_sigils)?;
let colon_idx = id.find(':').ok_or(Error::MissingDelimiter)?;
if colon_idx < 2 {
return Err(Error::InvalidLocalPart);
}
if !is_valid_server_name(&id[colon_idx + 1..]) {
return Err(Error::InvalidServerName);
}
Ok(NonZeroU8::new(colon_idx as u8).unwrap())
}
#[cfg(feature = "serde")]
fn deserialize_id<'de, D, T>(deserializer: D, expected_str: &str) -> Result<T, D::Error>
where
D: Deserializer<'de>,
T: for<'a> std::convert::TryFrom<&'a str>,
{
std::borrow::Cow::<'_, str>::deserialize(deserializer).and_then(|v| {
T::try_from(&v).map_err(|_| de::Error::invalid_value(Unexpected::Str(&v), &expected_str))
})
}