Function bootstrap

nodedb-cluster/src/bootstrap/bootstrap_fn.rs:23–86

Bootstrap a new cluster: this node is the founding member. `local_spki_pin` is the SHA-256 SPKI fingerprint of this node's own TLS leaf certificate; `None` in insecure transport mode. When present it is stored in the founding node's `NodeInfo` so that joining peers can pin our identity immediately.

(
    config: &ClusterConfig,
    catalog: &ClusterCatalog,
    local_spki_pin: Option<[u8; 32]>,
)

/// stored in the founding node's `NodeInfo` so that joining peers can pin our
/// identity immediately.
pub(super) fn bootstrap(
    config: &ClusterConfig,
    catalog: &ClusterCatalog,
    local_spki_pin: Option<[u8; 32]>,
) -> Result<ClusterState> {
    info!(
        node_id = config.node_id,
        addr = %config.listen_addr,
        groups = config.num_groups,
        "bootstrapping new cluster"
    );

    // Create topology with this node.
    let mut topology = ClusterTopology::new();
    topology.add_node(
        NodeInfo::new(config.node_id, config.listen_addr, NodeState::Active)
            .with_spki_pin(local_spki_pin),
    );

    // Create routing table: all groups on this single node.
    let routing = RoutingTable::uniform(
        config.num_groups,
        &[config.node_id],
        config.replication_factor.min(1), // Single node → RF=1.
    );

    // Create MultiRaft with all groups (single-node, no peers).
    let mut multi_raft = MultiRaft::new(config.node_id, routing.clone(), config.data_dir.clone())
        .with_election_timeout(config.election_timeout_min, config.election_timeout_max);
    for group_id in routing.group_ids() {
        multi_raft.add_group(group_id, vec![])?;
    }

    // Kick every group's election deadline into the past so the very
    // first tick of `RaftLoop::run` elects this node as leader of each
    // group. Otherwise an incoming `JoinRequest` that arrives before the
    // random 150–300 ms election timeout fires would hit a non-leader
    // node and be rejected. The bootstrap seed is by definition the only
    // voter in every group, so self-election is unambiguous.
    let now = std::time::Instant::now();
    for node in multi_raft.groups_mut().values_mut() {
        node.election_deadline_override(now - std::time::Duration::from_millis(1));
    }

    // Generate cluster ID and persist everything.
    let cluster_id = generate_cluster_id();
    catalog.save_cluster_id(cluster_id)?;
    catalog.save_cluster_settings(&ClusterSettings::from_config(config))?;
    catalog.save_topology(&topology)?;
    catalog.save_routing(&routing)?;

    info!(
        node_id = config.node_id,
        cluster_id,
        groups = config.num_groups,
        "cluster bootstrapped"
    );