// Copyright (c) The Diem Core Contributors
// SPDX-License-Identifier: Apache-2.0

// Copyright 2021 Conflux Foundation. All rights reserved.
// Conflux is free software and distributed under GNU General Public License.
// See http://www.gnu.org/licenses/

use crate::{account_address::AccountAddress, on_chain_config::ValidatorSet};
use diem_crypto::{
    bls::deserialize_bls_public_key_unchecked, hash::CryptoHash, Signature,
    VRFPublicKey, VerifyingKey,
};
use serde::{Deserialize, Serialize};
use std::{collections::BTreeMap, fmt};
use thiserror::Error;

use crate::{
    on_chain_config::OnChainConfig,
    validator_config::{
        ConsensusPublicKey, ConsensusSignature, ConsensusVRFProof,
        ConsensusVRFPublicKey,
    },
};
#[cfg(any(test, feature = "fuzzing"))]
use anyhow::{ensure, Result};
#[cfg(any(test, feature = "fuzzing"))]
use proptest_derive::Arbitrary;

/// Errors possible during signature verification.
#[derive(Debug, Error, PartialEq)]
pub enum VerifyError {
    #[error("Author is unknown")]
    /// The author for this signature is unknown by this validator.
    UnknownAuthor,
    #[error(
        "The voting power ({}) is less than quorum voting power ({})",
        voting_power,
        quorum_voting_power
    )]
    TooLittleVotingPower {
        voting_power: u64,
        quorum_voting_power: u64,
    },
    #[error(
        "The number of signatures ({}) is greater than total number of authors ({})",
        num_of_signatures,
        num_of_authors
    )]
    TooManySignatures {
        num_of_signatures: usize,
        num_of_authors: usize,
    },
    #[error("Signature is invalid")]
    /// The signature does not match the hash.
    InvalidSignature,
    #[error("Invalid VRF proof")]
    InvalidVrfProof,
}

/// Helper struct to manage validator information for validation
#[derive(Clone, Debug, Deserialize, Eq, PartialEq, Serialize)]
#[cfg_attr(any(test, feature = "fuzzing"), derive(Arbitrary))]
pub struct ValidatorConsensusInfo {
    // We always vote for our local EpochState, and EpochState is included in
    // the voted hash. Thus, if a malicious pubkey is provided here, its
    // LedgerInfo won't get a QC.
    #[serde(deserialize_with = "deserialize_bls_public_key_unchecked")]
    public_key: ConsensusPublicKey,
    /// None if we do not need VRF.
    vrf_public_key: Option<ConsensusVRFPublicKey>,
    voting_power: u64,
}

impl ValidatorConsensusInfo {
    pub fn new(
        public_key: ConsensusPublicKey,
        vrf_public_key: Option<ConsensusVRFPublicKey>, voting_power: u64,
    ) -> Self {
        ValidatorConsensusInfo {
            public_key,
            vrf_public_key,
            voting_power,
        }
    }

    pub fn voting_power(&self) -> u64 { self.voting_power }

    pub fn public_key(&self) -> &ConsensusPublicKey { &self.public_key }

    pub fn vrf_public_key(&self) -> &Option<ConsensusVRFPublicKey> {
        &self.vrf_public_key
    }
}

/// Supports validation of signatures for known authors with individual voting
/// powers. This struct can be used for all signature verification operations
/// including block and network signature verification, respectively.
#[derive(Clone, Debug, Deserialize, Eq, PartialEq, Serialize)]
#[cfg_attr(any(test, feature = "fuzzing"), derive(Arbitrary))]
pub struct ValidatorVerifier {
    /// An ordered map of each validator's on-chain account address to its
    /// pubkeys and voting power.
    address_to_validator_info: BTreeMap<AccountAddress, ValidatorConsensusInfo>,
    /// The minimum voting power required to achieve a quorum
    quorum_voting_power: u64,
    /// Total voting power of all validators (cached from
    /// address_to_validator_info)
    total_voting_power: u64,
}

impl ValidatorVerifier {
    /// Initialize with a map of account address to validator info and set
    /// quorum size to default (`2f + 1`) or zero if
    /// `address_to_validator_info` is empty.
    pub fn new(
        address_to_validator_info: BTreeMap<
            AccountAddress,
            ValidatorConsensusInfo,
        >,
    ) -> Self {
        let total_voting_power = sum_voting_power(&address_to_validator_info);
        let quorum_voting_power = if address_to_validator_info.is_empty() {
            0
        } else {
            total_voting_power * 2 / 3 + 1
        };
        ValidatorVerifier {
            address_to_validator_info,
            quorum_voting_power,
            total_voting_power,
        }
    }

    /// Initializes a validator verifier with a specified quorum voting power.
    #[cfg(any(test, feature = "fuzzing"))]
    pub fn new_with_quorum_voting_power(
        address_to_validator_info: BTreeMap<
            AccountAddress,
            ValidatorConsensusInfo,
        >,
        quorum_voting_power: u64,
    ) -> Result<Self> {
        let total_voting_power = sum_voting_power(&address_to_validator_info);
        ensure!(
            quorum_voting_power <= total_voting_power,
            "Quorum voting power is greater than the sum of all voting power of authors: {}, \
             quorum_size: {}.",
            quorum_voting_power,
            total_voting_power
        );
        Ok(ValidatorVerifier {
            address_to_validator_info,
            quorum_voting_power,
            total_voting_power,
        })
    }

    /// Initializes a validator verifier with a specified quorum voting power
    /// and total power.
    #[cfg(any(test, feature = "fuzzing"))]
    // This method should only used by tests and fuzzers to produce an arbitrary
    // ValidatorVerifier.
    pub fn new_for_testing(
        address_to_validator_info: BTreeMap<
            AccountAddress,
            ValidatorConsensusInfo,
        >,
        quorum_voting_power: u64, total_voting_power: u64,
    ) -> Self {
        ValidatorVerifier {
            address_to_validator_info,
            quorum_voting_power,
            total_voting_power,
        }
    }

    /// Helper method to initialize with a single author and public key with
    /// quorum voting power 1.
    pub fn new_single(
        author: AccountAddress, public_key: ConsensusPublicKey,
        vrf_public_key: Option<ConsensusVRFPublicKey>,
    ) -> Self {
        let mut author_to_validator_info = BTreeMap::new();
        author_to_validator_info.insert(
            author,
            ValidatorConsensusInfo::new(public_key, vrf_public_key, 1),
        );
        Self::new(author_to_validator_info)
    }

    /// Verify the correctness of a signature of a message by a known author.
    pub fn verify<T: Serialize + CryptoHash>(
        &self, author: AccountAddress, message: &T,
        signature: &ConsensusSignature,
    ) -> std::result::Result<(), VerifyError> {
        match self.get_public_key(&author) {
            Some(public_key) => {
                if public_key
                    .verify_struct_signature(message, signature)
                    .is_err()
                {
                    Err(VerifyError::InvalidSignature)
                } else {
                    Ok(())
                }
            }
            None => Err(VerifyError::UnknownAuthor),
        }
    }

    /// Verify the correctness of a signature of a message by a known author.
    pub fn verify_vrf(
        &self, author: AccountAddress, seed: &[u8], proof: &ConsensusVRFProof,
    ) -> std::result::Result<(), VerifyError> {
        match self.get_vrf_public_key(&author) {
            Some(Some(public_key)) => {
                if public_key.verify_proof(seed, proof).is_err() {
                    Err(VerifyError::InvalidVrfProof)
                } else {
                    Ok(())
                }
            }
            _ => Err(VerifyError::UnknownAuthor),
        }
    }

    /// This function will successfully return when at least quorum_size
    /// signatures of known authors are successfully verified. Also, an
    /// aggregated signature is considered invalid if any of the
    /// attached signatures is invalid or it does not correspond to a known
    /// author. The latter is to prevent malicious users from adding
    /// arbitrary content to the signature payload that would go unnoticed.
    pub fn verify_aggregated_struct_signature<T: CryptoHash + Serialize>(
        &self, message: &T,
        aggregated_signature: &BTreeMap<AccountAddress, ConsensusSignature>,
    ) -> std::result::Result<(), VerifyError> {
        self.check_num_of_signatures(aggregated_signature)?;
        self.check_voting_power(aggregated_signature.keys())?;
        for (author, signature) in aggregated_signature {
            self.verify(*author, message, &signature.clone())?;
        }
        Ok(())
    }

    /// This function will try batch signature verification and falls back to
    /// normal iterated verification if batching fails.
    pub fn batch_verify_aggregated_signatures<T: CryptoHash + Serialize>(
        &self, message: &T,
        aggregated_signature: &BTreeMap<AccountAddress, ConsensusSignature>,
    ) -> std::result::Result<(), VerifyError> {
        self.check_num_of_signatures(aggregated_signature)?;
        self.check_voting_power(aggregated_signature.keys())?;
        let keys_and_signatures: Vec<(ConsensusPublicKey, ConsensusSignature)> =
            aggregated_signature
                .iter()
                .flat_map(|(address, signature)| {
                    let sig = signature.clone();
                    self.get_public_key(&address).map(|pub_key| (pub_key, sig))
                })
                .collect();
        // Fallback is required to identify the source of the problem if
        // batching fails.
        if ConsensusSignature::batch_verify(message, keys_and_signatures)
            .is_err()
        {
            self.verify_aggregated_struct_signature(
                message,
                aggregated_signature,
            )?
        }
        Ok(())
    }

    /// Ensure there are not more than the maximum expected signatures (all
    /// possible signatures).
    fn check_num_of_signatures(
        &self,
        aggregated_signature: &BTreeMap<AccountAddress, ConsensusSignature>,
    ) -> std::result::Result<(), VerifyError> {
        let num_of_signatures = aggregated_signature.len();
        if num_of_signatures > self.len() {
            return Err(VerifyError::TooManySignatures {
                num_of_signatures,
                num_of_authors: self.len(),
            });
        }
        Ok(())
    }

    /// Ensure there is at least quorum_voting_power in the provided signatures
    /// and there are only known authors. According to the threshold
    /// verification policy, invalid public keys are not allowed.
    pub fn check_voting_power<'a>(
        &self, authors: impl Iterator<Item = &'a AccountAddress>,
    ) -> std::result::Result<(), VerifyError> {
        // Add voting power for valid accounts, exiting early for unknown
        // authors
        let mut aggregated_voting_power = 0;
        for account_address in authors {
            match self.get_voting_power(&account_address) {
                Some(voting_power) => aggregated_voting_power += voting_power,
                None => return Err(VerifyError::UnknownAuthor),
            }
        }

        if aggregated_voting_power < self.quorum_voting_power {
            return Err(VerifyError::TooLittleVotingPower {
                voting_power: aggregated_voting_power,
                quorum_voting_power: self.quorum_voting_power,
            });
        }
        Ok(())
    }

    /// Returns the public key for this address.
    pub fn get_public_key(
        &self, author: &AccountAddress,
    ) -> Option<ConsensusPublicKey> {
        self.address_to_validator_info
            .get(&author)
            .map(|validator_info| validator_info.public_key.clone())
    }

    /// Returns the VRF public key for this address.
    pub fn get_vrf_public_key(
        &self, author: &AccountAddress,
    ) -> Option<Option<ConsensusVRFPublicKey>> {
        self.address_to_validator_info
            .get(&author)
            .map(|validator_info| validator_info.vrf_public_key.clone())
    }

    /// Returns the voting power for this address.
    pub fn get_voting_power(&self, author: &AccountAddress) -> Option<u64> {
        self.address_to_validator_info
            .get(&author)
            .map(|validator_info| validator_info.voting_power)
    }

    /// Returns an ordered list of account addresses as an `Iterator`.
    pub fn get_ordered_account_addresses_iter(
        &self,
    ) -> impl Iterator<Item = AccountAddress> + '_ {
        // Since `address_to_validator_info` is a `BTreeMap`, the `.keys()`
        // iterator is guaranteed to be sorted.
        self.address_to_validator_info.keys().copied()
    }

    /// Returns the number of authors to be validated.
    pub fn len(&self) -> usize { self.address_to_validator_info.len() }

    /// Is there at least one author?
    pub fn is_empty(&self) -> bool { self.len() == 0 }

    /// Returns quorum voting power.
    pub fn quorum_voting_power(&self) -> u64 { self.quorum_voting_power }

    // Returns total voting power.
    pub fn total_voting_power(&self) -> u64 { self.total_voting_power }

    pub fn address_to_validator_info(
        &self,
    ) -> &BTreeMap<AccountAddress, ValidatorConsensusInfo> {
        &self.address_to_validator_info
    }

    /// Return the extra vote compared to `quorum_voting_power`.
    pub fn extra_vote_count<'a>(
        &self, signers: impl Iterator<Item = &'a AccountAddress>,
    ) -> anyhow::Result<u64> {
        let mut total_count = 0;
        for signer in signers {
            total_count += self
                .get_voting_power(signer)
                .ok_or(anyhow::anyhow!("Signer is not a validator"))?;
        }
        total_count.checked_sub(self.quorum_voting_power).ok_or(
            anyhow::anyhow!("counted voting power overflows total power"),
        )
    }
}

impl OnChainConfig for ValidatorVerifier {
    const IDENTIFIER: &'static str = "DiemSystem";
}

/// Returns sum of voting power from Map of validator account addresses,
/// validator consensus info
fn sum_voting_power(
    address_to_validator_info: &BTreeMap<
        AccountAddress,
        ValidatorConsensusInfo,
    >,
) -> u64 {
    address_to_validator_info.values().fold(0, |sum, x| {
        sum.checked_add(x.voting_power)
            .expect("sum of all voting power is greater than u64::max")
    })
}

impl fmt::Display for ValidatorVerifier {
    fn fmt(&self, f: &mut fmt::Formatter) -> std::fmt::Result {
        write!(f, "ValidatorSet: [")?;
        for (addr, info) in &self.address_to_validator_info {
            write!(
                f,
                "{}: {}, ",
                addr.short_str_lossless(),
                info.voting_power
            )?;
        }
        write!(f, "]")
    }
}

impl From<&ValidatorSet> for ValidatorVerifier {
    fn from(validator_set: &ValidatorSet) -> Self {
        ValidatorVerifier::new(validator_set.payload().iter().fold(
            BTreeMap::new(),
            |mut map, validator| {
                map.insert(
                    *validator.account_address(),
                    ValidatorConsensusInfo::new(
                        validator.consensus_public_key().clone(),
                        validator.vrf_public_key().clone(),
                        validator.consensus_voting_power(),
                    ),
                );
                map
            },
        ))
    }
}

#[cfg(any(test, feature = "fuzzing"))]
impl From<&ValidatorVerifier> for ValidatorSet {
    fn from(verifier: &ValidatorVerifier) -> Self {
        ValidatorSet::new(
            verifier
                .get_ordered_account_addresses_iter()
                .map(|addr| {
                    crate::validator_info::ValidatorInfo::new_with_test_network_keys(
                        addr,
                        verifier.get_public_key(&addr).unwrap(),
                        verifier.get_vrf_public_key(&addr).unwrap(),
                        verifier.get_voting_power(&addr).unwrap(),
                    )
                })
                .collect(),
        )
    }
}

/// Helper function to get random validator signers and a corresponding
/// validator verifier for testing.  If custom_voting_power_quorum is not None,
/// set a custom voting power quorum amount. With pseudo_random_account_address
/// enabled, logs show 0 -> [0000], 1 -> [1000]
#[cfg(any(test, feature = "fuzzing"))]
pub fn random_validator_verifier(
    count: usize, custom_voting_power_quorum: Option<u64>,
    pseudo_random_account_address: bool,
) -> (
    Vec<crate::validator_signer::ValidatorSigner>,
    ValidatorVerifier,
) {
    let mut signers = Vec::new();
    let mut account_address_to_validator_info = BTreeMap::new();
    for i in 0..count {
        let random_signer = if pseudo_random_account_address {
            crate::validator_signer::ValidatorSigner::from_int(i as u8)
        } else {
            crate::validator_signer::ValidatorSigner::random([i as u8; 32])
        };
        account_address_to_validator_info.insert(
            random_signer.author(),
            crate::validator_verifier::ValidatorConsensusInfo::new(
                random_signer.public_key(),
                random_signer.vrf_public_key(),
                1,
            ),
        );
        signers.push(random_signer);
    }
    (
        signers,
        match custom_voting_power_quorum {
            Some(custom_voting_power_quorum) => {
                ValidatorVerifier::new_with_quorum_voting_power(
                    account_address_to_validator_info,
                    custom_voting_power_quorum,
                )
                .expect("Unable to create testing validator verifier")
            }
            None => ValidatorVerifier::new(account_address_to_validator_info),
        },
    )
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::validator_signer::ValidatorSigner;
    use diem_crypto::test_utils::{TestDiemCrypto, TEST_SEED};
    use std::collections::BTreeMap;

    #[test]
    fn test_check_voting_power() {
        let (validator_signers, validator_verifier) =
            random_validator_verifier(2, None, false);
        let mut author_to_signature_map = BTreeMap::new();

        assert_eq!(
            validator_verifier
                .check_voting_power(author_to_signature_map.keys())
                .unwrap_err(),
            VerifyError::TooLittleVotingPower {
                voting_power: 0,
                quorum_voting_power: 2,
            }
        );

        let dummy_struct = TestDiemCrypto("Hello, World".to_string());
        for validator in validator_signers.iter() {
            author_to_signature_map
                .insert(validator.author(), validator.sign(&dummy_struct));
        }

        assert_eq!(
            validator_verifier
                .check_voting_power(author_to_signature_map.keys()),
            Ok(())
        );
    }

    #[test]
    fn test_validator() {
        let validator_signer = ValidatorSigner::random(TEST_SEED);
        let dummy_struct = TestDiemCrypto("Hello, World".to_string());
        let signature = validator_signer.sign(&dummy_struct);
        let validator = ValidatorVerifier::new_single(
            validator_signer.author(),
            validator_signer.public_key(),
            validator_signer.vrf_public_key(),
        );
        assert_eq!(
            validator.verify(
                validator_signer.author(),
                &dummy_struct,
                &signature
            ),
            Ok(())
        );
        let unknown_validator_signer = ValidatorSigner::random([1; 32]);
        let unknown_signature = unknown_validator_signer.sign(&dummy_struct);
        assert_eq!(
            validator.verify(
                unknown_validator_signer.author(),
                &dummy_struct,
                &unknown_signature
            ),
            Err(VerifyError::UnknownAuthor)
        );
        assert_eq!(
            validator.verify(
                validator_signer.author(),
                &dummy_struct,
                &unknown_signature
            ),
            Err(VerifyError::InvalidSignature)
        );
    }

    #[test]
    fn test_equal_vote_quorum_validators() {
        const NUM_SIGNERS: u8 = 7;
        // Generate NUM_SIGNERS random signers.
        let validator_signers: Vec<ValidatorSigner> = (0..NUM_SIGNERS)
            .map(|i| ValidatorSigner::random([i; 32]))
            .collect();
        let dummy_struct = TestDiemCrypto("Hello, World".to_string());

        // Create a map from authors to public keys with equal voting power.
        let mut author_to_public_key_map = BTreeMap::new();
        for validator in validator_signers.iter() {
            author_to_public_key_map.insert(
                validator.author(),
                ValidatorConsensusInfo::new(
                    validator.public_key(),
                    validator.vrf_public_key(),
                    1,
                ),
            );
        }

        // Create a map from author to signatures.
        let mut author_to_signature_map = BTreeMap::new();
        for validator in validator_signers.iter() {
            author_to_signature_map
                .insert(validator.author(), validator.sign(&dummy_struct));
        }

        // Let's assume our verifier needs to satisfy at least 5 signatures from
        // the original NUM_SIGNERS.
        let validator_verifier =
            ValidatorVerifier::new_with_quorum_voting_power(
                author_to_public_key_map,
                5,
            )
            .expect("Incorrect quorum size.");

        // Check against signatures == N; this will pass.
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Ok(())
        );

        // Add an extra unknown signer, signatures > N; this will fail.
        let unknown_validator_signer =
            ValidatorSigner::random([NUM_SIGNERS + 1; 32]);
        let unknown_signature = unknown_validator_signer.sign(&dummy_struct);
        author_to_signature_map.insert(
            unknown_validator_signer.author(),
            unknown_signature.clone(),
        );
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Err(VerifyError::TooManySignatures {
                num_of_signatures: 8,
                num_of_authors: 7
            })
        );

        // Add 5 valid signers only (quorum threshold is met); this will pass.
        author_to_signature_map.clear();
        for validator in validator_signers.iter().take(5) {
            author_to_signature_map
                .insert(validator.author(), validator.sign(&dummy_struct));
        }
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Ok(())
        );

        // Add an unknown signer, but quorum is satisfied and signatures <= N;
        // this will fail as we don't tolerate invalid signatures.
        author_to_signature_map.insert(
            unknown_validator_signer.author(),
            unknown_signature.clone(),
        );
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Err(VerifyError::UnknownAuthor)
        );

        // Add 4 valid signers only (quorum threshold is NOT met); this will
        // fail.
        author_to_signature_map.clear();
        for validator in validator_signers.iter().take(4) {
            author_to_signature_map
                .insert(validator.author(), validator.sign(&dummy_struct));
        }
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Err(VerifyError::TooLittleVotingPower {
                voting_power: 4,
                quorum_voting_power: 5
            })
        );

        // Add an unknown signer, we have 5 signers, but one of them is invalid;
        // this will fail.
        author_to_signature_map
            .insert(unknown_validator_signer.author(), unknown_signature);
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Err(VerifyError::UnknownAuthor)
        );
    }

    #[test]
    #[should_panic]
    fn test_very_unequal_vote_quorum_validators() {
        const NUM_SIGNERS: u8 = 4;
        // Generate NUM_SIGNERS random signers.
        let validator_signers: Vec<ValidatorSigner> = (0..NUM_SIGNERS)
            .map(|i| ValidatorSigner::random([i; 32]))
            .collect();
        let dummy_struct = TestDiemCrypto("Hello, World".to_string());

        // Create a map from authors to public keys with increasing weights (0,
        // 1, 2, 3) and a map of author to signature.
        let mut author_to_public_key_map = BTreeMap::new();
        let mut author_to_signature_map = BTreeMap::new();
        for (i, validator_signer) in validator_signers.iter().enumerate() {
            let mut voting_power: u64 = i as u64;
            if i == 3 {
                voting_power = u64::max_value()
            }
            author_to_public_key_map.insert(
                validator_signer.author(),
                ValidatorConsensusInfo::new(
                    validator_signer.public_key(),
                    validator_signer.vrf_public_key(),
                    voting_power,
                ),
            );
            author_to_signature_map.insert(
                validator_signer.author(),
                validator_signer.sign(&dummy_struct),
            );
        }

        // expect this to panic
        let _validator_verifier =
            ValidatorVerifier::new(author_to_public_key_map);
    }

    #[test]
    fn test_unequal_vote_quorum_validators() {
        const NUM_SIGNERS: u8 = 4;
        // Generate NUM_SIGNERS random signers.
        let validator_signers: Vec<ValidatorSigner> = (0..NUM_SIGNERS)
            .map(|i| ValidatorSigner::random([i; 32]))
            .collect();
        let dummy_struct = TestDiemCrypto("Hello, World".to_string());

        // Create a map from authors to public keys with increasing weights (0,
        // 1, 2, 3) and a map of author to signature.
        let mut author_to_public_key_map = BTreeMap::new();
        let mut author_to_signature_map = BTreeMap::new();
        for (i, validator_signer) in validator_signers.iter().enumerate() {
            author_to_public_key_map.insert(
                validator_signer.author(),
                ValidatorConsensusInfo::new(
                    validator_signer.public_key(),
                    validator_signer.vrf_public_key(),
                    i as u64,
                ),
            );
            author_to_signature_map.insert(
                validator_signer.author(),
                validator_signer.sign(&dummy_struct),
            );
        }

        // Let's assume our verifier needs to satisfy at least 5 quorum voting
        // power
        let validator_verifier =
            ValidatorVerifier::new_with_quorum_voting_power(
                author_to_public_key_map,
                5,
            )
            .expect("Incorrect quorum size.");

        // Check against all signatures (6 voting power); this will pass.
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Ok(())
        );

        // Add an extra unknown signer, signatures > N; this will fail.
        let unknown_validator_signer =
            ValidatorSigner::random([NUM_SIGNERS + 1; 32]);
        let unknown_signature = unknown_validator_signer.sign(&dummy_struct);
        author_to_signature_map.insert(
            unknown_validator_signer.author(),
            unknown_signature.clone(),
        );
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Err(VerifyError::TooManySignatures {
                num_of_signatures: 5,
                num_of_authors: 4
            })
        );

        // Add 5 voting power signers only (quorum threshold is met) with (2, 3)
        // ; this will pass.
        author_to_signature_map.clear();
        for validator in validator_signers.iter().skip(2) {
            author_to_signature_map
                .insert(validator.author(), validator.sign(&dummy_struct));
        }
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Ok(())
        );

        // Add an unknown signer, but quorum is satisfied and signatures <= N;
        // this will fail as we don't tolerate invalid signatures.
        author_to_signature_map.insert(
            unknown_validator_signer.author(),
            unknown_signature.clone(),
        );
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Err(VerifyError::UnknownAuthor)
        );

        // Add first 3 valid signers only (quorum threshold is NOT met); this
        // will fail.
        author_to_signature_map.clear();
        for validator in validator_signers.iter().take(3) {
            author_to_signature_map
                .insert(validator.author(), validator.sign(&dummy_struct));
        }
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Err(VerifyError::TooLittleVotingPower {
                voting_power: 3,
                quorum_voting_power: 5
            })
        );

        // Add an unknown signer, we have 5 signers, but one of them is invalid;
        // this will fail.
        author_to_signature_map
            .insert(unknown_validator_signer.author(), unknown_signature);
        assert_eq!(
            validator_verifier.batch_verify_aggregated_signatures(
                &dummy_struct,
                &author_to_signature_map
            ),
            Err(VerifyError::UnknownAuthor)
        );
    }
}