blob: 34377f9961d7219cb0ecf2043221ceab21d80bfa [file] [log] [blame]
// Copyright 2020 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 {
fidl_fidl_examples_routing_echo as fecho, fidl_fidl_test_components as ftest,
fuchsia_async as fasync,
fuchsia_component::{client, server::ServiceFs},
futures::{StreamExt, TryStreamExt},
tracing::*,
};
#[fuchsia::main]
async fn main() {
let mut fs = ServiceFs::new_local();
fs.dir("svc").add_fidl_service(move |stream| {
fasync::Task::local(async move {
run_trigger_service(stream).await;
})
.detach();
});
fs.take_and_serve_directory_handle().expect("failed to serve outgoing directory");
fs.collect::<()>().await;
}
async fn run_trigger_service(mut stream: ftest::TriggerRequestStream) {
// Attempt to connect to the Echo capability (a component manager namespace capability)
let echo =
client::connect_to_protocol::<fecho::EchoMarker>().expect("error connecting to echo");
while let Some(event) = stream.try_next().await.expect("failed to serve trigger service") {
info!("Received trigger invocation");
let ftest::TriggerRequest::Run { responder } = event;
let args: Vec<_> = std::env::args().collect();
let echo_str = args[1..].join(" ");
let out = echo.echo_string(Some(&echo_str)).await.expect("echo_string failed");
let out = out.expect("empty echo result");
// Attempt to open test-pkg (a component manager namespace capability)
let file = io_util::open_file_in_namespace(
"/test-pkg/data/testdata",
io_util::OpenFlags::RIGHT_READABLE,
)
.expect("could not open testdata");
let contents = io_util::read_file(&file).await.expect("could not read file");
assert_eq!(contents, "Hello world!\n");
responder.send(&out).expect("failed to send trigger response");
info!("Sent trigger response");
}
}