Function start_server

crates/hyperqueue/src/client/commands/server.rs:172–228

(gsettings: &GlobalSettings, opts: ServerStartOpts)

}

async fn start_server(gsettings: &GlobalSettings, opts: ServerStartOpts) -> anyhow::Result<()> {
    let access_file: Option<FullAccessRecord> = opts
        .access_file
        .map(|path| load_access_record(path.as_path()))
        .transpose()?;

    let worker_host = opts
        .host
        .clone()
        .or_else(|| access_file.as_ref().map(|a| a.worker_host().to_string()))
        .unwrap_or_else(|| get_hostname(None));

    let client_host = opts
        .host
        .or_else(|| access_file.as_ref().map(|a| a.client_host().to_string()))
        .unwrap_or_else(|| get_hostname(None));

    let worker_port = opts
        .worker_port
        .or(access_file.as_ref().map(|a| a.worker_port()));
    let client_port = opts
        .client_port
        .or(access_file.as_ref().map(|a| a.client_port()));

    let server_cfg = ServerConfig {
        client_host,
        worker_host,
        idle_timeout: opts.idle_timeout,
        client_port,
        worker_port,
        journal_path: opts.journal,
        journal_flush_period: opts.journal_flush_period,
        worker_secret_key: access_file
            .as_ref()
            .map(|a| a.worker_key().cloned())
            .unwrap_or_else(|| {
                if opts.disable_worker_authentication_and_encryption {
                    None
                } else {
                    Some(Arc::new(generate_key()))
                }
            }),
        client_secret_key: access_file
            .as_ref()
            .map(|a| a.client_key().cloned())
            .unwrap_or_else(|| {
                if opts.disable_client_authentication_and_encryption {
                    None
                } else {
                    Some(Arc::new(generate_key()))
                }
            }),
        server_uid: access_file.as_ref().map(|a| a.server_uid().to_string()),
    };

    init_hq_server(gsettings, server_cfg).await
}