@@ -170,98 +170,3 @@ impl Actor {
170
170
self . ballot . lock ( ) . await . draw ( block_hash)
171
171
}
172
172
}
173
-
174
- // #[cfg(test)]
175
- // mod tests {
176
- // use super::*;
177
- // use alloy_primitives::Address;
178
- // use raiko_lib::{
179
- // consts::SupportedChainSpecs,
180
- // input::BlobProofType,
181
- // primitives::{ChainId, B256},
182
- // proof_type::ProofType,
183
- // };
184
- // use raiko_reqpool::{
185
- // memory_pool, RequestEntity, RequestKey, SingleProofRequestEntity, SingleProofRequestKey,
186
- // StatusWithContext,
187
- // };
188
- // use std::collections::HashMap;
189
- // use tokio::sync::mpsc;
190
-
191
- // #[tokio::test]
192
- // async fn test_pause_sets_is_paused_flag() {
193
- // let pool = memory_pool("test_pause_sets_is_paused_flag");
194
- // let actor = Actor::new(
195
- // pool,
196
- // Ballot::default(),
197
- // ProofRequestOpt::default(),
198
- // SupportedChainSpecs::default(),
199
- // );
200
-
201
- // assert!(!actor.is_paused(), "Actor should not be paused initially");
202
-
203
- // actor.pause().await.expect("Pause should succeed");
204
- // assert!(
205
- // actor.is_paused(),
206
- // "Actor should be paused after calling pause()"
207
- // );
208
- // }
209
-
210
- // #[tokio::test]
211
- // async fn test_act_sends_action_and_returns_response() {
212
- // let pool = memory_pool("test_act_sends_action_and_returns_response");
213
- // let actor = Actor::new(
214
- // pool,
215
- // Ballot::default(),
216
- // ProofRequestOpt::default(),
217
- // SupportedChainSpecs::default(),
218
- // );
219
-
220
- // // Create a test action
221
- // let request_key = RequestKey::SingleProof(SingleProofRequestKey::new(
222
- // ChainId::default(),
223
- // 1,
224
- // B256::default(),
225
- // ProofType::default(),
226
- // "test_prover".to_string(),
227
- // ));
228
- // let request_entity = RequestEntity::SingleProof(SingleProofRequestEntity::new(
229
- // 1,
230
- // 1,
231
- // "test_network".to_string(),
232
- // "test_l1_network".to_string(),
233
- // B256::default(),
234
- // Address::default(),
235
- // ProofType::default(),
236
- // BlobProofType::default(),
237
- // HashMap::new(),
238
- // ));
239
- // let test_action = Action::Prove {
240
- // request_key: request_key.clone(),
241
- // request_entity,
242
- // start_time: chrono::Utc::now(),
243
- // };
244
-
245
- // // Spawn a task to handle the action and send back a response
246
- // let status = StatusWithContext::new_registered();
247
- // let status_clone = status.clone();
248
- // let handle = tokio::spawn(async move {
249
- // let (action, resp_tx) = action_rx.recv().await.expect("Should receive action");
250
- // // Verify we received the expected action
251
- // assert_eq!(action.request_key(), &request_key);
252
- // // Send back a mock response with Registered status
253
- // resp_tx
254
- // .send(Ok(status_clone))
255
- // .expect("Should send response");
256
- // });
257
-
258
- // // Send the action and wait for response
259
- // let result = actor.act(test_action).await;
260
-
261
- // // Make sure we got back an Ok response
262
- // assert_eq!(result, Ok(status), "Should receive successful response");
263
-
264
- // // Wait for the handler to complete
265
- // handle.await.expect("Handler should complete");
266
- // }
267
- // }
0 commit comments