use crate::error::*;
use chrono::NaiveDateTime;
use openssl::{
ec::{Asn1Flag, EcGroup, EcKey},
hash::MessageDigest,
nid::Nid,
pkey::{self, PKey},
rsa::Rsa,
stack::Stack,
x509::{extension::SubjectAlternativeName, X509Req, X509ReqBuilder, X509},
};
use std::sync::OnceLock;
pub(crate) fn ec_group_p256() -> &'static EcGroup {
static EC_GROUP_P256: OnceLock<EcGroup> = OnceLock::new();
EC_GROUP_P256.get_or_init(|| ec_group(Nid::X9_62_PRIME256V1))
}
pub(crate) fn ec_group_p384() -> &'static EcGroup {
static EC_GROUP_P384: OnceLock<EcGroup> = OnceLock::new();
EC_GROUP_P384.get_or_init(|| ec_group(Nid::SECP384R1))
}
fn ec_group(nid: Nid) -> EcGroup {
let mut g = EcGroup::from_curve_name(nid).expect("EcGroup");
g.set_asn1_flag(Asn1Flag::NAMED_CURVE);
g
}
pub fn create_rsa_key(bits: u32) -> Result<PKey<pkey::Private>> {
let pri_key_rsa = Rsa::generate(bits)?;
let pkey = PKey::from_rsa(pri_key_rsa)?;
Ok(pkey)
}
pub fn create_p256_key() -> Result<PKey<pkey::Private>> {
let pri_key_ec = EcKey::generate(ec_group_p256())?;
let pkey = PKey::from_ec_key(pri_key_ec)?;
Ok(pkey)
}
pub fn create_p384_key() -> Result<PKey<pkey::Private>> {
let pri_key_ec = EcKey::generate(ec_group_p384())?;
let pkey = PKey::from_ec_key(pri_key_ec)?;
Ok(pkey)
}
pub(crate) fn create_csr(pkey: &PKey<pkey::Private>, domains: &[&str]) -> Result<X509Req> {
let mut req_bld = X509ReqBuilder::new()?;
req_bld.set_pubkey(pkey)?;
let mut stack = Stack::new()?;
let ctx = req_bld.x509v3_context(None);
let mut an = SubjectAlternativeName::new();
for d in domains {
an.dns(d);
}
let ext = an.build(&ctx).context("SubjectAlternativeName::build")?;
stack.push(ext).expect("Stack::push");
req_bld.add_extensions(&stack)?;
req_bld.sign(pkey, MessageDigest::sha256())?;
Ok(req_bld.build())
}
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct Certificate {
private_key: String,
certificate: String,
}
impl Certificate {
pub(crate) fn new(private_key: String, certificate: String) -> Self {
Certificate {
private_key,
certificate,
}
}
pub fn parse(private_key: String, certificate: String) -> Result<Self> {
X509::from_pem(certificate.as_bytes())?;
PKey::private_key_from_pem(private_key.as_bytes())?;
Ok(Certificate {
private_key,
certificate,
})
}
pub fn private_key(&self) -> &str {
&self.private_key
}
pub fn private_key_der(&self) -> Result<Vec<u8>> {
let pkey = PKey::private_key_from_pem(self.private_key.as_bytes())?;
let der = pkey.private_key_to_der()?;
Ok(der)
}
pub fn certificate(&self) -> &str {
&self.certificate
}
pub fn certificate_der(&self) -> Result<Vec<u8>> {
let x509 = X509::from_pem(self.certificate.as_bytes())?;
let der = x509.to_der()?;
Ok(der)
}
pub fn valid_days_left(&self) -> Result<i64> {
if cfg!(test) {
return Ok(89);
}
let x509 = X509::from_pem(self.certificate.as_bytes())?;
let not_after = format!("{}", x509.not_after());
let expires = parse_date(¬_after)?;
let now = chrono::Utc::now();
let dur = expires.signed_duration_since(now);
Ok(dur.num_days())
}
}
fn parse_date(s: &str) -> Result<chrono::DateTime<chrono::Utc>> {
debug!("Parse date/time: {}", s);
let dt = NaiveDateTime::parse_from_str(s, "%b %d %H:%M:%S %Y %Z")?;
Ok(dt.and_utc())
}
#[cfg(test)]
mod test {
use super::*;
#[test]
fn test_parse_date() {
let x = parse_date("May 3 07:40:15 2019 GMT")
.context("input date parsing failed")
.unwrap();
assert_eq!(x.format("%F %T").to_string(), "2019-05-03 07:40:15");
}
}