// Copyright 2019 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.

//! Implementation of fuchsia.router.config

use {
    fidl_fuchsia_router_config::{RouterAdminRequestStream, RouterStateRequestStream},
    fuchsia_component::server::{ServiceFs, ServiceObjLocal},
    futures::future::Either,
    futures::stream::{self, Stream},
};

pub(super) enum IncomingFidlRequestStream {
    RouterAdmin(RouterAdminRequestStream),
    RouterState(RouterStateRequestStream),
}

/// Returns a `Stream` of [`IncomingFidlRequestStream`]s.
pub(super) fn new_stream<'a>(
    fs: &'a mut ServiceFs<ServiceObjLocal<'static, IncomingFidlRequestStream>>,
) -> Result<
    Either<
        impl Stream<Item = IncomingFidlRequestStream>,
        impl 'a + Stream<Item = IncomingFidlRequestStream>,
    >,
    anyhow::Error,
> {
    // NetworkManager's FIDL is currently disabled. We may eventually
    // remove the support for it from the codebase entirely, but for the
    // time being, we would still like to exercise the functionality
    // during testing to avoid bitrot.
    if !cfg!(test) {
        warn!("not serving FIDL server in non-test builds, the FIDL stream will never be ready");
        // We return a stream that is always pending so that the caller may assume that
        // the FIDL request stream is not expected to end (which is the case when for
        // non-test builds).
        return Ok(Either::Left(stream::pending()));
    }

    fs.dir("svc")
        .add_fidl_service(IncomingFidlRequestStream::RouterAdmin)
        .add_fidl_service(IncomingFidlRequestStream::RouterState);

    Ok(Either::Right(fs.take_and_serve_directory_handle()?))
}