use std::fmt::Debug;
use bitcoin_hashes::{Hash, sha256};
use fedimint_core::encoding::{
Decodable, DecodeError, Encodable, decode_field_from_finite_reader,
decode_legacy_system_time_from_finite_reader, encode_legacy_system_time, with_decoding_context,
};
use fedimint_core::module::registry::ModuleDecoderRegistry;
use fedimint_core::secp256k1;
use secp256k1::{Keypair, Message, PublicKey, SECP256K1, Secp256k1, Signing, Verification};
use serde::{Deserialize, Serialize};
#[derive(Debug, Serialize, Deserialize)]
pub struct BackupRequest {
pub id: PublicKey,
#[serde(with = "fedimint_core::hex::serde")]
pub payload: Vec<u8>,
pub timestamp: std::time::SystemTime,
}
impl Encodable for BackupRequest {
fn consensus_encode<W: std::io::Write>(&self, writer: &mut W) -> Result<(), std::io::Error> {
self.id.consensus_encode(writer)?;
self.payload.consensus_encode(writer)?;
encode_legacy_system_time(&self.timestamp, writer)
}
}
impl Decodable for BackupRequest {
fn consensus_decode_partial_from_finite_reader<D: std::io::Read>(
decoder: &mut D,
modules: &ModuleDecoderRegistry,
) -> Result<Self, DecodeError> {
Ok(Self {
id: decode_field_from_finite_reader(
decoder,
modules,
"Decoding named block field: BackupRequest{ ... id ... }",
)?,
payload: decode_field_from_finite_reader(
decoder,
modules,
"Decoding named block field: BackupRequest{ ... payload ... }",
)?,
timestamp: with_decoding_context(
decode_legacy_system_time_from_finite_reader(decoder, modules),
"Decoding named block field: BackupRequest{ ... timestamp ... }",
)?,
})
}
}
impl BackupRequest {
fn hash(&self) -> sha256::Hash {
self.consensus_hash()
}
pub fn sign(self, keypair: &Keypair) -> anyhow::Result<SignedBackupRequest> {
let signature =
SECP256K1.sign_schnorr(&Message::from_digest(*self.hash().as_ref()), keypair);
Ok(SignedBackupRequest {
request: self,
signature,
})
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct SignedBackupRequest {
#[serde(flatten)]
request: BackupRequest,
#[serde(with = "::fedimint_core::encoding::as_hex")]
pub signature: fedimint_core::secp256k1::schnorr::Signature,
}
impl SignedBackupRequest {
pub fn verify_valid<C>(&self, ctx: &Secp256k1<C>) -> Result<&BackupRequest, secp256k1::Error>
where
C: Signing + Verification,
{
ctx.verify_schnorr(
&self.signature,
&Message::from_digest_slice(&self.request.hash().to_byte_array()).expect("Can't fail"),
&self.request.id.x_only_public_key().0,
)?;
Ok(&self.request)
}
}