use keychain::BlindingFactor;
use util::secp::key::SecretKey;
use util::secp::pedersen::Commitment;
use util::{secp, secp_static, static_secp_instance};
#[derive(Debug, Clone, PartialEq, Eq, thiserror::Error, Serialize, Deserialize)]
pub enum Error {
#[error("Keychain error {0}")]
Keychain(keychain::Error),
#[error("Secp error {0}")]
Secp(secp::Error),
#[error("Kernel sum mismatch")]
KernelSumMismatch,
#[error("Invalid value")]
InvalidValue,
}
impl From<secp::Error> for Error {
fn from(e: secp::Error) -> Error {
Error::Secp(e)
}
}
impl From<keychain::Error> for Error {
fn from(e: keychain::Error) -> Error {
Error::Keychain(e)
}
}
pub trait Committed {
fn sum_kernel_excesses(
&self,
offset: &BlindingFactor,
) -> Result<(Commitment, Commitment), Error> {
let kernel_commits = self.kernels_committed();
let kernel_sum = sum_commits(kernel_commits, vec![])?;
let kernel_sum_plus_offset = {
let secp = static_secp_instance();
let secp = secp.lock();
let mut commits = vec![kernel_sum];
if *offset != BlindingFactor::zero() {
let key = offset.secret_key(&secp)?;
let offset_commit = secp.commit(0, key)?;
commits.push(offset_commit);
}
secp.commit_sum(commits, vec![])?
};
Ok((kernel_sum, kernel_sum_plus_offset))
}
fn sum_commitments(&self, overage: i64) -> Result<Commitment, Error> {
let mut input_commits = self.inputs_committed();
let mut output_commits = self.outputs_committed();
if overage != 0 {
let over_commit = {
let secp = static_secp_instance();
let secp = secp.lock();
let overage_abs = overage.checked_abs().ok_or_else(|| Error::InvalidValue)? as u64;
secp.commit_value(overage_abs).unwrap()
};
if overage < 0 {
input_commits.push(over_commit);
} else {
output_commits.push(over_commit);
}
}
sum_commits(output_commits, input_commits)
}
fn inputs_committed(&self) -> Vec<Commitment>;
fn outputs_committed(&self) -> Vec<Commitment>;
fn kernels_committed(&self) -> Vec<Commitment>;
fn verify_kernel_sums(
&self,
overage: i64,
kernel_offset: BlindingFactor,
) -> Result<(Commitment, Commitment), Error> {
let utxo_sum = self.sum_commitments(overage)?;
let (kernel_sum, kernel_sum_plus_offset) = self.sum_kernel_excesses(&kernel_offset)?;
if utxo_sum != kernel_sum_plus_offset {
return Err(Error::KernelSumMismatch);
}
Ok((utxo_sum, kernel_sum))
}
}
pub fn sum_commits(
mut positive: Vec<Commitment>,
mut negative: Vec<Commitment>,
) -> Result<Commitment, Error> {
let zero_commit = secp_static::commit_to_zero_value();
positive.retain(|x| *x != zero_commit);
negative.retain(|x| *x != zero_commit);
let secp = static_secp_instance();
let secp = secp.lock();
Ok(secp.commit_sum(positive, negative)?)
}
pub fn sum_kernel_offsets(
positive: Vec<BlindingFactor>,
negative: Vec<BlindingFactor>,
) -> Result<BlindingFactor, Error> {
let secp = static_secp_instance();
let secp = secp.lock();
let positive = to_secrets(positive, &secp);
let negative = to_secrets(negative, &secp);
if positive.is_empty() {
Ok(BlindingFactor::zero())
} else {
let sum = secp.blind_sum(positive, negative)?;
Ok(BlindingFactor::from_secret_key(sum))
}
}
fn to_secrets(bf: Vec<BlindingFactor>, secp: &secp::Secp256k1) -> Vec<SecretKey> {
bf.into_iter()
.filter(|x| *x != BlindingFactor::zero())
.filter_map(|x| x.secret_key(&secp).ok())
.collect::<Vec<_>>()
}