Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
47 changes: 20 additions & 27 deletions src/tls.rs
Original file line number Diff line number Diff line change
Expand Up @@ -24,12 +24,15 @@ pub(crate) enum TlsConfigError {
/// An Error parsing the Certificate
CertParseError,
/// Identity PEM is invalid
#[allow(dead_code)]
InvalidIdentityPem,
/// Identity PEM is missing a private key such as RSA, ECC or PKCS8
MissingPrivateKey,
/// Unknown private key format
#[allow(dead_code)]
UnknownPrivateKeyFormat,
/// An error from an empty key
#[allow(dead_code)]
EmptyKey,
/// An error from an invalid key
InvalidKey(TlsError),
Expand Down Expand Up @@ -171,38 +174,16 @@ impl TlsConfigBuilder {
self
}

pub(crate) fn build(mut self) -> Result<ServerConfig, TlsConfigError> {
pub(crate) fn build(self) -> Result<ServerConfig, TlsConfigError> {
let mut cert_rdr = BufReader::new(self.cert);
let cert = rustls_pemfile::certs(&mut cert_rdr)
.collect::<Result<Vec<_>, _>>()
.map_err(|_e| TlsConfigError::CertParseError)?;

let mut key_vec = Vec::new();
self.key
.read_to_end(&mut key_vec)
.map_err(TlsConfigError::Io)?;

if key_vec.is_empty() {
return Err(TlsConfigError::EmptyKey);
}

let mut key_opt = None;
let mut key_cur = std::io::Cursor::new(key_vec);
for item in rustls_pemfile::read_all(&mut key_cur)
.collect::<Result<Vec<_>, _>>()
.map_err(|_e| TlsConfigError::InvalidIdentityPem)?
{
match item {
rustls_pemfile::Item::Pkcs1Key(k) => key_opt = Some(k.into()),
rustls_pemfile::Item::Pkcs8Key(k) => key_opt = Some(k.into()),
rustls_pemfile::Item::Sec1Key(k) => key_opt = Some(k.into()),
_ => return Err(TlsConfigError::UnknownPrivateKeyFormat),
}
}
let key = match key_opt {
Some(v) => v,
_ => return Err(TlsConfigError::MissingPrivateKey),
};
let mut key_rdr = BufReader::new(self.key);
let key = rustls_pemfile::private_key(&mut key_rdr)
.map_err(TlsConfigError::Io)?
.ok_or(TlsConfigError::MissingPrivateKey)?;

fn read_trust_anchor(
trust_anchor: Box<dyn Read + Send + Sync>,
Expand Down Expand Up @@ -442,4 +423,16 @@ mod tests {
.build()
.unwrap();
}

#[test]
fn cert_key_as_one() {
let key = include_str!("../examples/tls/key.ecc");
let cert = include_str!("../examples/tls/cert.ecc.pem");
let combined = format!("{cert}\n{key}");
TlsConfigBuilder::new()
.key(combined.as_bytes())
.cert(combined.as_bytes())
.build()
.unwrap();
}
}