use crate::traits::evm_serde::EvmCompatSerde;
use crate::{
constants::{BN_LIMB_WIDTH, BN_N_LIMBS, PARALLEL_THRESHOLD},
digest::{DigestComputer, SimpleDigestible},
errors::NovaError,
gadgets::{
nonnative::{bignat::nat_to_limbs, util::f_to_nat},
utils::scalar_as_base,
},
traits::{
commitment::CommitmentEngineTrait, AbsorbInRO2Trait, AbsorbInROTrait, Engine, ROTrait,
TranscriptReprTrait,
},
Commitment, CommitmentKey, DerandKey, CE,
};
use core::cmp::max;
use ff::Field;
use once_cell::sync::OnceCell;
use rand_core::OsRng;
use rayon::prelude::*;
use serde::{Deserialize, Serialize};
use serde_with::serde_as;
mod sparse;
use sparse::PrecomputedSparseMatrix;
pub use sparse::SparseMatrix;
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct R1CSShape<E: Engine> {
pub(crate) num_cons: usize,
pub(crate) num_vars: usize,
pub(crate) num_io: usize,
pub(crate) A: SparseMatrix<E::Scalar>,
pub(crate) B: SparseMatrix<E::Scalar>,
pub(crate) C: SparseMatrix<E::Scalar>,
#[serde(skip, default = "OnceCell::new")]
pub(crate) digest: OnceCell<E::Scalar>,
#[serde(skip, default = "OnceCell::new")]
precomputed_A: OnceCell<PrecomputedSparseMatrix<E::Scalar>>,
#[serde(skip, default = "OnceCell::new")]
precomputed_B: OnceCell<PrecomputedSparseMatrix<E::Scalar>>,
#[serde(skip, default = "OnceCell::new")]
precomputed_C: OnceCell<PrecomputedSparseMatrix<E::Scalar>>,
}
impl<E: Engine> SimpleDigestible for R1CSShape<E> {}
impl<E: Engine> PartialEq for R1CSShape<E> {
fn eq(&self, other: &Self) -> bool {
self.num_cons == other.num_cons
&& self.num_vars == other.num_vars
&& self.num_io == other.num_io
&& self.A == other.A
&& self.B == other.B
&& self.C == other.C
}
}
impl<E: Engine> Eq for R1CSShape<E> {}
#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct R1CSWitness<E: Engine> {
pub(crate) W: Vec<E::Scalar>,
pub(crate) r_W: E::Scalar,
}
#[serde_as]
#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
#[serde(bound = "")]
pub struct R1CSInstance<E: Engine> {
pub(crate) comm_W: Commitment<E>,
#[serde_as(as = "Vec<EvmCompatSerde>")]
pub(crate) X: Vec<E::Scalar>,
}
#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct RelaxedR1CSWitness<E: Engine> {
pub(crate) W: Vec<E::Scalar>,
pub(crate) r_W: E::Scalar,
pub(crate) E: Vec<E::Scalar>,
pub(crate) r_E: E::Scalar,
}
#[serde_as]
#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
#[serde(bound = "")]
pub struct RelaxedR1CSInstance<E: Engine> {
pub(crate) comm_W: Commitment<E>,
pub(crate) comm_E: Commitment<E>,
#[serde_as(as = "Vec<EvmCompatSerde>")]
pub(crate) X: Vec<E::Scalar>,
#[serde_as(as = "EvmCompatSerde")]
pub(crate) u: E::Scalar,
}
pub type CommitmentKeyHint<E> = dyn Fn(&R1CSShape<E>) -> usize;
impl<E: Engine> R1CSShape<E> {
pub fn num_cons(&self) -> usize {
self.num_cons
}
pub fn num_vars(&self) -> usize {
self.num_vars
}
pub fn num_io(&self) -> usize {
self.num_io
}
pub fn A(&self) -> &SparseMatrix<E::Scalar> {
&self.A
}
pub fn B(&self) -> &SparseMatrix<E::Scalar> {
&self.B
}
pub fn C(&self) -> &SparseMatrix<E::Scalar> {
&self.C
}
pub fn new(
num_cons: usize,
num_vars: usize,
num_io: usize,
A: SparseMatrix<E::Scalar>,
B: SparseMatrix<E::Scalar>,
C: SparseMatrix<E::Scalar>,
) -> Result<R1CSShape<E>, NovaError> {
let is_valid = |num_cons: usize,
num_vars: usize,
num_io: usize,
M: &SparseMatrix<E::Scalar>|
-> Result<Vec<()>, NovaError> {
M.iter()
.map(|(row, col, _val)| {
if row >= num_cons || col > num_io + num_vars {
Err(NovaError::InvalidIndex)
} else {
Ok(())
}
})
.collect::<Result<Vec<()>, NovaError>>()
};
is_valid(num_cons, num_vars, num_io, &A)?;
is_valid(num_cons, num_vars, num_io, &B)?;
is_valid(num_cons, num_vars, num_io, &C)?;
Ok(R1CSShape {
num_cons,
num_vars,
num_io,
A,
B,
C,
digest: OnceCell::new(),
precomputed_A: OnceCell::new(),
precomputed_B: OnceCell::new(),
precomputed_C: OnceCell::new(),
})
}
fn compute_max_ck_size(shapes: &[&R1CSShape<E>], ck_floors: &[&CommitmentKeyHint<E>]) -> usize {
assert!(
!shapes.is_empty(),
"commitment_key requires at least one R1CS shape"
);
assert_eq!(
shapes.len(),
ck_floors.len(),
"shapes and ck_floors must have the same length"
);
shapes
.iter()
.zip(ck_floors.iter())
.map(|(shape, ck_floor)| {
let num_cons = shape.num_cons;
let num_vars = shape.num_vars;
let ck_hint = ck_floor(shape);
max(max(num_cons, num_vars), ck_hint)
})
.max()
.unwrap() }
pub fn commitment_key(
shapes: &[&R1CSShape<E>],
ck_floors: &[&CommitmentKeyHint<E>],
) -> Result<CommitmentKey<E>, crate::errors::NovaError> {
let max_size = Self::compute_max_ck_size(shapes, ck_floors);
E::CE::setup(b"ck", max_size)
}
#[cfg(feature = "io")]
pub fn commitment_key_from_ptau_dir(
shapes: &[&R1CSShape<E>],
ck_floors: &[&CommitmentKeyHint<E>],
ptau_dir: &std::path::Path,
) -> Result<CommitmentKey<E>, crate::errors::NovaError>
where
E::GE: crate::provider::traits::PairingGroup,
{
use std::fs::File;
use std::io::BufReader;
if shapes.is_empty() {
return Err(crate::errors::NovaError::PtauFileError(
"commitment_key_from_ptau_dir requires at least one R1CS shape".to_string(),
));
}
if shapes.len() != ck_floors.len() {
return Err(crate::errors::NovaError::PtauFileError(format!(
"Mismatched lengths: shapes.len() = {}, ck_floors.len() = {}",
shapes.len(),
ck_floors.len(),
)));
}
let max_size = Self::compute_max_ck_size(shapes, ck_floors);
let min_power = max_size.next_power_of_two().trailing_zeros();
let mut ptau_path = None;
for power in min_power..=crate::provider::ptau::MAX_PPOT_POWER {
let pruned = ptau_dir.join(format!("ppot_pruned_{:02}.ptau", power));
if pruned.exists() {
ptau_path = Some(pruned);
break;
}
let original = if power == crate::provider::ptau::MAX_PPOT_POWER {
ptau_dir.join("ppot_0080_final.ptau")
} else {
ptau_dir.join(format!("ppot_0080_{:02}.ptau", power))
};
if original.exists() {
ptau_path = Some(original);
break;
}
}
let ptau_path = ptau_path.ok_or_else(|| {
crate::errors::NovaError::PtauFileError(format!(
"No suitable ptau file found in {:?}. Need at least {} generators (power >= {}). \
Expected files named ppot_pruned_XX.ptau or ppot_0080_XX.ptau where XX >= {:02}",
ptau_dir, max_size, min_power, min_power
))
})?;
let file = File::open(&ptau_path).map_err(|e| {
crate::errors::NovaError::PtauFileError(format!(
"Failed to open {}: {}",
ptau_path.display(),
e
))
})?;
let mut reader = BufReader::new(file);
E::CE::load_setup(&mut reader, b"ck", max_size)
.map_err(|e| crate::errors::NovaError::PtauFileError(e.to_string()))
}
pub fn digest(&self) -> E::Scalar {
self
.digest
.get_or_try_init(|| DigestComputer::new(self).digest())
.cloned()
.expect("Failure in retrieving digest")
}
pub fn precompute_sparse_matrices(&self) {
self
.precomputed_A
.get_or_init(|| PrecomputedSparseMatrix::from_sparse(&self.A));
self
.precomputed_B
.get_or_init(|| PrecomputedSparseMatrix::from_sparse(&self.B));
self
.precomputed_C
.get_or_init(|| PrecomputedSparseMatrix::from_sparse(&self.C));
}
#[inline]
pub(crate) fn is_regular_shape(&self) -> bool {
let cons_valid = self.num_cons.next_power_of_two() == self.num_cons;
let vars_valid = self.num_vars.next_power_of_two() == self.num_vars;
let io_lt_vars = self.num_io < self.num_vars;
cons_valid && vars_valid && io_lt_vars
}
pub fn multiply_vec(
&self,
z: &[E::Scalar],
) -> Result<(Vec<E::Scalar>, Vec<E::Scalar>, Vec<E::Scalar>), NovaError> {
if z.len() != self.num_io + self.num_vars + 1 {
return Err(NovaError::InvalidWitnessLength);
}
let pa = self
.precomputed_A
.get_or_init(|| PrecomputedSparseMatrix::from_sparse(&self.A));
let pb = self
.precomputed_B
.get_or_init(|| PrecomputedSparseMatrix::from_sparse(&self.B));
let pc = self
.precomputed_C
.get_or_init(|| PrecomputedSparseMatrix::from_sparse(&self.C));
let (Az, (Bz, Cz)) = rayon::join(
|| pa.multiply_vec(z),
|| rayon::join(|| pb.multiply_vec(z), || pc.multiply_vec(z)),
);
Ok((Az, Bz, Cz))
}
pub fn multiply_vec_pair(
&self,
z1: &[E::Scalar],
z2: &[E::Scalar],
) -> Result<
(
(Vec<E::Scalar>, Vec<E::Scalar>, Vec<E::Scalar>),
(Vec<E::Scalar>, Vec<E::Scalar>, Vec<E::Scalar>),
),
NovaError,
> {
if z1.len() != self.num_io + self.num_vars + 1 || z2.len() != self.num_io + self.num_vars + 1 {
return Err(NovaError::InvalidWitnessLength);
}
let pa = self
.precomputed_A
.get_or_init(|| PrecomputedSparseMatrix::from_sparse(&self.A));
let pb = self
.precomputed_B
.get_or_init(|| PrecomputedSparseMatrix::from_sparse(&self.B));
let pc = self
.precomputed_C
.get_or_init(|| PrecomputedSparseMatrix::from_sparse(&self.C));
let ((Az1, Az2), ((Bz1, Bz2), (Cz1, Cz2))) = rayon::join(
|| pa.multiply_vec_pair(z1, z2),
|| {
rayon::join(
|| pb.multiply_vec_pair(z1, z2),
|| pc.multiply_vec_pair(z1, z2),
)
},
);
Ok(((Az1, Bz1, Cz1), (Az2, Bz2, Cz2)))
}
pub fn is_sat_relaxed(
&self,
ck: &CommitmentKey<E>,
U: &RelaxedR1CSInstance<E>,
W: &RelaxedR1CSWitness<E>,
) -> Result<(), NovaError> {
assert_eq!(W.W.len(), self.num_vars);
assert_eq!(W.E.len(), self.num_cons);
assert_eq!(U.X.len(), self.num_io);
let res_eq = {
let z = [W.W.clone(), vec![U.u], U.X.clone()].concat();
let (Az, Bz, Cz) = self.multiply_vec(&z)?;
assert_eq!(Az.len(), self.num_cons);
assert_eq!(Bz.len(), self.num_cons);
assert_eq!(Cz.len(), self.num_cons);
(0..self.num_cons).all(|i| Az[i] * Bz[i] == U.u * Cz[i] + W.E[i])
};
let res_comm = {
let (comm_W, comm_E) = rayon::join(
|| CE::<E>::commit(ck, &W.W, &W.r_W),
|| CE::<E>::commit(ck, &W.E, &W.r_E),
);
U.comm_W == comm_W && U.comm_E == comm_E
};
if !res_eq {
return Err(NovaError::UnSat {
reason: "Relaxed R1CS is unsatisfiable".to_string(),
});
}
if !res_comm {
return Err(NovaError::UnSat {
reason: "Invalid commitments".to_string(),
});
}
Ok(())
}
pub fn is_sat(
&self,
ck: &CommitmentKey<E>,
U: &R1CSInstance<E>,
W: &R1CSWitness<E>,
) -> Result<(), NovaError> {
assert_eq!(W.W.len(), self.num_vars);
assert_eq!(U.X.len(), self.num_io);
let res_eq = {
let z = [W.W.clone(), vec![E::Scalar::ONE], U.X.clone()].concat();
let (Az, Bz, Cz) = self.multiply_vec(&z)?;
assert_eq!(Az.len(), self.num_cons);
assert_eq!(Bz.len(), self.num_cons);
assert_eq!(Cz.len(), self.num_cons);
(0..self.num_cons).all(|i| Az[i] * Bz[i] == Cz[i])
};
let res_comm = U.comm_W == CE::<E>::commit(ck, &W.W, &W.r_W);
if !res_eq {
return Err(NovaError::UnSat {
reason: "R1CS is unsatisfiable".to_string(),
});
}
if !res_comm {
return Err(NovaError::UnSat {
reason: "Invalid commitment".to_string(),
});
}
Ok(())
}
pub fn commit_T(
&self,
ck: &CommitmentKey<E>,
U1: &RelaxedR1CSInstance<E>,
W1: &RelaxedR1CSWitness<E>,
U2: &R1CSInstance<E>,
W2: &R1CSWitness<E>,
r_T: &E::Scalar,
) -> Result<(Vec<E::Scalar>, Commitment<E>), NovaError> {
let z_len = W1.W.len() + 1 + U1.X.len();
let Z = if z_len <= PARALLEL_THRESHOLD {
let mut z = Vec::with_capacity(z_len);
W1.W
.iter()
.zip(W2.W.iter())
.for_each(|(w1, w2)| z.push(*w1 + *w2));
z.push(U1.u + E::Scalar::ONE);
U1.X
.iter()
.zip(U2.X.iter())
.for_each(|(x1, x2)| z.push(*x1 + *x2));
z
} else {
let Z1 = [W1.W.clone(), vec![U1.u], U1.X.clone()].concat();
let Z2 = [W2.W.clone(), vec![E::Scalar::ONE], U2.X.clone()].concat();
Z1.into_par_iter()
.zip(Z2.into_par_iter())
.map(|(z1, z2)| z1 + z2)
.collect::<Vec<E::Scalar>>()
};
let u = U1.u + E::Scalar::ONE;
let (AZ, BZ, CZ) = self.multiply_vec(&Z)?;
let T = AZ
.par_iter()
.zip(BZ.par_iter())
.zip(CZ.par_iter())
.zip(W1.E.par_iter())
.map(|(((az, bz), cz), e)| *az * *bz - u * *cz - *e)
.collect::<Vec<E::Scalar>>();
let comm_T = CE::<E>::commit(ck, &T, r_T);
Ok((T, comm_T))
}
pub fn commit_T_relaxed(
&self,
ck: &CommitmentKey<E>,
U1: &RelaxedR1CSInstance<E>,
W1: &RelaxedR1CSWitness<E>,
U2: &RelaxedR1CSInstance<E>,
W2: &RelaxedR1CSWitness<E>,
r_T: &E::Scalar,
) -> Result<(Vec<E::Scalar>, Commitment<E>), NovaError> {
let Z1 = [W1.W.clone(), vec![U1.u], U1.X.clone()].concat();
let Z2 = [W2.W.clone(), vec![U2.u], U2.X.clone()].concat();
let Z = Z1
.into_par_iter()
.zip(Z2.into_par_iter())
.map(|(z1, z2)| z1 + z2)
.collect::<Vec<E::Scalar>>();
let u = U1.u + U2.u;
let (AZ, BZ, CZ) = self.multiply_vec(&Z)?;
let T = AZ
.par_iter()
.zip(BZ.par_iter())
.zip(CZ.par_iter())
.zip(W1.E.par_iter())
.zip(W2.E.par_iter())
.map(|((((az, bz), cz), e1), e2)| *az * *bz - u * *cz - *e1 - *e2)
.collect::<Vec<E::Scalar>>();
let comm_T = CE::<E>::commit(ck, &T, r_T);
Ok((T, comm_T))
}
pub fn pad(&self) -> Self {
if self.is_regular_shape() {
return self.clone();
}
let m = max(max(self.num_vars, self.num_cons), self.num_io).next_power_of_two();
if self.num_vars == m {
return R1CSShape {
num_cons: m,
num_vars: m,
num_io: self.num_io,
A: self.A.clone(),
B: self.B.clone(),
C: self.C.clone(),
digest: OnceCell::new(),
precomputed_A: OnceCell::new(),
precomputed_B: OnceCell::new(),
precomputed_C: OnceCell::new(),
};
}
let num_vars_padded = m;
let num_cons_padded = m;
let apply_pad = |mut M: SparseMatrix<E::Scalar>| -> SparseMatrix<E::Scalar> {
M.indices.par_iter_mut().for_each(|c| {
if *c >= self.num_vars {
*c += num_vars_padded - self.num_vars
}
});
M.cols += num_vars_padded - self.num_vars;
let ex = {
let nnz = M.indptr.last().unwrap();
vec![*nnz; num_cons_padded - self.num_cons]
};
M.indptr.extend(ex);
M
};
let A_padded = apply_pad(self.A.clone());
let B_padded = apply_pad(self.B.clone());
let C_padded = apply_pad(self.C.clone());
R1CSShape {
num_cons: num_cons_padded,
num_vars: num_vars_padded,
num_io: self.num_io,
A: A_padded,
B: B_padded,
C: C_padded,
digest: OnceCell::new(),
precomputed_A: OnceCell::new(),
precomputed_B: OnceCell::new(),
precomputed_C: OnceCell::new(),
}
}
pub fn pad_nonsquare(&self) -> Self {
if self.is_regular_shape() {
return self.clone();
}
let num_vars_padded = max(self.num_vars, self.num_io + 1).next_power_of_two();
let num_cons_padded = self.num_cons.next_power_of_two();
let apply_pad = |mut M: SparseMatrix<E::Scalar>| -> SparseMatrix<E::Scalar> {
if num_vars_padded > self.num_vars {
M.indices.par_iter_mut().for_each(|c| {
if *c >= self.num_vars {
*c += num_vars_padded - self.num_vars
}
});
M.cols += num_vars_padded - self.num_vars;
}
if num_cons_padded > self.num_cons {
let ex = {
let nnz = M.indptr.last().unwrap();
vec![*nnz; num_cons_padded - self.num_cons]
};
M.indptr.extend(ex);
}
M
};
let A_padded = apply_pad(self.A.clone());
let B_padded = apply_pad(self.B.clone());
let C_padded = apply_pad(self.C.clone());
R1CSShape {
num_cons: num_cons_padded,
num_vars: num_vars_padded,
num_io: self.num_io,
A: A_padded,
B: B_padded,
C: C_padded,
digest: OnceCell::new(),
precomputed_A: OnceCell::new(),
precomputed_B: OnceCell::new(),
precomputed_C: OnceCell::new(),
}
}
pub fn sample_random_instance_witness(
&self,
ck: &CommitmentKey<E>,
) -> Result<(RelaxedR1CSInstance<E>, RelaxedR1CSWitness<E>), NovaError> {
let Z = (0..self.num_vars + self.num_io + 1)
.into_par_iter()
.map(|_| E::Scalar::random(&mut OsRng))
.collect::<Vec<E::Scalar>>();
let r_W = E::Scalar::random(&mut OsRng);
let r_E = E::Scalar::random(&mut OsRng);
let u = Z[self.num_vars];
let (AZ, BZ, CZ) = self.multiply_vec(&Z)?;
let E = AZ
.par_iter()
.zip(BZ.par_iter())
.zip(CZ.par_iter())
.map(|((az, bz), cz)| *az * *bz - u * *cz)
.collect::<Vec<E::Scalar>>();
let (comm_W, comm_E) = rayon::join(
|| CE::<E>::commit(ck, &Z[..self.num_vars], &r_W),
|| CE::<E>::commit(ck, &E, &r_E),
);
Ok((
RelaxedR1CSInstance {
comm_W,
comm_E,
u,
X: Z[self.num_vars + 1..].to_vec(),
},
RelaxedR1CSWitness {
W: Z[..self.num_vars].to_vec(),
r_W,
E,
r_E,
},
))
}
}
impl<E: Engine> R1CSWitness<E> {
pub fn new(S: &R1CSShape<E>, W: &[E::Scalar]) -> Result<R1CSWitness<E>, NovaError> {
let mut W = W.to_vec();
W.resize(S.num_vars, E::Scalar::ZERO);
Ok(R1CSWitness {
W,
r_W: E::Scalar::random(&mut OsRng),
})
}
pub fn W(&self) -> &[E::Scalar] {
&self.W
}
pub fn r_W(&self) -> &E::Scalar {
&self.r_W
}
pub fn commit(&self, ck: &CommitmentKey<E>) -> Commitment<E> {
CE::<E>::commit(ck, &self.W, &self.r_W)
}
pub fn pad(&self, S: &R1CSShape<E>) -> R1CSWitness<E> {
let mut W = self.W.clone();
W.extend(vec![E::Scalar::ZERO; S.num_vars - W.len()]);
Self { W, r_W: self.r_W }
}
pub fn derandomize(&self) -> (Self, E::Scalar) {
(
R1CSWitness {
W: self.W.clone(),
r_W: E::Scalar::ZERO,
},
self.r_W,
)
}
}
impl<E: Engine> R1CSInstance<E> {
pub fn new(
S: &R1CSShape<E>,
comm_W: &Commitment<E>,
X: &[E::Scalar],
) -> Result<R1CSInstance<E>, NovaError> {
if S.num_io != X.len() {
Err(NovaError::InvalidInputLength)
} else {
Ok(R1CSInstance {
comm_W: *comm_W,
X: X.to_owned(),
})
}
}
pub fn new_unchecked(
comm_W: &Commitment<E>,
X: &[E::Scalar],
) -> Result<R1CSInstance<E>, NovaError> {
Ok(R1CSInstance {
comm_W: *comm_W,
X: X.to_owned(),
})
}
pub fn comm_W(&self) -> &Commitment<E> {
&self.comm_W
}
pub fn X(&self) -> &[E::Scalar] {
&self.X
}
pub fn derandomize(&self, dk: &DerandKey<E>, r_W: &E::Scalar) -> R1CSInstance<E> {
R1CSInstance {
comm_W: CE::<E>::derandomize(dk, &self.comm_W, r_W),
X: self.X.clone(),
}
}
}
impl<E: Engine> TranscriptReprTrait<E::GE> for R1CSInstance<E> {
fn to_transcript_bytes(&self) -> Vec<u8> {
[
self.comm_W.to_transcript_bytes(),
self.X.as_slice().to_transcript_bytes(),
]
.concat()
}
}
impl<E: Engine> AbsorbInROTrait<E> for R1CSInstance<E> {
fn absorb_in_ro(&self, ro: &mut E::RO) {
self.comm_W.absorb_in_ro(ro);
for x in &self.X {
ro.absorb(scalar_as_base::<E>(*x));
}
}
}
impl<E: Engine> AbsorbInRO2Trait<E> for R1CSInstance<E> {
fn absorb_in_ro2(&self, ro: &mut E::RO2) {
self.comm_W.absorb_in_ro2(ro);
for x in &self.X {
ro.absorb(*x);
}
}
}
impl<E: Engine> RelaxedR1CSWitness<E> {
pub fn default(S: &R1CSShape<E>) -> RelaxedR1CSWitness<E> {
RelaxedR1CSWitness {
W: vec![E::Scalar::ZERO; S.num_vars],
r_W: E::Scalar::ZERO,
E: vec![E::Scalar::ZERO; S.num_cons],
r_E: E::Scalar::ZERO,
}
}
pub fn from_r1cs_witness(S: &R1CSShape<E>, witness: &R1CSWitness<E>) -> RelaxedR1CSWitness<E> {
RelaxedR1CSWitness {
W: witness.W.clone(),
r_W: witness.r_W,
E: vec![E::Scalar::ZERO; S.num_cons],
r_E: E::Scalar::ZERO,
}
}
pub fn new(
S: &R1CSShape<E>,
W: Vec<E::Scalar>,
r_W: E::Scalar,
E: Vec<E::Scalar>,
r_E: E::Scalar,
) -> Result<RelaxedR1CSWitness<E>, NovaError> {
if W.len() != S.num_vars {
return Err(NovaError::InvalidWitnessLength);
}
if E.len() != S.num_cons {
return Err(NovaError::InvalidWitnessLength);
}
Ok(RelaxedR1CSWitness { W, r_W, E, r_E })
}
pub fn W(&self) -> &[E::Scalar] {
&self.W
}
pub fn E(&self) -> &[E::Scalar] {
&self.E
}
pub fn commit(&self, ck: &CommitmentKey<E>) -> (Commitment<E>, Commitment<E>) {
(
CE::<E>::commit(ck, &self.W, &self.r_W),
CE::<E>::commit(ck, &self.E, &self.r_E),
)
}
pub fn fold(
&self,
W2: &R1CSWitness<E>,
T: &[E::Scalar],
r_T: &E::Scalar,
r: &E::Scalar,
) -> Result<RelaxedR1CSWitness<E>, NovaError> {
let (W1, r_W1, E1, r_E1) = (&self.W, &self.r_W, &self.E, &self.r_E);
let (W2, r_W2) = (&W2.W, &W2.r_W);
if W1.len() != W2.len() {
return Err(NovaError::InvalidWitnessLength);
}
let W = W1
.par_iter()
.zip(W2)
.map(|(a, b)| *a + *r * *b)
.collect::<Vec<E::Scalar>>();
let E = E1
.par_iter()
.zip(T)
.map(|(a, b)| *a + *r * *b)
.collect::<Vec<E::Scalar>>();
let r_W = *r_W1 + *r * r_W2;
let r_E = *r_E1 + *r * r_T;
Ok(RelaxedR1CSWitness { W, r_W, E, r_E })
}
pub fn fold_relaxed(
&self,
W2: &RelaxedR1CSWitness<E>,
T: &[E::Scalar],
r_T: &E::Scalar,
r: &E::Scalar,
) -> Result<RelaxedR1CSWitness<E>, NovaError> {
let (W1, r_W1, E1, r_E1) = (&self.W, &self.r_W, &self.E, &self.r_E);
let (W2, r_W2, E2, r_E2) = (&W2.W, &W2.r_W, &W2.E, &W2.r_E);
if W1.len() != W2.len() {
return Err(NovaError::InvalidWitnessLength);
}
let W = W1
.par_iter()
.zip(W2)
.map(|(a, b)| *a + *r * *b)
.collect::<Vec<E::Scalar>>();
let E = E1
.par_iter()
.zip(T)
.zip(E2.par_iter())
.map(|((a, b), c)| *a + *r * *b + *r * *r * *c)
.collect::<Vec<E::Scalar>>();
let r_W = *r_W1 + *r * r_W2;
let r_E = *r_E1 + *r * r_T + *r * *r * *r_E2;
Ok(RelaxedR1CSWitness { W, r_W, E, r_E })
}
pub fn pad(&self, S: &R1CSShape<E>) -> RelaxedR1CSWitness<E> {
let mut W = self.W.clone();
W.extend(vec![E::Scalar::ZERO; S.num_vars - W.len()]);
let mut E = self.E.clone();
E.extend(vec![E::Scalar::ZERO; S.num_cons - E.len()]);
Self {
W,
r_W: self.r_W,
E,
r_E: self.r_E,
}
}
pub fn into_W_E(self) -> (Vec<E::Scalar>, Vec<E::Scalar>) {
(self.W, self.E)
}
pub fn derandomize(&self) -> (Self, E::Scalar, E::Scalar) {
(
RelaxedR1CSWitness {
W: self.W.clone(),
r_W: E::Scalar::ZERO,
E: self.E.clone(),
r_E: E::Scalar::ZERO,
},
self.r_W,
self.r_E,
)
}
}
impl<E: Engine> RelaxedR1CSInstance<E> {
pub fn default(_ck: &CommitmentKey<E>, S: &R1CSShape<E>) -> RelaxedR1CSInstance<E> {
let (comm_W, comm_E) = (Commitment::<E>::default(), Commitment::<E>::default());
RelaxedR1CSInstance {
comm_W,
comm_E,
u: E::Scalar::ZERO,
X: vec![E::Scalar::ZERO; S.num_io],
}
}
pub fn from_r1cs_instance(
ck: &CommitmentKey<E>,
S: &R1CSShape<E>,
instance: &R1CSInstance<E>,
) -> RelaxedR1CSInstance<E> {
let mut r_instance = RelaxedR1CSInstance::default(ck, S);
r_instance.comm_W = instance.comm_W;
r_instance.u = E::Scalar::ONE;
r_instance.X.clone_from(&instance.X);
r_instance
}
pub fn comm_W(&self) -> &Commitment<E> {
&self.comm_W
}
pub fn comm_E(&self) -> &Commitment<E> {
&self.comm_E
}
pub fn X(&self) -> &[E::Scalar] {
&self.X
}
pub fn u(&self) -> E::Scalar {
self.u
}
pub fn new(
S: &R1CSShape<E>,
comm_W: Commitment<E>,
comm_E: Commitment<E>,
u: E::Scalar,
X: Vec<E::Scalar>,
) -> Result<RelaxedR1CSInstance<E>, NovaError> {
if X.len() != S.num_io {
return Err(NovaError::InvalidInputLength);
}
Ok(RelaxedR1CSInstance {
comm_W,
comm_E,
u,
X,
})
}
pub fn from_r1cs_instance_unchecked(
comm_W: &Commitment<E>,
X: &[E::Scalar],
) -> RelaxedR1CSInstance<E> {
RelaxedR1CSInstance {
comm_W: *comm_W,
comm_E: Commitment::<E>::default(),
u: E::Scalar::ONE,
X: X.to_vec(),
}
}
pub fn fold(
&self,
U2: &R1CSInstance<E>,
comm_T: &Commitment<E>,
r: &E::Scalar,
) -> RelaxedR1CSInstance<E> {
let (X1, u1, comm_W_1, comm_E_1) =
(&self.X, &self.u, &self.comm_W.clone(), &self.comm_E.clone());
let (X2, comm_W_2) = (&U2.X, &U2.comm_W);
let X = X1
.par_iter()
.zip(X2)
.map(|(a, b)| *a + *r * *b)
.collect::<Vec<E::Scalar>>();
let comm_W = *comm_W_1 + *comm_W_2 * *r;
let comm_E = *comm_E_1 + *comm_T * *r;
let u = *u1 + *r;
RelaxedR1CSInstance {
comm_W,
comm_E,
X,
u,
}
}
pub fn fold_relaxed(
&self,
U2: &RelaxedR1CSInstance<E>,
comm_T: &Commitment<E>,
r: &E::Scalar,
) -> RelaxedR1CSInstance<E> {
let (X1, u1, comm_W_1, comm_E_1) =
(&self.X, &self.u, &self.comm_W.clone(), &self.comm_E.clone());
let (X2, u2, comm_W_2, comm_E_2) = (&U2.X, &U2.u, &U2.comm_W, &U2.comm_E);
let X = X1
.par_iter()
.zip(X2)
.map(|(a, b)| *a + *r * *b)
.collect::<Vec<E::Scalar>>();
let comm_W = *comm_W_1 + *comm_W_2 * *r;
let comm_E = *comm_E_1 + *comm_T * *r + *comm_E_2 * *r * *r;
let u = *u1 + *r * *u2;
RelaxedR1CSInstance {
comm_W,
comm_E,
X,
u,
}
}
pub fn derandomize(
&self,
dk: &DerandKey<E>,
r_W: &E::Scalar,
r_E: &E::Scalar,
) -> RelaxedR1CSInstance<E> {
RelaxedR1CSInstance {
comm_W: CE::<E>::derandomize(dk, &self.comm_W, r_W),
comm_E: CE::<E>::derandomize(dk, &self.comm_E, r_E),
X: self.X.clone(),
u: self.u,
}
}
}
impl<E: Engine> TranscriptReprTrait<E::GE> for RelaxedR1CSInstance<E> {
fn to_transcript_bytes(&self) -> Vec<u8> {
[
self.comm_W.to_transcript_bytes(),
self.comm_E.to_transcript_bytes(),
self.u.to_transcript_bytes(),
self.X.as_slice().to_transcript_bytes(),
]
.concat()
}
}
impl<E: Engine> AbsorbInROTrait<E> for RelaxedR1CSInstance<E> {
fn absorb_in_ro(&self, ro: &mut E::RO) {
self.comm_W.absorb_in_ro(ro);
self.comm_E.absorb_in_ro(ro);
ro.absorb(scalar_as_base::<E>(self.u));
for x in &self.X {
let limbs: Vec<E::Scalar> = nat_to_limbs(&f_to_nat(x), BN_LIMB_WIDTH, BN_N_LIMBS).unwrap();
for limb in limbs {
ro.absorb(scalar_as_base::<E>(limb));
}
}
}
}
#[cfg(test)]
mod tests {
use ff::Field;
use super::*;
use crate::{
provider::{Bn256EngineKZG, PallasEngine, Secp256k1Engine},
r1cs::sparse::SparseMatrix,
traits::{snark::default_ck_hint, Engine},
};
fn tiny_r1cs<E: Engine>(num_vars: usize) -> R1CSShape<E> {
let one = <E::Scalar as Field>::ONE;
let (num_cons, num_vars, num_io, A, B, C) = {
let num_cons = 4;
let num_io = 2;
let mut A: Vec<(usize, usize, E::Scalar)> = Vec::new();
let mut B: Vec<(usize, usize, E::Scalar)> = Vec::new();
let mut C: Vec<(usize, usize, E::Scalar)> = Vec::new();
A.push((0, num_vars + 1, one));
B.push((0, num_vars + 1, one));
C.push((0, 0, one));
A.push((1, 0, one));
B.push((1, num_vars + 1, one));
C.push((1, 1, one));
A.push((2, 1, one));
A.push((2, num_vars + 1, one));
B.push((2, num_vars, one));
C.push((2, 2, one));
A.push((3, 2, one));
A.push((3, num_vars, one + one + one + one + one));
B.push((3, num_vars, one));
C.push((3, num_vars + 2, one));
(num_cons, num_vars, num_io, A, B, C)
};
let rows = num_cons;
let cols = num_vars + num_io + 1;
let res = R1CSShape::new(
num_cons,
num_vars,
num_io,
SparseMatrix::new(&A, rows, cols),
SparseMatrix::new(&B, rows, cols),
SparseMatrix::new(&C, rows, cols),
);
assert!(res.is_ok());
res.unwrap()
}
fn test_pad_tiny_r1cs_with<E: Engine>() {
let padded_r1cs = tiny_r1cs::<E>(3).pad();
assert!(padded_r1cs.is_regular_shape());
let expected_r1cs = tiny_r1cs::<E>(4);
assert_eq!(padded_r1cs, expected_r1cs);
}
#[test]
fn test_pad_tiny_r1cs() {
test_pad_tiny_r1cs_with::<PallasEngine>();
test_pad_tiny_r1cs_with::<Bn256EngineKZG>();
test_pad_tiny_r1cs_with::<Secp256k1Engine>();
}
fn test_pad_nonsquare_with<E: Engine>() {
let S = tiny_r1cs::<E>(8);
let padded = S.pad_nonsquare();
assert!(padded.is_regular_shape());
assert_eq!(padded.num_cons, 4);
assert_eq!(padded.num_vars, 8);
let S2 = tiny_r1cs::<E>(3);
let padded2 = S2.pad_nonsquare();
assert!(padded2.is_regular_shape());
assert_eq!(padded2.num_cons, 4);
assert_eq!(padded2.num_vars, 4);
let ck = R1CSShape::commitment_key(&[&padded], &[&*default_ck_hint()]).unwrap();
let (inst, wit) = padded.sample_random_instance_witness(&ck).unwrap();
assert!(padded.is_sat_relaxed(&ck, &inst, &wit).is_ok());
}
#[test]
fn test_pad_nonsquare() {
test_pad_nonsquare_with::<PallasEngine>();
test_pad_nonsquare_with::<Bn256EngineKZG>();
test_pad_nonsquare_with::<Secp256k1Engine>();
}
fn test_random_sample_with<E: Engine>() {
let S = tiny_r1cs::<E>(4);
let ck = R1CSShape::commitment_key(&[&S], &[&*default_ck_hint()]).unwrap();
let (inst, wit) = S.sample_random_instance_witness(&ck).unwrap();
assert!(S.is_sat_relaxed(&ck, &inst, &wit).is_ok());
}
#[test]
fn test_random_sample() {
test_random_sample_with::<PallasEngine>();
test_random_sample_with::<Bn256EngineKZG>();
test_random_sample_with::<Secp256k1Engine>();
}
fn test_multiply_vec_pair_with<E: Engine>() {
let S = tiny_r1cs::<E>(4);
let z_len = S.num_vars + 1 + S.num_io;
let z1: Vec<E::Scalar> = (1..=z_len as u64).map(E::Scalar::from).collect();
let z2: Vec<E::Scalar> = (10..10 + z_len as u64).map(E::Scalar::from).collect();
let (az1, bz1, cz1) = S.multiply_vec(&z1).unwrap();
let (az2, bz2, cz2) = S.multiply_vec(&z2).unwrap();
let ((paz1, pbz1, pcz1), (paz2, pbz2, pcz2)) = S.multiply_vec_pair(&z1, &z2).unwrap();
assert_eq!(az1, paz1);
assert_eq!(bz1, pbz1);
assert_eq!(cz1, pcz1);
assert_eq!(az2, paz2);
assert_eq!(bz2, pbz2);
assert_eq!(cz2, pcz2);
}
#[test]
fn test_multiply_vec_pair() {
test_multiply_vec_pair_with::<PallasEngine>();
test_multiply_vec_pair_with::<Bn256EngineKZG>();
test_multiply_vec_pair_with::<Secp256k1Engine>();
}
}