src/connectivity/bluetooth/profiles/bt-hfp-hands-free/src/main.rs

// Copyright 2022 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

use anyhow::{Context, Error};
use fidl_fuchsia_bluetooth_hfp as fidl_hfp;
use fuchsia_component::server::{ServiceFs, ServiceObj};
use futures::StreamExt;
use tracing::{debug, error, info};

use crate::config::HandsFreeFeatureSupport;
use crate::hfp::Hfp;

mod config;
mod features;
mod hfp;
mod peer;
mod profile;
mod service_definition;

type HandsFreeFidlService = ServiceFs<ServiceObj<'static, fidl_hfp::HandsFreeRequestStream>>;

#[fuchsia::main(logging_tags = ["bt-hfp-hf"])]
async fn main() -> Result<(), Error> {
    debug!("Starting HFP Hands Free");

    let mut fs = ServiceFs::new();

    let _inspect_server_task = start_inspect();

    let feature_support = HandsFreeFeatureSupport::load()?;
    let (profile_client, profile_proxy) = profile::register_hands_free(feature_support)?;

    serve_fidl(&mut fs)?;

    let hfp = Hfp::new(feature_support, profile_client, profile_proxy, fs.fuse());
    let result = hfp.run().await;

    match result {
        Ok(()) => {
            info!("Profile client connection closed. Exiting.");
        }
        Err(e) => {
            error!("Error encountered running main HFP loop: {e}. Exiting.");
        }
    }

    Ok(())
}

fn start_inspect() -> Option<fuchsia_async::Task<()>> {
    // TODO(fxb/136817) Add inspect.
    let inspector = fuchsia_inspect::Inspector::default();
    inspect_runtime::publish(&inspector, inspect_runtime::PublishOptions::default())
}

fn serve_fidl(fs: &mut HandsFreeFidlService) -> Result<(), Error> {
    let _ = fs.dir("svc").add_fidl_service(|s: fidl_hfp::HandsFreeRequestStream| s);
    let _ = fs.take_and_serve_directory_handle().context("Failed to serve ServiceFs directory")?;

    Ok(())
}