Function serve

packages/server/src/main.rs:5881–5977

(
    port: u16,
    bind: IpAddr,
    advertise_host: Option<String>,
    client_root: Option<PathBuf>,
    video_codec: VideoCodecMode,
    low_latency: bool,
    server_kind: ServerKind,
    access

#[allow(clippy::too_many_arguments)]
async fn serve(
    port: u16,
    bind: IpAddr,
    advertise_host: Option<String>,
    client_root: Option<PathBuf>,
    video_codec: VideoCodecMode,
    low_latency: bool,
    server_kind: ServerKind,
    access_token: Option<String>,
    pairing_code: Option<String>,
) -> anyhow::Result<()> {
    let root = match client_root {
        Some(root) => root,
        None => default_client_root()?,
    };
    let config = Config::new(
        port,
        root,
        bind,
        advertise_host,
        server_kind,
        video_codec.as_env_value().to_owned(),
        low_latency,
        access_token,
        pairing_code,
    );
    let metrics = Arc::new(Metrics::default());
    let bridge = NativeBridge;
    let registry = SessionRegistry::new(bridge, metrics.clone());
    let logs = LogRegistry::default();
    let inspectors = InspectorHub::with_registry(InspectorRegistryAdvertisement::new(&config));
    let state = AppState {
        config: config.clone(),
        registry,
        logs,
        inspectors,
        metrics,
        performance: PerformanceRegistry::default(),
        stream_clients: Default::default(),
        simulator_inventory: Default::default(),
        accessibility_cache: Default::default(),
        android: Default::default(),
    };

    let http_router = app_router(
        state.clone(),
        config.client_root.clone(),
        config.access_token.clone(),
    );
    let http_listener = tokio::net::TcpListener::bind(config.http_addr())
        .await
        .with_context(|| format!("bind HTTP listener on {}", config.http_addr()))?;
    let health_heartbeat = Arc::new(AtomicU64::new(now_secs()));
    start_server_health_watchdog(config.http_addr(), health_heartbeat.clone());
    let _bonjour_advertisement = BonjourAdvertisement::start(&config);

    info!("HTTP listening on http://{}", config.http_addr());
    info!("Serving client from {}", config.client_root.display());