use std::io::Read;
use base64::{Engine as _, engine::general_purpose as base64_engine};
use serde::Deserialize;
use zeroize::{Zeroize, ZeroizeOnDrop};
use crate::crypt::calculate_sha256;
pub type KeyElement = Vec<u8>;
pub type KeyElements = Vec<KeyElement>;
#[derive(Debug, thiserror::Error)]
pub enum DatabaseKeyError {
#[error("Incorrect key")]
IncorrectKey,
#[error(transparent)]
Cryptography(#[from] crate::crypt::CryptographyError),
#[error(transparent)]
Io(#[from] std::io::Error),
#[error(transparent)]
Xml(#[from] quick_xml::DeError),
#[error("Could not obtain a key from the keyfile")]
InvalidKeyFile,
#[cfg(feature = "challenge_response")]
#[error(transparent)]
ChallengeResponse(#[from] yubikey::ChallengeResponseKeyError),
}
#[cfg(feature = "challenge_response")]
mod yubikey;
#[cfg(feature = "challenge_response")]
pub use yubikey::{ChallengeResponseKey, ChallengeResponseKeyError};
fn parse_xml_keyfile(xml: &[u8]) -> Result<KeyElement, DatabaseKeyError> {
#[derive(Deserialize)]
struct KeyFileXml {
#[serde(rename = "Meta", default)]
meta: Option<KeyMetaXml>,
#[serde(rename = "Key", default)]
key: Option<KeyDataXml>,
}
#[derive(Deserialize)]
struct KeyMetaXml {
#[serde(rename = "Version", default)]
version: Option<String>,
}
#[derive(Deserialize)]
struct KeyDataXml {
#[serde(rename = "Data", default)]
data: Option<String>,
}
let parsed: KeyFileXml = quick_xml::de::from_reader(xml)?;
let key_version = parsed.meta.and_then(|meta| meta.version);
let key_value = parsed.key.and_then(|key| key.data).unwrap_or_default();
if key_value.is_empty() {
return Err(DatabaseKeyError::InvalidKeyFile);
}
let key_bytes = key_value.as_bytes().to_vec();
if key_version == Some("2.0".to_string()) {
let trimmed_key = key_value
.trim()
.replace(" ", "")
.replace("\n", "")
.replace("\t", "")
.replace("\r", "");
return if let Ok(key) = hex::decode(&trimmed_key) {
Ok(key)
} else {
Ok(key_bytes)
};
}
if let Ok(key) = base64_engine::STANDARD.decode(&key_bytes) {
Ok(key)
} else {
Ok(key_bytes)
}
}
fn parse_keyfile(buffer: &[u8]) -> KeyElement {
if let Ok(v) = parse_xml_keyfile(buffer) {
v
} else if buffer.len() == 32 {
buffer.to_vec()
} else {
calculate_sha256(&[buffer]).as_slice().to_vec()
}
}
#[derive(Debug, Clone, Default, PartialEq, Zeroize, ZeroizeOnDrop)]
pub struct DatabaseKey {
password: Option<String>,
keyfile: Option<Vec<u8>>,
#[cfg(feature = "challenge_response")]
challenge_response_key: Option<ChallengeResponseKey>,
#[cfg(feature = "challenge_response")]
challenge_response_result: Option<KeyElement>,
}
impl DatabaseKey {
pub fn with_password(mut self, password: &str) -> Self {
self.password = Some(password.to_string());
self
}
#[cfg(feature = "utilities")]
pub fn with_password_from_prompt(mut self, prompt_message: &str) -> Result<Self, std::io::Error> {
self.password = Some(rpassword::prompt_password(prompt_message)?);
Ok(self)
}
#[cfg(all(feature = "challenge_response", feature = "utilities"))]
pub fn with_hmac_sha1_secret_from_prompt(mut self, prompt_message: &str) -> Result<Self, std::io::Error> {
self.challenge_response_key = Some(ChallengeResponseKey::LocalChallenge(rpassword::prompt_password(prompt_message)?));
Ok(self)
}
pub fn with_keyfile(mut self, keyfile: &mut dyn Read) -> Result<Self, std::io::Error> {
let mut buf = Vec::new();
keyfile.read_to_end(&mut buf)?;
self.keyfile = Some(buf);
Ok(self)
}
#[cfg(feature = "challenge_response")]
pub fn with_challenge_response_key(mut self, challenge_response_key: ChallengeResponseKey) -> Self {
self.challenge_response_key = Some(challenge_response_key);
self
}
#[cfg(feature = "challenge_response")]
pub fn perform_challenge(mut self, kdf_seed: &[u8]) -> Result<Self, DatabaseKeyError> {
if let Some(challenge_response_key) = &self.challenge_response_key {
let response = challenge_response_key.perform_challenge(kdf_seed)?;
self.challenge_response_result = Some(response);
}
Ok(self)
}
pub fn new() -> Self {
DatabaseKey::default()
}
pub(crate) fn get_key_elements(&self) -> Result<KeyElements, DatabaseKeyError> {
let mut out = Vec::new();
if let Some(p) = &self.password {
out.push(calculate_sha256(&[p.as_bytes()]).to_vec());
}
if let Some(ref f) = self.keyfile {
out.push(parse_keyfile(f));
}
if out.is_empty() {
return Err(DatabaseKeyError::IncorrectKey);
}
#[cfg(feature = "challenge_response")]
if let Some(result) = &self.challenge_response_result {
out.push(calculate_sha256(&[result]).as_slice().to_vec());
} else if self.challenge_response_key.is_some() {
return Err(DatabaseKeyError::ChallengeResponse(ChallengeResponseKeyError::NotPerformed));
}
Ok(out)
}
pub fn is_empty(&self) -> bool {
if self.password.is_some() || self.keyfile.is_some() {
return false;
}
#[cfg(feature = "challenge_response")]
if self.challenge_response_key.is_some() {
return false;
}
true
}
}
#[cfg(test)]
mod key_tests {
use crate::error::DatabaseKeyError;
use super::DatabaseKey;
#[test]
fn test_key() -> Result<(), DatabaseKeyError> {
let ke = DatabaseKey::new().with_password("asdf").get_key_elements()?;
assert_eq!(ke.len(), 1);
let ke = DatabaseKey::new()
.with_keyfile(&mut "bare-key-file".as_bytes())?
.get_key_elements()?;
assert_eq!(ke.len(), 1);
let ke = DatabaseKey::new()
.with_keyfile(&mut "0123456789ABCDEF0123456789ABCDEF".as_bytes())?
.get_key_elements()?;
assert_eq!(ke.len(), 1);
let ke = DatabaseKey::new()
.with_password("asdf")
.with_keyfile(&mut "bare-key-file".as_bytes())?
.get_key_elements()?;
assert_eq!(ke.len(), 2);
let ke = DatabaseKey::new()
.with_keyfile(&mut "<KeyFile><Key><Data>0!23456789ABCDEF0123456789ABCDEF</Data></Key></KeyFile>".as_bytes())?
.get_key_elements()?;
assert_eq!(ke.len(), 1);
let ke = DatabaseKey::new()
.with_keyfile(&mut "<KeyFile><Key><Data>NXyYiJMHg3ls+eBmjbAjWec9lcOToJiofbhNiFMTJMw=</Data></Key></KeyFile>".as_bytes())?
.get_key_elements()?;
assert_eq!(ke.len(), 1);
let xml_keyfile_v2 = r###"
<?xml version="1.0" encoding="utf-8"?>
<KeyFile>
<Meta>
<Version>2.0</Version>
</Meta>
<Key>
<Data Hash="A65F0C2D">
36057B1C 35037FD9 62257893 C0A22403
EE3F8FBB 504D9981 08B821CB 00D28F89
</Data>
</Key>
</KeyFile>
"###;
let ke = DatabaseKey::new()
.with_keyfile(&mut xml_keyfile_v2.trim().as_bytes())?
.get_key_elements()?;
assert_eq!(ke.len(), 1);
let ke = DatabaseKey::new()
.with_keyfile(&mut "<Not><A><KeyFile></KeyFile></A></Not>".as_bytes())?
.get_key_elements()?;
assert_eq!(ke.len(), 1);
assert!(
DatabaseKey {
password: None,
keyfile: None,
#[cfg(feature = "challenge_response")]
challenge_response_key: None,
#[cfg(feature = "challenge_response")]
challenge_response_result: None,
}
.get_key_elements()
.is_err()
);
Ok(())
}
}