Skip to content

Commit d8c71a3

Browse files
committed
feat: persist cch orders in rocksdb
1 parent 6151020 commit d8c71a3

File tree

12 files changed

+253
-173
lines changed

12 files changed

+253
-173
lines changed

crates/fiber-bin/src/main.rs

Lines changed: 11 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ use fnn::tasks::{
2121
use fnn::watchtower::{
2222
WatchtowerActor, WatchtowerMessage, DEFAULT_WATCHTOWER_CHECK_INTERVAL_SECONDS,
2323
};
24-
use fnn::{start_cch, start_network, Config, NetworkServiceEvent};
24+
use fnn::{start_cch, start_network, CchArgs, Config, NetworkServiceEvent};
2525
use jsonrpsee::http_client::HttpClientBuilder;
2626
use jsonrpsee::ws_client::{HeaderMap, HeaderValue};
2727
use ractor::{Actor, ActorRef};
@@ -307,14 +307,17 @@ pub async fn main() -> Result<(), ExitMessage> {
307307
info!("Starting cch");
308308
let ignore_startup_failure = cch_config.ignore_startup_failure;
309309
match start_cch(
310-
cch_config,
311-
new_tokio_task_tracker(),
312-
new_tokio_cancellation_token(),
310+
CchArgs {
311+
config: cch_config,
312+
tracker: new_tokio_task_tracker(),
313+
token: new_tokio_cancellation_token(),
314+
network_actor: network_actor
315+
.clone()
316+
.expect("Cch service requires network actor"),
317+
pubkey: node_public_key.expect("Cch service requires node public key"),
318+
store: store.clone(),
319+
},
313320
root_actor.get_cell(),
314-
network_actor
315-
.clone()
316-
.expect("Cch service requires network actor"),
317-
node_public_key.expect("Cch service requires node public key"),
318321
)
319322
.await
320323
{

0 commit comments

Comments
 (0)