revm_precompile/bls12_381/
g1_msm.rsuse super::{
g1::{encode_g1_point, extract_g1_input, G1_INPUT_ITEM_LENGTH},
g1_mul,
msm::msm_required_gas,
utils::{extract_scalar_input, NBITS, SCALAR_LENGTH},
};
use crate::{u64_to_address, PrecompileWithAddress};
use crate::{PrecompileError, PrecompileOutput, PrecompileResult};
use blst::{blst_p1, blst_p1_affine, blst_p1_from_affine, blst_p1_to_affine, p1_affines};
use primitives::Bytes;
pub const PRECOMPILE: PrecompileWithAddress =
PrecompileWithAddress(u64_to_address(ADDRESS), g1_msm);
pub const ADDRESS: u64 = 0x0d;
pub(super) fn g1_msm(input: &Bytes, gas_limit: u64) -> PrecompileResult {
let input_len = input.len();
if input_len == 0 || input_len % g1_mul::INPUT_LENGTH != 0 {
return Err(PrecompileError::Other(format!(
"G1MSM input length should be multiple of {}, was {}",
g1_mul::INPUT_LENGTH,
input_len
))
.into());
}
let k = input_len / g1_mul::INPUT_LENGTH;
let required_gas = msm_required_gas(k, g1_mul::BASE_GAS_FEE);
if required_gas > gas_limit {
return Err(PrecompileError::OutOfGas.into());
}
let mut g1_points: Vec<blst_p1> = Vec::with_capacity(k);
let mut scalars: Vec<u8> = Vec::with_capacity(k * SCALAR_LENGTH);
for i in 0..k {
let slice =
&input[i * g1_mul::INPUT_LENGTH..i * g1_mul::INPUT_LENGTH + G1_INPUT_ITEM_LENGTH];
if slice.iter().all(|i| *i == 0) {
continue;
}
let p0_aff = &extract_g1_input(slice, true)?;
let mut p0 = blst_p1::default();
unsafe { blst_p1_from_affine(&mut p0, p0_aff) };
g1_points.push(p0);
scalars.extend_from_slice(
&extract_scalar_input(
&input[i * g1_mul::INPUT_LENGTH + G1_INPUT_ITEM_LENGTH
..i * g1_mul::INPUT_LENGTH + G1_INPUT_ITEM_LENGTH + SCALAR_LENGTH],
)?
.b,
);
}
if g1_points.is_empty() {
return Ok(PrecompileOutput::new(required_gas, [0; 128].into()));
}
let points = p1_affines::from(&g1_points);
let multiexp = points.mult(&scalars, NBITS);
let mut multiexp_aff = blst_p1_affine::default();
unsafe { blst_p1_to_affine(&mut multiexp_aff, &multiexp) };
let out = encode_g1_point(&multiexp_aff);
Ok(PrecompileOutput::new(required_gas, out))
}