use ff::WithSmallOrderMulGroup;
use rayon::iter::{
IndexedParallelIterator, IntoParallelRefIterator, IntoParallelRefMutIterator, ParallelIterator,
};
use super::{Argument, ProvingKey, VerifyingKey};
use crate::{
plonk::{Any, Column, Error},
poly::{
commitment::PolynomialCommitmentScheme, Coeff, EvaluationDomain, ExtendedLagrangeCoeff,
LagrangeCoeff, Polynomial,
},
utils::arithmetic::parallelize,
};
#[derive(Clone, Debug, PartialEq, Eq)]
pub struct Assembly {
columns: Vec<Column<Any>>,
mapping: Vec<Vec<(usize, usize)>>,
aux: Vec<Vec<(usize, usize)>>,
sizes: Vec<Vec<usize>>,
}
impl Assembly {
pub(crate) fn new(n: usize, p: &Argument) -> Self {
let mut columns = vec![];
for i in 0..p.columns.len() {
columns.push((0..n).map(|j| (i, j)).collect());
}
Assembly {
columns: p.columns.clone(),
mapping: columns.clone(),
aux: columns,
sizes: vec![vec![1usize; n]; p.columns.len()],
}
}
pub(crate) fn copy(
&mut self,
left_column: Column<Any>,
left_row: usize,
right_column: Column<Any>,
right_row: usize,
) -> Result<(), Error> {
let left_column = self
.columns
.iter()
.position(|c| c == &left_column)
.ok_or(Error::ColumnNotInPermutation(left_column))?;
let right_column = self
.columns
.iter()
.position(|c| c == &right_column)
.ok_or(Error::ColumnNotInPermutation(right_column))?;
if left_row >= self.mapping[left_column].len()
|| right_row >= self.mapping[right_column].len()
{
return Err(Error::BoundsFailure);
}
let mut left_cycle = self.aux[left_column][left_row];
let mut right_cycle = self.aux[right_column][right_row];
if left_cycle == right_cycle {
return Ok(());
}
if self.sizes[left_cycle.0][left_cycle.1] < self.sizes[right_cycle.0][right_cycle.1] {
std::mem::swap(&mut left_cycle, &mut right_cycle);
}
self.sizes[left_cycle.0][left_cycle.1] += self.sizes[right_cycle.0][right_cycle.1];
let mut i = right_cycle;
loop {
self.aux[i.0][i.1] = left_cycle;
i = self.mapping[i.0][i.1];
if i == right_cycle {
break;
}
}
let tmp = self.mapping[left_column][left_row];
self.mapping[left_column][left_row] = self.mapping[right_column][right_row];
self.mapping[right_column][right_row] = tmp;
Ok(())
}
pub(crate) fn build_vk<F: WithSmallOrderMulGroup<3>, CS: PolynomialCommitmentScheme<F>>(
self,
params: &CS::Parameters,
domain: &EvaluationDomain<F>,
p: &Argument,
) -> VerifyingKey<F, CS> {
build_vk(params, domain, p, |i, j| self.mapping[i][j])
}
pub(crate) fn build_pk<F: WithSmallOrderMulGroup<3>>(
self,
domain: &EvaluationDomain<F>,
p: &Argument,
) -> ProvingKey<F> {
build_pk::<_>(domain, p, |i, j| self.mapping[i][j])
}
pub fn columns(&self) -> &[Column<Any>] {
&self.columns
}
pub fn mapping(
&self,
) -> impl Iterator<Item = impl IndexedParallelIterator<Item = (usize, usize)> + '_> {
self.mapping.iter().map(|c| c.par_iter().copied())
}
}
pub(crate) fn build_pk<F: WithSmallOrderMulGroup<3>>(
domain: &EvaluationDomain<F>,
p: &Argument,
mapping: impl Fn(usize, usize) -> (usize, usize) + Sync,
) -> ProvingKey<F> {
let mut omega_powers = vec![F::ZERO; domain.n as usize];
{
let omega = domain.get_omega();
parallelize(&mut omega_powers, |o, start| {
let mut cur = omega.pow_vartime([start as u64]);
for v in o.iter_mut() {
*v = cur;
cur *= ω
}
})
}
let mut deltaomega = vec![omega_powers; p.columns.len()];
{
parallelize(&mut deltaomega, |o, start| {
let mut cur = F::DELTA.pow_vartime([start as u64]);
for omega_powers in o.iter_mut() {
for v in omega_powers {
*v *= &cur;
}
cur *= &F::DELTA;
}
});
}
let mut permutations = vec![domain.empty_lagrange(); p.columns.len()];
{
parallelize(&mut permutations, |o, start| {
o.par_iter_mut().enumerate().for_each(|(x, permutation_poly)| {
let i = start + x;
permutation_poly.par_iter_mut().enumerate().for_each(|(j, p)| {
let (permuted_i, permuted_j) = mapping(i, j);
*p = deltaomega[permuted_i][permuted_j];
})
})
});
}
let (polys, cosets) = compute_polys_and_cosets::<F>(domain, p, &permutations);
ProvingKey {
permutations,
polys,
cosets,
}
}
pub(crate) fn build_vk<F: WithSmallOrderMulGroup<3>, CS: PolynomialCommitmentScheme<F>>(
params: &CS::Parameters,
domain: &EvaluationDomain<F>,
p: &Argument,
mapping: impl Fn(usize, usize) -> (usize, usize) + Sync,
) -> VerifyingKey<F, CS> {
let mut omega_powers = vec![F::ZERO; domain.n as usize];
{
let omega = domain.get_omega();
parallelize(&mut omega_powers, |o, start| {
let mut cur = omega.pow_vartime([start as u64]);
for v in o.iter_mut() {
*v = cur;
cur *= ω
}
})
}
let mut deltaomega = vec![omega_powers; p.columns.len()];
{
parallelize(&mut deltaomega, |o, start| {
let mut cur = F::DELTA.pow_vartime([start as u64]);
for omega_powers in o.iter_mut() {
for v in omega_powers {
*v *= &cur;
}
cur *= &F::DELTA;
}
});
}
let mut permutations = vec![domain.empty_lagrange(); p.columns.len()];
{
parallelize(&mut permutations, |o, start| {
for (x, permutation_poly) in o.iter_mut().enumerate() {
let i = start + x;
for (j, p) in permutation_poly.iter_mut().enumerate() {
let (permuted_i, permuted_j) = mapping(i, j);
*p = deltaomega[permuted_i][permuted_j];
}
}
});
}
let mut commitments = Vec::with_capacity(p.columns.len());
for permutation in &permutations {
commitments.push(CS::commit_lagrange(params, permutation));
}
VerifyingKey { commitments }
}
#[allow(clippy::type_complexity)]
pub(crate) fn compute_polys_and_cosets<F: WithSmallOrderMulGroup<3>>(
domain: &EvaluationDomain<F>,
p: &Argument,
permutations: &[Polynomial<F, LagrangeCoeff>],
) -> (
Vec<Polynomial<F, Coeff>>,
Vec<Polynomial<F, ExtendedLagrangeCoeff>>,
) {
let mut polys = vec![domain.empty_coeff(); p.columns.len()];
{
parallelize(&mut polys, |o, start| {
for (x, poly) in o.iter_mut().enumerate() {
let i = start + x;
let permutation_poly = permutations[i].clone();
*poly = domain.lagrange_to_coeff(permutation_poly);
}
});
}
let mut cosets = vec![domain.empty_extended(); p.columns.len()];
{
parallelize(&mut cosets, |o, start| {
for (x, coset) in o.iter_mut().enumerate() {
let i = start + x;
let poly = polys[i].clone();
*coset = domain.coeff_to_extended(poly);
}
});
}
(polys, cosets)
}