#[allow(unused)]
use crate::{
Blind, Commitment, CommitmentKey,
errors::SpartanError,
math::Math,
polys::{eq::EqPolynomial, multilinear::MultilinearPolynomial},
provider::{
pcs::ipa::{
InnerProductArgumentLinear, InnerProductInstance, InnerProductWitness, inner_product,
},
traits::{DlogGroup, DlogGroupExt},
},
start_span,
traits::{
Engine,
pcs::{CommitmentTrait, Len, PCSEngineTrait},
transcript::{TranscriptEngineTrait, TranscriptReprTrait},
},
};
use core::marker::PhantomData;
use ff::Field;
use num_integer::Integer;
use num_traits::ToPrimitive;
use rayon::prelude::*;
use serde::{Deserialize, Serialize};
use std::time::Instant;
use tracing::{info, info_span};
type AffineGroupElement<E> = <<E as Engine>::GE as DlogGroup>::AffineGroupElement;
#[derive(Clone, Debug, Serialize, Deserialize)]
#[serde(bound = "")]
pub struct HyraxCommitmentKey<E: Engine>
where
E::GE: DlogGroup,
{
num_rows: usize,
num_cols: usize,
ck: Vec<AffineGroupElement<E>>,
h: AffineGroupElement<E>,
ck_s: AffineGroupElement<E>,
}
#[derive(Clone, Debug, Serialize, Deserialize)]
#[serde(bound = "")]
pub struct HyraxVerifierKey<E: Engine>
where
E::GE: DlogGroup,
{
num_rows: usize,
num_cols: usize,
ck: Vec<AffineGroupElement<E>>,
h: AffineGroupElement<E>,
ck_s: AffineGroupElement<E>,
}
impl<E: Engine> Len for HyraxCommitmentKey<E>
where
E::GE: DlogGroup,
{
fn length(&self) -> usize {
self.num_rows * self.num_cols
}
}
#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
#[serde(bound = "")]
pub struct HyraxCommitment<E: Engine> {
comm: Vec<E::GE>,
}
#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
#[serde(bound = "")]
pub struct HyraxBlind<E: Engine> {
blind: Vec<E::Scalar>,
}
#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct HyraxPCS<E: Engine> {
_p: PhantomData<E>,
}
#[derive(Clone, Debug, Serialize, Deserialize)]
#[serde(bound = "")]
pub struct HyraxEvaluationArgument<E: Engine>
where
E::GE: DlogGroupExt,
{
ipa: InnerProductArgumentLinear<E>,
}
fn compute_factored_lens(n: usize) -> (usize, usize) {
let ell = n.log_2();
let ell1 = ell.div_ceil(2); let ell2 = ell / 2;
(1 << ell1, 1 << ell2)
}
impl<E: Engine> PCSEngineTrait<E> for HyraxPCS<E>
where
E::GE: DlogGroupExt,
{
type CommitmentKey = HyraxCommitmentKey<E>;
type VerifierKey = HyraxVerifierKey<E>;
type Commitment = HyraxCommitment<E>;
type Blind = HyraxBlind<E>;
type EvaluationArgument = HyraxEvaluationArgument<E>;
fn setup(label: &'static [u8], n: usize) -> (Self::CommitmentKey, Self::VerifierKey) {
let padded_n = n.next_power_of_two();
let (num_rows, num_cols) = compute_factored_lens(padded_n);
let gens = E::GE::from_label(label, num_cols + 2);
let ck = gens[..num_cols].to_vec();
let h = gens[num_cols];
let ck_s = gens[num_cols + 1];
let vk = Self::VerifierKey {
num_rows,
num_cols,
ck: ck.clone(),
h,
ck_s,
};
let ck = Self::CommitmentKey {
num_rows,
num_cols,
ck,
h,
ck_s,
};
(ck, vk)
}
fn blind(ck: &Self::CommitmentKey) -> Self::Blind {
HyraxBlind {
blind: (0..ck.num_rows)
.map(|_| E::Scalar::ZERO)
.collect::<Vec<E::Scalar>>(),
}
}
fn commit(
ck: &Self::CommitmentKey,
v: &[E::Scalar],
r: &Self::Blind,
) -> Result<Self::Commitment, SpartanError> {
let n = v.len();
if n > ck.num_rows * ck.num_cols {
return Err(SpartanError::InvalidVectorSize {
actual: n,
max: ck.num_rows * ck.num_cols,
});
}
let (num_rows, num_cols) = compute_factored_lens(n);
let comm: Result<Vec<_>, _> = (0..num_rows)
.collect::<Vec<usize>>()
.into_par_iter()
.map(|i| {
let msm_result = E::GE::vartime_multiscalar_mul(
&v[num_cols * i..num_cols * (i + 1)],
&ck.ck[..num_cols],
false,
)?;
Ok(msm_result + <E::GE as DlogGroup>::group(&ck.h) * r.blind[i])
})
.collect();
Ok(HyraxCommitment { comm: comm? })
}
fn commit_small<T: Integer + Into<u64> + Copy + Sync + ToPrimitive>(
ck: &Self::CommitmentKey,
v: &[T],
r: &Self::Blind,
) -> Result<Self::Commitment, SpartanError> {
let n = v.len();
if n > ck.num_rows * ck.num_cols {
return Err(SpartanError::InvalidVectorSize {
actual: n,
max: ck.num_rows * ck.num_cols,
});
}
let (num_rows, num_cols) = compute_factored_lens(n);
let comm: Result<Vec<_>, _> = (0..num_rows)
.into_par_iter()
.map(|i| {
let msm_result = E::GE::vartime_multiscalar_mul_small(
&v[num_cols * i..num_cols * (i + 1)],
&ck.ck[..num_cols],
false,
)?;
Ok(msm_result + <E::GE as DlogGroup>::group(&ck.h) * r.blind[i])
})
.collect();
Ok(HyraxCommitment { comm: comm? })
}
fn prove(
ck: &Self::CommitmentKey,
transcript: &mut E::TE,
comm: &Self::Commitment,
poly: &[E::Scalar],
blind: &Self::Blind,
point: &[E::Scalar],
) -> Result<(E::Scalar, Self::EvaluationArgument), SpartanError> {
let (_setup_span, setup_t) = start_span!("hyrax_prove_prep");
if poly.len() != (2usize).pow(point.len() as u32) {
return Err(SpartanError::InvalidInputLength);
}
transcript.absorb(b"poly_com", comm);
let (num_rows, num_cols) = compute_factored_lens(poly.len());
let (num_vars_rows, _) = (num_rows.log_2(), num_cols.log_2());
let (L, R) = rayon::join(
|| EqPolynomial::new(point[..num_vars_rows].to_vec()).evals(),
|| EqPolynomial::new(point[num_vars_rows..].to_vec()).evals(),
);
info!(elapsed_ms = %setup_t.elapsed().as_millis(), "hyrax_prove_prep");
let (_bind_span, bind_t) = start_span!("hyrax_prove_bind");
let LZ = MultilinearPolynomial::bind_with(poly, &L, R.len());
info!(elapsed_ms = %bind_t.elapsed().as_millis(), "hyrax_prove_bind");
let eval = inner_product(&LZ, &R);
let (_commit_span, commit_t) = start_span!("hyrax_prove_commit");
let comm_LZ = E::GE::vartime_multiscalar_mul(&LZ, &ck.ck[..LZ.len()], true)?;
let r_LZ = (0..LZ.len())
.into_par_iter()
.map(|i| LZ[i] * blind.blind[i])
.reduce(|| E::Scalar::ZERO, |acc, x| acc + x);
info!(elapsed_ms = %commit_t.elapsed().as_millis(), "hyrax_prove_commit");
let (_ipa_span, ipa_t) = start_span!("hyrax_prove_ipa");
let ipa_instance = InnerProductInstance::<E>::new(&comm_LZ, &R, &eval);
let ipa_witness = InnerProductWitness::<E>::new(&LZ, &r_LZ);
let ipa = InnerProductArgumentLinear::<E>::prove(
&ck.ck,
&ck.h,
&ck.ck_s,
&ipa_instance,
&ipa_witness,
transcript,
)?;
info!(elapsed_ms = %ipa_t.elapsed().as_millis(), "hyrax_prove_ipa");
Ok((eval, HyraxEvaluationArgument { ipa }))
}
fn verify(
vk: &Self::VerifierKey,
transcript: &mut E::TE,
comm: &Self::Commitment,
point: &[E::Scalar],
eval: &E::Scalar,
arg: &Self::EvaluationArgument,
) -> Result<(), SpartanError> {
let (_verify_span, verify_t) = start_span!("hyrax_pcs_verify");
transcript.absorb(b"poly_com", comm);
let (_lr_span, lr_t) = start_span!("hyrax_compute_lr");
let n = (2_usize).pow(point.len() as u32);
let (num_rows, num_cols) = compute_factored_lens(n);
let (num_vars_rows, _num_vars_cols) = (num_rows.log_2(), num_cols.log_2());
let L = EqPolynomial::new(point[..num_vars_rows].to_vec()).evals();
let R = EqPolynomial::new(point[num_vars_rows..].to_vec()).evals();
let ck: Vec<_> = comm.comm.iter().map(|c| c.affine()).collect();
let comm_LZ = E::GE::vartime_multiscalar_mul(&L, &ck[..L.len()], true)?;
info!(elapsed_ms = %lr_t.elapsed().as_millis(), "hyrax_compute_lr");
let ipa_instance = InnerProductInstance::<E>::new(&comm_LZ, &R, eval);
let result = arg
.ipa
.verify(&vk.ck, &vk.h, &vk.ck_s, R.len(), &ipa_instance, transcript);
info!(elapsed_ms = %verify_t.elapsed().as_millis(), "hyrax_pcs_verify");
result
}
}
impl<E: Engine> TranscriptReprTrait<E::GE> for HyraxCommitment<E>
where
E::GE: DlogGroupExt,
{
fn to_transcript_bytes(&self) -> Vec<u8> {
let mut v = Vec::new();
v.append(&mut b"poly_commitment_begin".to_vec());
for c in &self.comm {
v.extend(c.to_transcript_bytes());
}
v.append(&mut b"poly_commitment_end".to_vec());
v
}
}
impl<E: Engine> CommitmentTrait<E> for HyraxCommitment<E> where E::GE: DlogGroupExt {}