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

use failure::Error;
use fidl::endpoints::DiscoverableService;
use fuchsia_component::client::connect_to_service;

pub trait ServiceConnect: Send + Sync {
    fn connect_to_service<S: DiscoverableService>(&self) -> Result<S::Proxy, Error>;
}

#[derive(Debug, Clone)]
pub struct ServiceConnector;

impl ServiceConnect for ServiceConnector {
    fn connect_to_service<S: DiscoverableService>(&self) -> Result<S::Proxy, Error> {
        connect_to_service::<S>()
    }
}

#[cfg(test)]
mod test {
    use super::*;
    use failure::{bail, ResultExt};
    use fuchsia_component::client::connect_to_service_at;
    use fuchsia_zircon as zx;

    #[derive(Debug, Clone)]
    pub struct NamespacedServiceConnector(String);

    impl NamespacedServiceConnector {
        pub fn bind(path: impl Into<String>) -> Result<(Self, zx::Channel), Error> {
            let path = path.into();

            let ns = fdio::Namespace::installed().context("installed namespace")?;
            let (service_channel, server_end) = zx::Channel::create().context("create channel")?;
            ns.bind(path.as_str(), service_channel).context("bind svc")?;

            Ok((NamespacedServiceConnector(path), server_end))
        }
    }

    impl ServiceConnect for NamespacedServiceConnector {
        fn connect_to_service<S: DiscoverableService>(&self) -> Result<S::Proxy, Error> {
            connect_to_service_at::<S>(self.0.as_str())
        }
    }

    #[derive(Debug, Clone)]
    pub struct FailServiceConnector;

    impl ServiceConnect for FailServiceConnector {
        fn connect_to_service<S: DiscoverableService>(&self) -> Result<S::Proxy, Error> {
            bail!("no services here")
        }
    }
}

#[cfg(test)]
pub(crate) use test::*;