@@ -25,7 +25,7 @@ pub struct EnvTask {
2525 ru_provider : RuProvider ,
2626}
2727
28- /// An environment for simulating a signet block.
28+ /// An environment for simulating a block.
2929#[ derive( Debug , Clone ) ]
3030pub struct Environment {
3131 block_env : BlockEnv ,
@@ -56,36 +56,36 @@ impl Environment {
5656 }
5757}
5858
59- /// Contains a signet BlockEnv and its corresponding host Header .
59+ /// Contains environments to simulate both host and rollup blocks .
6060#[ derive( Debug , Clone ) ]
6161pub struct SimEnv {
6262 /// The host environment, for host block simulation.
6363 pub host : Environment ,
6464
65- /// The signet environment, for rollup block simulation.
65+ /// The rollup environment, for rollup block simulation.
6666 pub rollup : Environment ,
6767
68- /// A tracing span associated with this block
68+ /// A tracing span associated with this block simulation.
6969 pub span : Span ,
7070}
7171
7272impl SimEnv {
73- /// Get a reference to previous Signet header.
74- pub const fn prev_header ( & self ) -> & Header {
73+ /// Get a reference to previous rollup header.
74+ pub const fn prev_rollup ( & self ) -> & Header {
7575 & self . rollup . prev_header
7676 }
7777
78- /// Get a reference to the previous host header
78+ /// Get a reference to the previous host header.
7979 pub const fn prev_host ( & self ) -> & Header {
8080 & self . host . prev_header
8181 }
8282
83- /// Get the block number of the signet block environment.
84- pub const fn block_number ( & self ) -> u64 {
85- self . prev_header ( ) . number . saturating_add ( 1 )
83+ /// Get the block number of the rollup block environment.
84+ pub const fn rollup_block_number ( & self ) -> u64 {
85+ self . prev_rollup ( ) . number . saturating_add ( 1 )
8686 }
8787
88- /// Get the host block number for the signet block environment.
88+ /// Get the block number for the host block environment.
8989 pub const fn host_block_number ( & self ) -> u64 {
9090 self . prev_host ( ) . number . saturating_add ( 1 )
9191 }
@@ -146,7 +146,7 @@ impl EnvTask {
146146 async fn task_fut ( self , sender : watch:: Sender < Option < SimEnv > > ) {
147147 let span = info_span ! ( "EnvTask::task_fut::init" ) ;
148148
149- let mut headers = match self . ru_provider . subscribe_blocks ( ) . await {
149+ let mut rollup_headers = match self . ru_provider . subscribe_blocks ( ) . await {
150150 Ok ( poller) => poller,
151151 Err ( err) => {
152152 span_error ! ( span, %err, "Failed to subscribe to blocks" ) ;
@@ -158,7 +158,7 @@ impl EnvTask {
158158 drop ( span) ;
159159
160160 while let Some ( rollup_header) =
161- headers . next ( ) . instrument ( info_span ! ( "EnvTask::task_fut::stream" ) ) . await
161+ rollup_headers . next ( ) . instrument ( info_span ! ( "EnvTask::task_fut::stream" ) ) . await
162162 {
163163 let host_block_number =
164164 self . config . constants . rollup_block_to_host_block_num ( rollup_header. number ) ;
@@ -170,7 +170,7 @@ impl EnvTask {
170170 span,
171171 error!( "error fetching previous host block - skipping block submission" )
172172 ) ;
173- let prev_host = opt_unwrap_or_continue ! (
173+ let host_header = opt_unwrap_or_continue ! (
174174 host_block_opt,
175175 span,
176176 warn!( "previous host block not found - skipping block submission" )
@@ -179,17 +179,17 @@ impl EnvTask {
179179 . inner ;
180180
181181 // Construct the block env using the previous block header
182- let signet_env = self . construct_block_env ( rollup_header. into ( ) ) ;
183- let host_env = self . construct_block_env ( prev_host ) ;
182+ let rollup_env = self . construct_block_env ( rollup_header. into ( ) ) ;
183+ let host_env = self . construct_block_env ( host_header ) ;
184184
185185 span_debug ! (
186186 span,
187- signet_env_number = signet_env . block_env. number. to:: <u64 >( ) ,
188- signet_env_basefee = signet_env . block_env. basefee,
189- "constructed signet block env"
187+ rollup_env_number = rollup_env . block_env. number. to:: <u64 >( ) ,
188+ rollup_env_basefee = rollup_env . block_env. basefee,
189+ "constructed block env"
190190 ) ;
191191
192- if sender. send ( Some ( SimEnv { span, rollup : signet_env , host : host_env } ) ) . is_err ( ) {
192+ if sender. send ( Some ( SimEnv { span, rollup : rollup_env , host : host_env } ) ) . is_err ( ) {
193193 // The receiver has been dropped, so we can stop the task.
194194 tracing:: debug!( "receiver dropped, stopping task" ) ;
195195 break ;
0 commit comments