@@ -10,7 +10,7 @@ use crate::types::jobs::metadata::{JobMetadata, JobSpecificMetadata, SnosMetadat
1010use crate :: types:: jobs:: status:: JobVerificationStatus ;
1111use crate :: types:: jobs:: types:: { JobStatus , JobType } ;
1212use crate :: worker:: event_handler:: jobs:: JobHandlerTrait ;
13- use crate :: worker:: utils:: fact_info:: { build_on_chain_data , get_fact_info, get_fact_l2, get_program_output} ;
13+ use crate :: worker:: utils:: fact_info:: { get_fact_info, get_fact_l2, get_program_output} ;
1414use async_trait:: async_trait;
1515use bytes:: Bytes ;
1616use cairo_vm:: vm:: runners:: cairo_pie:: CairoPie ;
@@ -180,11 +180,7 @@ impl JobHandlerTrait for SnosJobHandler {
180180 }
181181
182182 debug ! ( "Storing SNOS outputs" ) ;
183- if config. layer ( ) == & Layer :: L3 {
184- // Store the on-chain data path
185- self . store_l2 ( internal_id. clone ( ) , config. storage ( ) , & snos_metadata, cairo_pie, os_output, program_output)
186- . await ?;
187- } else if config. layer ( ) == & Layer :: L2 {
183+ if config. layer ( ) == & Layer :: L2 {
188184 // Store the Cairo Pie path
189185 self . store ( internal_id. clone ( ) , config. storage ( ) , & snos_metadata, cairo_pie, os_output, program_output)
190186 . await ?;
@@ -218,38 +214,6 @@ impl JobHandlerTrait for SnosJobHandler {
218214}
219215
220216impl SnosJobHandler {
221- /// Stores the [CairoPie] and the [StarknetOsOutput] and [OnChainData] in the Data Storage.
222- /// The paths will be:
223- /// - [block_number]/cairo_pie.zip
224- /// - [block_number]/snos_output.json
225- /// - [block_number]/onchain_data.json
226- /// - [block_number]/program_output.json
227- async fn store_l2 (
228- & self ,
229- internal_id : String ,
230- data_storage : & dyn StorageClient ,
231- snos_metadata : & SnosMetadata ,
232- cairo_pie : CairoPie ,
233- snos_output : Vec < Felt > ,
234- program_output : Vec < Felt252 > ,
235- ) -> Result < ( ) , SnosError > {
236- let on_chain_data = build_on_chain_data ( & cairo_pie)
237- . map_err ( |_e| SnosError :: FactCalculationError ( FactError :: OnChainDataCompute ) ) ?;
238-
239- self . store ( internal_id. clone ( ) , data_storage, snos_metadata, cairo_pie, snos_output, program_output) . await ?;
240- let on_chain_data_key = snos_metadata
241- . on_chain_data_path
242- . as_ref ( )
243- . ok_or_else ( || SnosError :: Other ( OtherError ( eyre ! ( "OnChain data path is not found" ) ) ) ) ?;
244-
245- let on_chain_data_vec = serde_json:: to_vec ( & on_chain_data) . map_err ( |e| {
246- SnosError :: OnChainDataUnserializable { internal_id : internal_id. to_string ( ) , message : e. to_string ( ) }
247- } ) ?;
248- data_storage. put_data ( on_chain_data_vec. into ( ) , on_chain_data_key) . await . map_err ( |e| {
249- SnosError :: OnChainDataUnstorable { internal_id : internal_id. to_string ( ) , message : e. to_string ( ) }
250- } ) ?;
251- Ok ( ( ) )
252- }
253217 /// Stores the [CairoPie] and the [StarknetOsOutput] in the Data Storage.
254218 /// The paths will be:
255219 /// - [block_number]/cairo_pie.zip
0 commit comments