Method start

etc/systems/src/l2/in_process_builder.rs:92–186

Starts an in-process builder node with the provided configuration.

(config: InProcessBuilderConfig)

impl InProcessBuilder {
    /// Starts an in-process builder node with the provided configuration.
    pub async fn start(config: InProcessBuilderConfig) -> Result<Self> {
        clear_otel_env_vars();

        let tempdir = std::env::temp_dir();
        let random_id = nanoid!();
        let data_path = tempdir.join(format!("in-process-builder.{random_id}"));
        let jwt_path = data_path.join("jwt.hex");

        std::fs::create_dir_all(&data_path).wrap_err("Failed to create data directory")?;
        std::fs::write(&jwt_path, config.jwt_secret.as_bytes().encode_hex().as_bytes())
            .wrap_err("Failed to write JWT secret")?;

        let runtime = RuntimeBuilder::new(RuntimeConfig::default()).build()?;

        let chain_spec = parse_genesis(&config.genesis_json)?;

        let flashblocks_port = config.flashblocks_port.unwrap_or_else(get_available_port);
        let builder_config = BuilderConfig {
            block_time: Duration::from_millis(2000),
            flashblocks_ws_addr: SocketAddr::new(Ipv4Addr::LOCALHOST.into(), flashblocks_port),
            flashblocks_interval: Duration::from_millis(200),
            ..Default::default()
        };

        let flashblocks_ws_addr = builder_config.flashblocks_ws_addr;

        let da_config = builder_config.da_config.clone();
        let gas_limit_config = builder_config.gas_limit_config.clone();

        let rollup_args = RollupArgs::default();

        let base_node = BaseNode::new(rollup_args.clone());

        let addons: base_node_runner::BaseAddOns<
            _,
            base_execution_rpc::BaseEthApiBuilder,
            base_node_core::BasePayloadValidatorBuilder,
        > = base_node
            .add_ons_builder()
            .with_sequencer(rollup_args.sequencer.clone())
            .with_da_config(da_config)
            .with_gas_limit_config(gas_limit_config)
            .build();

        let (db, _db_path) = create_test_db(&data_path)?;

        let node_config = create_node_config(chain_spec, &data_path, &jwt_path, &config)?;
        let p2p_port = node_config.network.port;

        let node_builder = NodeBuilder::new(node_config.clone())
            .with_database(db)
            .with_launch_context(runtime.clone())
            .with_types::<BaseNode>()
            .with_components(
                base_node
                    .components()
                    .pool(pool_component(&rollup_args))
                    .payload(FlashblocksServiceBuilder(builder_config)),