(
flags: &RunFlags,
key_store: &KeyStore<PrivateKey>,
committee: &[Validator],
)
| 763 | .await |
| 764 | }) |
| 765 | } |
| 766 | |
| 767 | async fn run_node_local_inner( |
| 768 | context: tokio::Context, |
| 769 | flags: RunFlags, |
| 770 | key_store: KeyStore<PrivateKey>, |
| 771 | checkpoint: Option<ConsensusState>, |
| 772 | checkpoint_parent_block: Option<Block>, |
| 773 | ) -> anyhow::Result<()> { |
| 774 | let context = context.with_label("summit_cw"); |
| 775 | |
| 776 | let genesis = acquire_genesis(&context, &flags).await; |
| 777 | |
| 778 | let mut committee: Vec<Validator> = genesis.get_validators().expect("Failed to get validators"); |
| 779 | committee.sort_by(|lhs, rhs| lhs.node_public_key.cmp(&rhs.node_public_key)); |
| 780 | |
| 781 | let initial_state = get_initial_state(&genesis, &committee, checkpoint); |
| 782 | let peers = initial_state.get_validator_keys(); |
| 783 | |
| 784 | let engine_ipc_path = |
| 785 | get_expanded_path(&flags.engine_ipc_path).expect("failed to expand engine ipc path"); |
| 786 | |
| 787 | #[allow(unused)] |
| 788 | #[cfg(feature = "bench")] |
| 789 | let engine_client = { |
| 790 | let block_dir = flags |
| 791 | .bench_block_dir |
| 792 | .as_ref() |
no test coverage detected