garnet/bin/sys/component_manager/tests/routing_integration_test.rs

// 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 {
    fdio,
    fidl_fuchsia_sys::FileDescriptor,
    fuchsia_async as fasync,
    fuchsia_component::client::{self, LaunchOptions},
    fuchsia_runtime::HandleType,
    std::{
        fs::File,
        io::Read,
        str,
        time::{Duration, SystemTime},
    },
};

fn main() {
    run_test();
}

fn run_test() {
    let mut _executor = fasync::Executor::new().expect("error creating executor");
    let launcher = client::launcher().expect("failed to connect to launcher");
    let (mut pipe, pipe_handle) = make_pipe();
    let mut options = LaunchOptions::new();
    options.set_out(pipe_handle);
    let _app = client::launch_with_options(
        &launcher,
        "fuchsia-pkg://fuchsia.com/routing_integration_test#meta/component_manager.cmx".to_string(),
        Some(vec![
            "fuchsia-pkg://fuchsia.com/routing_integration_test#meta/echo_realm.cm".to_string()
        ]),
        options,
    )
    .expect("component manager failed to launch");
    read_from_pipe(&mut pipe, "Hippos rule!\n");
}

fn make_pipe() -> (std::fs::File, FileDescriptor) {
    match fdio::pipe_half() {
        Err(_) => panic!("failed to create pipe"),
        Ok((pipe, handle)) => {
            let pipe_handle = FileDescriptor {
                type0: HandleType::FileDescriptor as i32,
                type1: 0,
                type2: 0,
                handle0: Some(handle.into()),
                handle1: None,
                handle2: None,
            };
            (pipe, pipe_handle)
        }
    }
}

fn read_from_pipe(f: &mut File, msg: &str) {
    let mut buf = [0; 1024];
    let mut out = String::new();
    let start = SystemTime::now();
    while out != msg {
        let n = f.read(&mut buf).expect("failed to read pipe");
        out.push_str(str::from_utf8(&buf[0..n]).expect("string is not utf-8"));
        if start.elapsed().unwrap() > Duration::from_secs(60) {
            panic!("reading from pipe timed out");
        }
    }
}