forked from availproject/avail
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Made more clear what code is native (availproject#563)
* Made more clear what code is native * Added missing std cfg flag * Hope now this works
- Loading branch information
1 parent
1d2aa5a
commit 152673e
Showing
23 changed files
with
182 additions
and
94 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,128 @@ | ||
| // !!!! | ||
| // If the logic is changed in this file it will break Turing. Do not change it. | ||
| // If the logic is changed in avail-core it will break Turing as well. Do no change it. | ||
| // !!!! | ||
| #![cfg(feature = "std")] | ||
|
|
||
| use super::hosted_header_builder::MIN_WIDTH; | ||
| use crate::limits::BlockLength; | ||
| use avail_base::metrics::avail::{ | ||
| HeaderExtensionBuilderMetrics as Metrics, MetricObserver, ObserveKind, | ||
| }; | ||
| use avail_core::{ | ||
| app_extrinsic::AppExtrinsic, | ||
| header::{extension as he, HeaderExtension}, | ||
| kate_commitment as kc, HeaderVersion, | ||
| }; | ||
| use kate::{ | ||
| couscous::multiproof_params, | ||
| gridgen::{AsBytes, EvaluationGrid}, | ||
| pmp::m1_blst::M1NoPrecomp, | ||
| Seed, | ||
| }; | ||
| use sp_core::H256; | ||
| use sp_runtime::SaturatedConversion; | ||
| use std::{sync::OnceLock, vec::Vec}; | ||
|
|
||
| static PMP: OnceLock<M1NoPrecomp> = OnceLock::new(); | ||
|
|
||
| fn build_grid( | ||
| submitted: Vec<AppExtrinsic>, | ||
| block_length: BlockLength, | ||
| seed: Seed, | ||
| ) -> Result<EvaluationGrid, String> { | ||
| let _metric_observer = MetricObserver::new(ObserveKind::HEGrid); | ||
|
|
||
| let grid = EvaluationGrid::from_extrinsics( | ||
| submitted, | ||
| MIN_WIDTH, | ||
| block_length.cols.0.saturated_into(), // even if we run on a u16 target this is fine | ||
| block_length.rows.0.saturated_into(), | ||
| seed, | ||
| ) | ||
| .map_err(|e| format!("Grid construction failed: {e:?}"))?; | ||
|
|
||
| Ok(grid) | ||
| } | ||
|
|
||
| fn build_commitment(grid: &EvaluationGrid) -> Result<Vec<u8>, String> { | ||
| let _metric_observer = MetricObserver::new(ObserveKind::HECommitment); | ||
|
|
||
| // couscous has pp for degree upto 1024 | ||
| let pmp = PMP.get_or_init(multiproof_params); | ||
|
|
||
| let poly_grid = grid | ||
| .make_polynomial_grid() | ||
| .map_err(|e| format!("Make polynomial grid failed: {e:?}"))?; | ||
|
|
||
| let extended_grid = poly_grid | ||
| .extended_commitments(pmp, 2) | ||
| .map_err(|e| format!("Grid extension failed: {e:?}"))?; | ||
|
|
||
| let mut commitment = Vec::new(); | ||
| for c in extended_grid.iter() { | ||
| match c.to_bytes() { | ||
| Ok(bytes) => commitment.extend(bytes), | ||
| Err(e) => return Err(format!("Commitment serialization failed: {:?}", e)), | ||
| } | ||
| } | ||
|
|
||
| Ok(commitment) | ||
| } | ||
|
|
||
| pub fn build_extension( | ||
| submitted: Vec<AppExtrinsic>, | ||
| data_root: H256, | ||
| block_length: BlockLength, | ||
| _block_number: u32, | ||
| seed: Seed, | ||
| version: HeaderVersion, | ||
| ) -> HeaderExtension { | ||
| let _metric_observer = MetricObserver::new(ObserveKind::HETotalExecutionTime); | ||
|
|
||
| // Build the grid | ||
| let maybe_grid = build_grid(submitted, block_length, seed); | ||
|
|
||
| // We get the grid or return an empty header in case of an error | ||
| let grid = match maybe_grid { | ||
| Ok(res) => res, | ||
| Err(message) => { | ||
| log::error!("NODE_CRITICAL_ERROR_001 - A critical error has occured: {message:?}."); | ||
| log::error!("NODE_CRITICAL_ERROR_001 - If you see this, please warn Avail team and raise an issue."); | ||
| return HeaderExtension::get_faulty_header(data_root, version); | ||
| }, | ||
| }; | ||
|
|
||
| let maybe_commitment = build_commitment(&grid); | ||
|
|
||
| // We get the commitment or return an empty header in case of an error | ||
| let commitment = match maybe_commitment { | ||
| Ok(res) => res, | ||
| Err(message) => { | ||
| log::error!("NODE_CRITICAL_ERROR_002 - A critical error has occured: {message:?}."); | ||
| log::error!("NODE_CRITICAL_ERROR_002 - If you see this, please warn Avail team and raise an issue."); | ||
| return HeaderExtension::get_faulty_header(data_root, version); | ||
| }, | ||
| }; | ||
|
|
||
| // Note that this uses the original dims, _not the extended ones_ | ||
| let rows = grid.dims().rows().get(); | ||
| let cols = grid.dims().cols().get(); | ||
|
|
||
| // Grid Metrics | ||
| Metrics::observe_grid_rows(rows as f64); | ||
| Metrics::observe_grid_cols(cols as f64); | ||
|
|
||
| let app_lookup = grid.lookup().clone(); | ||
|
|
||
| match version { | ||
| HeaderVersion::V3 => { | ||
| let commitment = kc::v3::KateCommitment::new(rows, cols, data_root, commitment); | ||
| he::v3::HeaderExtension { | ||
| app_lookup, | ||
| commitment, | ||
| } | ||
| .into() | ||
| }, | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.