use std::io::{self, Read};
use base64::{engine::general_purpose::STANDARD as BASE64, Engine};
use clap::Parser;
use sha2::{Digest, Sha256};
use crate::{
commands::global,
config::{locator, secret},
print::Print,
signer::{self, Signer},
};
use super::SEP53_PREFIX;
#[derive(thiserror::Error, Debug)]
pub enum Error {
#[error(transparent)]
Locator(#[from] locator::Error),
#[error(transparent)]
Secret(#[from] secret::Error),
#[error(transparent)]
Signer(#[from] signer::Error),
#[error(transparent)]
Io(#[from] io::Error),
#[error(transparent)]
Base64(#[from] base64::DecodeError),
#[error(transparent)]
StrKey(#[from] stellar_strkey::DecodeError),
#[error(transparent)]
Ed25519(#[from] ed25519_dalek::SignatureError),
#[error("No signing key provided. Use --sign-with-key")]
NoSigningKey,
#[error("Ledger signing of arbitrary messages is not yet supported")]
LedgerNotSupported,
}
#[derive(Debug, Parser, Clone)]
#[group(skip)]
pub struct Cmd {
#[arg()]
pub message: Option<String>,
#[arg(long)]
pub base64: bool,
#[arg(long, env = "STELLAR_SIGN_WITH_KEY")]
pub sign_with_key: String,
#[arg(long)]
pub hd_path: Option<usize>,
#[command(flatten)]
pub locator: locator::Args,
}
impl Cmd {
pub async fn run(&self, global_args: &global::Args) -> Result<(), Error> {
let print = Print::new(global_args.quiet);
let message_bytes = self.get_message_bytes()?;
let key_or_name = &self.sign_with_key;
let secret = self.locator.get_secret_key(key_or_name)?;
let signer = secret.signer(self.hd_path, print.clone()).await?;
let public_key = signer.get_public_key()?;
let signature_base64 = sep_53_sign(&message_bytes, signer)?;
print.infoln(format!("Signer: {public_key}"));
let message_display = if self.base64 {
BASE64.encode(&message_bytes)
} else {
String::from_utf8_lossy(&message_bytes).to_string()
};
print.infoln(format!("Message: {message_display}"));
println!("{signature_base64}");
Ok(())
}
fn get_message_bytes(&self) -> Result<Vec<u8>, Error> {
let message_str = if let Some(msg) = &self.message {
msg.clone()
} else {
let mut buffer = String::new();
io::stdin().read_to_string(&mut buffer)?;
if buffer.ends_with('\n') {
buffer.pop();
if buffer.ends_with('\r') {
buffer.pop();
}
}
buffer
};
if self.base64 {
Ok(BASE64.decode(&message_str)?)
} else {
Ok(message_str.into_bytes())
}
}
}
fn sep_53_sign(message_bytes: &[u8], signer: Signer) -> Result<String, Error> {
let mut payload = Vec::with_capacity(SEP53_PREFIX.len() + message_bytes.len());
payload.extend_from_slice(SEP53_PREFIX.as_bytes());
payload.extend_from_slice(message_bytes);
let hash: [u8; 32] = Sha256::digest(&payload).into();
let signature = signer.sign_payload(hash)?;
Ok(BASE64.encode(signature.to_bytes()))
}
#[cfg(test)]
mod tests {
use std::str::FromStr;
use super::*;
use crate::{config::secret::Secret, utils::into_signing_key};
const TEST_SECRET_KEY: &str = "SAKICEVQLYWGSOJS4WW7HZJWAHZVEEBS527LHK5V4MLJALYKICQCJXMW";
fn setup_locator() -> locator::Args {
let temp_dir = tempfile::tempdir().unwrap();
locator::Args {
config_dir: Some(temp_dir.path().to_path_buf()),
}
}
fn build_signer_for_test_key() -> Signer {
let secret = Secret::from_str(TEST_SECRET_KEY).unwrap();
let private_key = secret.private_key(None).unwrap();
let signing_key = into_signing_key(&private_key);
Signer {
kind: signer::SignerKind::Local(signer::LocalKey { key: signing_key }),
print: Print::new(true),
}
}
#[test]
fn test_sign_simple() {
let message = "Hello, World!".to_string();
let expected_signature = "fO5dbYhXUhBMhe6kId/cuVq/AfEnHRHEvsP8vXh03M1uLpi5e46yO2Q8rEBzu3feXQewcQE5GArp88u6ePK6BA==";
let locator = setup_locator();
let cmd = super::Cmd {
message: Some(message),
base64: false,
sign_with_key: TEST_SECRET_KEY.to_string(),
hd_path: None,
locator: locator.clone(),
};
let signer = build_signer_for_test_key();
let message_bytes = cmd.get_message_bytes().unwrap();
let signature_base64 = sep_53_sign(&message_bytes, signer).unwrap();
assert_eq!(signature_base64, expected_signature);
}
#[test]
fn test_sign_japanese() {
let message = "こんにちは、世界!".to_string();
let expected_signature = "CDU265Xs8y3OWbB/56H9jPgUss5G9A0qFuTqH2zs2YDgTm+++dIfmAEceFqB7bhfN3am59lCtDXrCtwH2k1GBA==";
let locator = setup_locator();
let cmd = super::Cmd {
message: Some(message),
base64: false,
sign_with_key: TEST_SECRET_KEY.to_string(),
hd_path: None,
locator: locator.clone(),
};
let signer = build_signer_for_test_key();
let message_bytes = cmd.get_message_bytes().unwrap();
let signature_base64 = sep_53_sign(&message_bytes, signer).unwrap();
assert_eq!(signature_base64, expected_signature);
}
#[test]
fn test_sign_base64() {
let message = "2zZDP1sa1BVBfLP7TeeMk3sUbaxAkUhBhDiNdrksaFo=".to_string();
let expected_signature = "VA1+7hefNwv2NKScH6n+Sljj15kLAge+M2wE7fzFOf+L0MMbssA1mwfJZRyyrhBORQRle10X1Dxpx+UOI4EbDQ==";
let locator = setup_locator();
let cmd = super::Cmd {
message: Some(message),
base64: true,
sign_with_key: TEST_SECRET_KEY.to_string(),
hd_path: None,
locator: locator.clone(),
};
let signer = build_signer_for_test_key();
let message_bytes = cmd.get_message_bytes().unwrap();
let signature_base64 = sep_53_sign(&message_bytes, signer).unwrap();
assert_eq!(signature_base64, expected_signature);
}
}