// 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 {
    cm_types::Name,
    fidl_fidl_examples_routing_echo::{EchoRequest, EchoRequestStream},
    futures::TryStreamExt,
    lazy_static::lazy_static,
};

lazy_static! {
    pub static ref ECHO_CAPABILITY: Name = "builtin.Echo".parse().unwrap();
}

pub struct EchoProtocol;

impl EchoProtocol {
    pub async fn serve(mut stream: EchoRequestStream) -> Result<(), anyhow::Error> {
        while let Some(EchoRequest::EchoString { value, responder }) =
            stream.try_next().await.unwrap()
        {
            responder.send(value.as_ref().map(|s| &**s)).unwrap();
        }
        Ok(())
    }
}