use std::fs;
use std::net::{IpAddr, SocketAddr};
use std::path::Path;
use crate::error::{Error, Result};
pub fn load_secret_key_bytes(path: &Path) -> Result<Option<[u8; 32]>> {
if !path.exists() {
return Ok(None);
}
let bytes = fs::read(path).map_err(|e| Error::SecretKey(e.to_string()))?;
let key_bytes: [u8; 32] = bytes
.as_slice()
.try_into()
.map_err(|_| Error::SecretKey(format!("invalid key file length in {}", path.display())))?;
Ok(Some(key_bytes))
}
pub fn generate_secret_key_file(path: &Path) -> Result<[u8; 32]> {
if path.exists() {
return Err(Error::SecretKey(format!(
"secret key already exists at {}",
path.display()
)));
}
let mut key_bytes = [0u8; 32];
use rand::RngCore;
rand::rngs::OsRng.fill_bytes(&mut key_bytes);
if let Some(parent) = path.parent() {
fs::create_dir_all(parent).map_err(|e| {
Error::SecretKey(format!("failed to create dir {}: {}", parent.display(), e))
})?;
}
fs::write(path, key_bytes)
.map_err(|e| Error::SecretKey(format!("failed to write {}: {}", path.display(), e)))?;
#[cfg(unix)]
{
use std::os::unix::fs::PermissionsExt;
let _ = fs::set_permissions(path, fs::Permissions::from_mode(0o400));
}
Ok(key_bytes)
}
pub fn socket_addr_to_multiaddr(addr: &SocketAddr) -> String {
match addr.ip() {
IpAddr::V4(ip) => format!("/ip4/{}/udp/{}/quic-v1", ip, addr.port()),
IpAddr::V6(ip) => format!("/ip6/{}/udp/{}/quic-v1", ip, addr.port()),
}
}
#[cfg(test)]
mod tests {
use super::*;
use std::net::{Ipv4Addr, Ipv6Addr};
use std::path::PathBuf;
fn test_tmp_file(name: &str) -> PathBuf {
let root = PathBuf::from(env!("CARGO_MANIFEST_DIR"))
.join("tmp")
.join("identity-tests");
fs::create_dir_all(&root).expect("failed creating test tmp directory");
root.join(name)
}
#[test]
fn multiaddr_ipv4() {
let addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 4433);
assert_eq!(
socket_addr_to_multiaddr(&addr),
"/ip4/127.0.0.1/udp/4433/quic-v1"
);
}
#[test]
fn multiaddr_ipv6() {
let addr = SocketAddr::new(IpAddr::V6(Ipv6Addr::LOCALHOST), 5555);
assert_eq!(socket_addr_to_multiaddr(&addr), "/ip6/::1/udp/5555/quic-v1");
}
#[test]
fn load_missing_returns_none() {
let path = test_tmp_file("nonexistent-key");
let _ = fs::remove_file(&path);
assert!(load_secret_key_bytes(&path).unwrap().is_none());
}
#[test]
fn generate_and_load_round_trip() {
let path = test_tmp_file("round-trip-key");
let _ = fs::remove_file(&path);
let generated = generate_secret_key_file(&path).unwrap();
let loaded = load_secret_key_bytes(&path).unwrap().unwrap();
assert_eq!(generated, loaded);
let _ = fs::remove_file(&path);
}
#[test]
fn generate_refuses_overwrite() {
let path = test_tmp_file("no-overwrite-key");
let _ = fs::remove_file(&path);
generate_secret_key_file(&path).unwrap();
let err = generate_secret_key_file(&path).unwrap_err();
assert!(matches!(err, crate::error::Error::SecretKey(_)));
let _ = fs::remove_file(&path);
}
}