Google Git
Sign in
fuchsia / fuchsia / e6947a4884fd9b273effb980afcf828bd8d5f4c5 / . / src / lib / fuchsia-component-test / src / lib.rs
blob: 9251b622ab78847bbc6f62988602d2a0e0c7c127 [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 {
crate::{error::Error, local_component_runner::LocalComponentRunnerBuilder},
anyhow::{format_err, Context as _},
cm_rust::{self, FidlIntoNative, NativeIntoFidl},
component_events::{
events::{Event as CeEvent, EventSource, EventSubscription, Started},
matcher::EventMatcher,
},
fidl::endpoints::{
self, create_proxy, ClientEnd, DiscoverableProtocolMarker, Proxy, ServerEnd, ServiceMarker,
},
fidl_fuchsia_component as fcomponent, fidl_fuchsia_component_decl as fdecl,
fidl_fuchsia_component_test as ftest, fidl_fuchsia_data as fdata, fidl_fuchsia_io as fio,
fidl_fuchsia_mem as fmem, fidl_fuchsia_sys2 as fsys, fuchsia_async as fasync,
fuchsia_component::client as fclient,
fuchsia_zircon as zx,
futures::{future::BoxFuture, lock::Mutex, FutureExt, TryFutureExt},
maplit::hashmap,
rand::Rng,
std::{
collections::HashMap,
fmt::{self, Display, Formatter},
sync::Arc,
},
tracing::*,
};
pub mod new {
pub use super::*;
}
/// The default name of the child component collection that contains built topologies.
pub const DEFAULT_COLLECTION_NAME: &'static str = "realm_builder";
const REALM_BUILDER_SERVER_CHILD_NAME: &'static str = "realm_builder_server";
pub mod error;
mod local_component_runner;
pub use local_component_runner::LocalComponentHandles;
/// The source or destination of a capability route.
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub struct Ref {
value: RefInner,
/// The path to the realm this ref exists in, if known. When set, this ref may not be used
/// outside of the realm it is scoped to.
scope: Option<Vec<String>>,
}
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
enum RefInner {
Capability(String),
Child(String),
Collection(String),
Debug,
Framework,
Parent,
Self_,
}
impl Ref {
pub fn capability(name: impl Into<String>) -> Ref {
Ref { value: RefInner::Capability(name.into()), scope: None }
}
pub fn child(name: impl Into<String>) -> Ref {
Ref { value: RefInner::Child(name.into()), scope: None }
}
pub fn collection(name: impl Into<String>) -> Ref {
Ref { value: RefInner::Collection(name.into()), scope: None }
}
pub fn debug() -> Ref {
Ref { value: RefInner::Debug, scope: None }
}
pub fn framework() -> Ref {
Ref { value: RefInner::Framework, scope: None }
}
pub fn parent() -> Ref {
Ref { value: RefInner::Parent, scope: None }
}
pub fn self_() -> Ref {
Ref { value: RefInner::Self_, scope: None }
}
fn check_scope(&self, realm_scope: &Vec<String>) -> Result<(), Error> {
if let Some(ref_scope) = self.scope.as_ref() {
if ref_scope != realm_scope {
return Err(Error::RefUsedInWrongRealm(
self.clone(),
realm_scope.join("/").to_string(),
));
}
}
Ok(())
}
}
impl Into<fdecl::Ref> for Ref {
fn into(self) -> fdecl::Ref {
match self.value {
RefInner::Capability(name) => fdecl::Ref::Capability(fdecl::CapabilityRef { name }),
RefInner::Child(name) => fdecl::Ref::Child(fdecl::ChildRef { name, collection: None }),
RefInner::Collection(name) => fdecl::Ref::Collection(fdecl::CollectionRef { name }),
RefInner::Debug => fdecl::Ref::Debug(fdecl::DebugRef {}),
RefInner::Framework => fdecl::Ref::Framework(fdecl::FrameworkRef {}),
RefInner::Parent => fdecl::Ref::Parent(fdecl::ParentRef {}),
RefInner::Self_ => fdecl::Ref::Self_(fdecl::SelfRef {}),
}
}
}
/// A SubRealmBuilder may be referenced as a child in a route, in order to route a capability to or
/// from the sub realm.
impl From<&SubRealmBuilder> for Ref {
fn from(input: &SubRealmBuilder) -> Ref {
// It should not be possible for library users to access the top-level SubRealmBuilder,
// which means that this realm_path.last() will always return Some
let mut scope = input.realm_path.clone();
let child_name = scope.pop().expect("this should be impossible");
Ref { value: RefInner::Child(child_name), scope: Some(scope) }
}
}
impl From<&ChildRef> for Ref {
fn from(input: &ChildRef) -> Ref {
Ref { value: RefInner::Child(input.name.clone()), scope: input.scope.clone() }
}
}
impl Display for Ref {
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
match &self.value {
RefInner::Capability(name) => {
write!(f, "capability {}", name)?;
}
RefInner::Child(name) => {
write!(f, "child {}", name)?;
}
RefInner::Collection(name) => {
write!(f, "collection {}", name)?;
}
RefInner::Debug => {
write!(f, "debug")?;
}
RefInner::Framework => {
write!(f, "framework")?;
}
RefInner::Parent => {
write!(f, "parent")?;
}
RefInner::Self_ => {
write!(f, "self")?;
}
}
if let Some(ref_scope) = self.scope.as_ref() {
write!(f, " in realm {:?}", ref_scope.join("/"))?;
}
Ok(())
}
}
/// A reference to a child in a realm. This struct will be returned when a child is added to a
/// realm, and may be used in subsequent calls to `RealmBuilder` or `SubRealmBuilder` to reference
/// the child that was added.
#[derive(Debug, Clone, PartialEq)]
pub struct ChildRef {
name: String,
scope: Option<Vec<String>>,
}
impl ChildRef {
fn new(name: String, scope: Vec<String>) -> Self {
ChildRef { name, scope: Some(scope) }
}
fn check_scope(&self, realm_scope: &Vec<String>) -> Result<(), Error> {
if let Some(ref_scope) = self.scope.as_ref() {
if ref_scope != realm_scope {
return Err(Error::RefUsedInWrongRealm(
self.into(),
realm_scope.join("/").to_string(),
));
}
}
Ok(())
}
}
impl From<String> for ChildRef {
fn from(input: String) -> ChildRef {
ChildRef { name: input, scope: None }
}
}
impl From<&str> for ChildRef {
fn from(input: &str) -> ChildRef {
ChildRef { name: input.to_string(), scope: None }
}
}
impl From<&SubRealmBuilder> for ChildRef {
fn from(input: &SubRealmBuilder) -> ChildRef {
// It should not be possible for library users to access the top-level SubRealmBuilder,
// which means that this realm_path.last() will always return Some
let mut scope = input.realm_path.clone();
let child_name = scope.pop().expect("this should be impossible");
ChildRef { name: child_name, scope: Some(scope) }
}
}
impl From<&ChildRef> for ChildRef {
fn from(input: &ChildRef) -> ChildRef {
input.clone()
}
}
/// A capability, which may be routed between different components with a `Route`.
pub struct Capability;
impl Capability {
/// Creates a new protocol capability, whose name is derived from a protocol marker.
pub fn protocol<P: DiscoverableProtocolMarker>() -> ProtocolCapability {
Self::protocol_by_name(P::PROTOCOL_NAME.to_string())
}
/// Creates a new protocol capability.
pub fn protocol_by_name(name: impl Into<String>) -> ProtocolCapability {
ProtocolCapability {
name: name.into(),
as_: None,
type_: fdecl::DependencyType::Strong,
path: None,
}
}
/// Creates a new directory capability.
pub fn directory(name: impl Into<String>) -> DirectoryCapability {
DirectoryCapability {
name: name.into(),
as_: None,
type_: fdecl::DependencyType::Strong,
rights: None,
subdir: None,
path: None,
}
}
/// Creates a new storage capability.
pub fn storage(name: impl Into<String>) -> StorageCapability {
StorageCapability { name: name.into(), as_: None, path: None }
}
/// Creates a new service capability, whose name is derived from a protocol marker.
pub fn service<S: ServiceMarker>() -> ServiceCapability {
Self::service_by_name(S::SERVICE_NAME.to_string())
}
/// Creates a new service capability.
pub fn service_by_name(name: impl Into<String>) -> ServiceCapability {
ServiceCapability { name: name.into(), as_: None, path: None }
}
/// Creates a new event capability.
pub fn event(event: Event) -> EventCapability {
EventCapability { event }
}
}
/// A protocol capability, which may be routed between components. Created by
/// `Capability::protocol`.
#[derive(Debug, Clone, PartialEq)]
pub struct ProtocolCapability {
name: String,
as_: Option<String>,
type_: fdecl::DependencyType,
path: Option<String>,
}
impl ProtocolCapability {
/// The name the targets will see the directory capability as.
pub fn as_(mut self, as_: impl Into<String>) -> Self {
self.as_ = Some(as_.into());
self
}
/// Marks any offers involved in this route as "weak", which will cause this route to be
/// ignored when determining shutdown ordering.
pub fn weak(mut self) -> Self {
self.type_ = fdecl::DependencyType::Weak;
self
}
/// The path at which this protocol capability will be provided or used. Only relevant if the
/// route's source or target is a legacy or local component, as these are the only components
/// that realm builder will generate a modern component manifest for.
pub fn path(mut self, path: impl Into<String>) -> Self {
self.path = Some(path.into());
self
}
}
impl Into<ftest::Capability> for ProtocolCapability {
fn into(self) -> ftest::Capability {
ftest::Capability::Protocol(ftest::Protocol {
name: Some(self.name),
as_: self.as_,
type_: Some(self.type_),
path: self.path,
..ftest::Protocol::EMPTY
})
}
}
/// A directory capability, which may be routed between components. Created by
/// `Capability::directory`.
#[derive(Debug, Clone, PartialEq)]
pub struct DirectoryCapability {
name: String,
as_: Option<String>,
type_: fdecl::DependencyType,
rights: Option<fio::Operations>,
subdir: Option<String>,
path: Option<String>,
}
impl DirectoryCapability {
/// The name the targets will see the directory capability as.
pub fn as_(mut self, as_: impl Into<String>) -> Self {
self.as_ = Some(as_.into());
self
}
/// Marks any offers involved in this route as "weak", which will cause this route to be
/// ignored when determining shutdown ordering.
pub fn weak(mut self) -> Self {
self.type_ = fdecl::DependencyType::Weak;
self
}
/// The rights the target will be allowed to use when accessing the directory.
pub fn rights(mut self, rights: fio::Operations) -> Self {
self.rights = Some(rights);
self
}
/// The sub-directory of the directory that the target will be given access to.
pub fn subdir(mut self, subdir: impl Into<String>) -> Self {
self.subdir = Some(subdir.into());
self
}
/// The path at which this directory will be provided or used. Only relevant if the route's
/// source or target is a local component.
pub fn path(mut self, path: impl Into<String>) -> Self {
self.path = Some(path.into());
self
}
}
impl Into<ftest::Capability> for DirectoryCapability {
fn into(self) -> ftest::Capability {
ftest::Capability::Directory(ftest::Directory {
name: Some(self.name),
as_: self.as_,
type_: Some(self.type_),
rights: self.rights,
subdir: self.subdir,
path: self.path,
..ftest::Directory::EMPTY
})
}
}
/// A storage capability, which may be routed between components. Created by
/// `Capability::storage`.
#[derive(Debug, Clone, PartialEq)]
pub struct StorageCapability {
name: String,
as_: Option<String>,
path: Option<String>,
}
impl StorageCapability {
/// The name the targets will see the storage capability as.
pub fn as_(mut self, as_: impl Into<String>) -> Self {
self.as_ = Some(as_.into());
self
}
/// The path at which this storage will be used. Only relevant if the route's target is a local
/// component.
pub fn path(mut self, path: impl Into<String>) -> Self {
self.path = Some(path.into());
self
}
}
impl Into<ftest::Capability> for StorageCapability {
fn into(self) -> ftest::Capability {
ftest::Capability::Storage(ftest::Storage {
name: Some(self.name),
as_: self.as_,
path: self.path,
..ftest::Storage::EMPTY
})
}
}
/// A service capability, which may be routed between components. Created by
/// `Capability::service`.
#[derive(Debug, Clone, PartialEq)]
pub struct ServiceCapability {
name: String,
as_: Option<String>,
path: Option<String>,
}
impl ServiceCapability {
/// The name the targets will see the service capability as.
pub fn as_(mut self, as_: impl Into<String>) -> Self {
self.as_ = Some(as_.into());
self
}
/// The path at which this service capability will be provided or used. Only relevant if the
/// route's source or target is a local component, as these are the only components that realm
/// builder will generate a modern component manifest for.
pub fn path(mut self, path: impl Into<String>) -> Self {
self.path = Some(path.into());
self
}
}
impl Into<ftest::Capability> for ServiceCapability {
fn into(self) -> ftest::Capability {
ftest::Capability::Service(ftest::Service {
name: Some(self.name),
as_: self.as_,
path: self.path,
..ftest::Service::EMPTY
})
}
}
#[derive(Debug, Clone, PartialEq)]
pub struct EventCapability {
event: Event,
}
impl Into<ftest::Capability> for EventCapability {
fn into(self) -> ftest::Capability {
ftest::Capability::Event(ftest::Event {
name: Some(self.event.name().to_string()),
as_: None,
filter: self.event.filter().map(NativeIntoFidl::native_into_fidl),
..ftest::Event::EMPTY
})
}
}
/// A route of one or more capabilities from one point in the realm to one or more targets.
#[derive(Debug, Clone, PartialEq)]
pub struct Route {
capabilities: Vec<ftest::Capability>,
from: Option<Ref>,
to: Vec<Ref>,
}
impl Route {
pub fn new() -> Self {
Self { capabilities: vec![], from: None, to: vec![] }
}
/// Adds a capability to this route. Must be called at least once.
pub fn capability(mut self, capability: impl Into<ftest::Capability>) -> Self {
self.capabilities.push(capability.into());
self
}
/// Adds a source to this route. Must be called exactly once. Will panic if called a second
/// time.
pub fn from(mut self, from: impl Into<Ref>) -> Self {
if self.from.is_some() {
panic!("from is already set for this route");
}
self.from = Some(from.into());
self
}
/// Adds a target to this route. Must be called at least once.
pub fn to(mut self, to: impl Into<Ref>) -> Self {
self.to.push(to.into());
self
}
}
/// A running instance of a created realm. When this struct is dropped the realm is destroyed,
/// along with any components that were in the realm.
pub struct RealmInstance {
/// The root component of this realm instance, which can be used to access exposed capabilities
/// from the realm.
pub root: ScopedInstance,
// We want to ensure that the local component runner remains alive for as long as the realm
// exists, so the ScopedInstance is bundled up into a struct along with the local component
// runner's task.
local_component_runner_task: Option<fasync::Task<()>>,
}
impl Drop for RealmInstance {
/// To ensure local components are shutdown in an orderly manner (i.e. after their dependent
/// clients) upon `drop`, keep the local_component_runner_task alive in an async task until the
/// destroy_waiter synchronously destroys the realm.
fn drop(&mut self) {
if !self.root.destroy_waiter_taken() {
let destroy_waiter = self.root.take_destroy_waiter();
let local_component_runner_task = self.local_component_runner_task.take();
fasync::Task::spawn(async move {
// move the local component runner task into this block
let _local_component_runner_task = local_component_runner_task;
// There's nothing to be done if we fail to destroy the child, perhaps someone
// else already destroyed it for us. Ignore any error we could get here.
let _ = destroy_waiter.await;
})
.detach();
}
}
}
impl RealmInstance {
/// Destroys the realm instance, returning only once realm destruction is complete.
///
/// This function can be useful to call when it's important to ensure a realm accessing a
/// global resource is stopped before proceeding, or to ensure that realm destruction doesn't
/// race with process (and thus local component implementations) termination.
pub async fn destroy(mut self) -> Result<(), Error> {
if self.root.destroy_waiter_taken() {
return Err(Error::DestroyWaiterTaken);
}
let _local_component_runner_task = self.local_component_runner_task.take();
let destroy_waiter = self.root.take_destroy_waiter();
drop(self);
destroy_waiter.await.map_err(Error::FailedToDestroyChild)?;
Ok(())
}
/// Connects to the `fuchsia.sys2.LifecycleController` protocol exposed by a nested
/// component manager and attempts to start the root component. This should only be used
/// when a realm is built in a nested component manager in debug mode.
pub async fn start_component_tree(&self) -> Result<(), Error> {
let lifecycle_controller = self
.root
.connect_to_protocol_at_exposed_dir::<fsys::LifecycleControllerMarker>()
.map_err(|e| Error::CannotStartRootComponent(e))?;
lifecycle_controller.start("./").await?.map_err(|e| {
Error::CannotStartRootComponent(format_err!("received error status: {:?}", e))
})?;
Ok(())
}
}
/// The `RealmBuilder` struct can be used to assemble and create a component realm at runtime.
/// For more information on what can be done with this struct, please see the [documentation on
/// fuchsia.dev](https://fuchsia.dev/fuchsia-src/development/testing/components/realm_builder)
#[derive(Debug)]
pub struct RealmBuilder {
root_realm: SubRealmBuilder,
builder_proxy: ftest::BuilderProxy,
local_component_runner_builder: LocalComponentRunnerBuilder,
collection_name: String,
}
impl RealmBuilder {
/// Creates a new, empty Realm Builder.
pub async fn new() -> Result<Self, Error> {
Self::create(DEFAULT_COLLECTION_NAME.to_string(), None).await
}
/// Creates a new Realm Builder, and loads the contents of the manifest located at
/// `relative_url` into the realm.
pub async fn from_relative_url(relative_url: impl Into<String>) -> Result<Self, Error> {
Self::create(DEFAULT_COLLECTION_NAME.to_string(), Some(relative_url.into())).await
}
/// Creates a new Realm Builder, and loads the contents of the manifest located at
/// `relative_url` into the realm. When `RealmBuilder::build` is called, the realm will be
/// launched in the collection named `collection_name`.
pub async fn from_relative_url_with_collection(
relative_url: impl Into<String>,
collection_name: impl Into<String>,
) -> Result<Self, Error> {
Self::create(collection_name.into(), Some(relative_url.into())).await
}
/// Creates a new, empty Realm Builder. When `RealmBuilder::build` is called, the realm will be
/// launched in the collection named `collection_name`.
pub async fn new_with_collection(collection_name: impl Into<String>) -> Result<Self, Error> {
Self::create(collection_name.into(), None).await
}
async fn create(collection_name: String, relative_url: Option<String>) -> Result<Self, Error> {
let realm_proxy = fclient::connect_to_protocol::<fcomponent::RealmMarker>()
.map_err(Error::ConnectToServer)?;
let (exposed_dir_proxy, exposed_dir_server_end) =
endpoints::create_proxy::<fio::DirectoryMarker>()
.expect("failed to create channel pair");
realm_proxy
.open_exposed_dir(
&mut fdecl::ChildRef {
name: REALM_BUILDER_SERVER_CHILD_NAME.to_string(),
collection: None,
},
exposed_dir_server_end,
)
.await?
.map_err(|e| {
Error::ConnectToServer(format_err!("failed to open exposed dir: {:?}", e))
})?;
let realm_builder_factory_proxy = fclient::connect_to_protocol_at_dir_root::<
ftest::RealmBuilderFactoryMarker,
>(&exposed_dir_proxy)
.map_err(Error::ConnectToServer)?;
let pkg_dir_proxy = fuchsia_fs::open_directory_in_namespace(
"/pkg",
fuchsia_fs::OpenFlags::RIGHT_READABLE | fuchsia_fs::OpenFlags::RIGHT_EXECUTABLE,
)
.map_err(Error::FailedToOpenPkgDir)?;
let (realm_proxy, realm_server_end) =
create_proxy::<ftest::RealmMarker>().expect("failed to create channel pair");
let (builder_proxy, builder_server_end) =
create_proxy::<ftest::BuilderMarker>().expect("failed to create channel pair");
match relative_url {
Some(relative_url) => {
realm_builder_factory_proxy
.create_from_relative_url(
ClientEnd::from(pkg_dir_proxy.into_channel().unwrap().into_zx_channel()),
&relative_url,
realm_server_end,
builder_server_end,
)
.await??;
}
None => {
realm_builder_factory_proxy
.create(
ClientEnd::from(pkg_dir_proxy.into_channel().unwrap().into_zx_channel()),
realm_server_end,
builder_server_end,
)
.await??;
}
}
Self::build_struct(realm_proxy, builder_proxy, collection_name)
}
fn build_struct(
realm_proxy: ftest::RealmProxy,
builder_proxy: ftest::BuilderProxy,
collection_name: String,
) -> Result<Self, Error> {
let local_component_runner_builder = LocalComponentRunnerBuilder::new();
Ok(Self {
root_realm: SubRealmBuilder {
realm_proxy,
realm_path: vec![],
local_component_runner_builder: local_component_runner_builder.clone(),
has_legacy_children: Arc::new(Mutex::new(false)),
},
builder_proxy,
local_component_runner_builder,
collection_name,
})
}
/// Initializes the realm, but doesn't create it. Returns the root URL and the task managing
/// local component implementations. The caller should pass the URL into
/// `fuchsia.component.Realm#CreateChild`, and keep the task alive until after
/// `fuchsia.component.Realm#DestroyChild` has been called.
async fn initialize(self) -> Result<(String, fasync::Task<()>), Error> {
let (component_runner_client_end, local_component_runner_task) =
self.local_component_runner_builder.build().await?;
let root_url = self.builder_proxy.build(component_runner_client_end).await??;
Ok((root_url, local_component_runner_task))
}
/// Creates this realm in a child component collection, using an autogenerated name for the
/// instance. By default this happens in the [`DEFAULT_COLLECTION_NAME`] collection.
///
/// After creation it connects to the fuchsia.component.Binder protocol exposed from the root
/// realm, which gets added automatically by the server.
pub async fn build(self) -> Result<RealmInstance, Error> {
let (component_runner_client_end, local_component_runner_task) =
self.local_component_runner_builder.build().await?;
let root_url = self.builder_proxy.build(component_runner_client_end).await??;
let root = ScopedInstance::new(self.collection_name, root_url)
.await
.map_err(Error::FailedToCreateChild)?;
root.connect_to_binder().map_err(Error::FailedToBind)?;
Ok(RealmInstance { root, local_component_runner_task: Some(local_component_runner_task) })
}
/// Creates this realm in a child component collection. By default this happens in the
/// [`DEFAULT_COLLECTION_NAME`] collection.
pub async fn build_with_name(
self,
child_name: impl Into<String>,
) -> Result<RealmInstance, Error> {
let (component_runner_client_end, local_component_runner_task) =
self.local_component_runner_builder.build().await?;
let root_url = self.builder_proxy.build(component_runner_client_end).await??;
let root = ScopedInstance::new_with_name(child_name.into(), self.collection_name, root_url)
.await
.map_err(Error::FailedToCreateChild)?;
root.connect_to_binder().map_err(Error::FailedToBind)?;
Ok(RealmInstance { root, local_component_runner_task: Some(local_component_runner_task) })
}
/// Launches a nested component manager which will run the created realm (along with any local
/// components in the realm). This component manager _must_ be referenced by a relative URL.
///
/// Note that any routes with a source of `parent` in the root realm will need to also be used
/// in component manager's manifest and listed as a namespace capability in its config.
///
/// Note that any routes with a target of `parent` from the root realm will result in exposing
/// the capability to component manager, which is rather useless by itself. Component manager
/// does expose the hub though, which could be traversed to find an exposed capability.
pub async fn build_in_nested_component_manager(
self,
component_manager_relative_url: &str,
) -> Result<RealmInstance, Error> {
if *self.root_realm.has_legacy_children.lock().await {
return Err(Error::LegacyChildrenUnsupportedInNestedComponentManager);
}
let collection_name = self.collection_name.clone();
let (root_url, local_component_runner_task) = self.initialize().await?;
// We now have a root URL we could create in a collection, but instead we want to launch a
// component manager and give that component manager this root URL. That flag is set with
// command line arguments, so we can't just launch an unmodified component manager.
//
// Open a new connection to the realm builder server to begin creating a new realm. This
// new realm will hold a single component: component manager. We will modify its manifest
// such that the root component URL is set to the root_url we just obtained, and the nested
// component manager will then fetch the manifest from realm builder itself.
//
// Note this presumes that component manager is pointed to a config with the following line:
//
// realm_builder_resolver_and_runner: "namespace",
let component_manager_realm = RealmBuilder::new().await?;
component_manager_realm
.add_child(
"component_manager",
component_manager_relative_url,
ChildOptions::new().eager(),
)
.await?;
let mut component_manager_decl =
component_manager_realm.get_component_decl("component_manager").await?;
match **component_manager_decl
.program
.as_mut()
.expect("component manager's manifest is lacking a program section")
.info
.entries
.get_or_insert(vec![])
.iter_mut()
.find(|e| e.key == "args")
.expect("component manager's manifest doesn't specify a config")
.value
.as_mut()
.expect("component manager's manifest has a malformed 'args' section") {
fdata::DictionaryValue::StrVec(ref mut v) => v.push(root_url),
_ => panic!("component manager's manifest has a single value for 'args', but we were expecting a vector"),
}
component_manager_realm
.replace_component_decl("component_manager", component_manager_decl)
.await?;
component_manager_realm
.add_route(
Route::new()
.capability(Capability::protocol_by_name(
"fuchsia.component.resolver.RealmBuilder",
))
.capability(Capability::protocol_by_name(
"fuchsia.component.runner.RealmBuilder",
))
.capability(Capability::protocol_by_name("fuchsia.logger.LogSink"))
.capability(Capability::protocol_by_name("fuchsia.process.Launcher"))
.capability(Capability::protocol_by_name("fuchsia.sys.Loader"))
.capability(Capability::protocol_by_name("fuchsia.tracing.provider.Registry"))
.from(Ref::parent())
.to(Ref::child("component_manager")),
)
.await?;
component_manager_realm
.add_route(
Route::new()
.capability(Capability::directory("hub").path("/hub").rights(fio::RW_STAR_DIR))
.capability(Capability::protocol_by_name("fuchsia.sys2.LifecycleController"))
.capability(Capability::protocol_by_name("fuchsia.sys2.EventSource"))
.from(Ref::child("component_manager"))
.to(Ref::parent()),
)
.await?;
let (component_manager_url, _) = component_manager_realm.initialize().await?;
let root = ScopedInstance::new(collection_name, component_manager_url)
.await
.map_err(Error::FailedToCreateChild)?;
root.connect_to_binder().map_err(Error::FailedToBind)?;
Ok(RealmInstance { root, local_component_runner_task: Some(local_component_runner_task) })
}
// Note: the RealmBuilder functions below this line all forward to the implementations in
// SubRealmBuilder. It would be easier to hold these definitions in a common trait that both
// structs implemented, but then anyone using RealmBuilder would have to use the trait
// regardless of if they want sub-realm support or not. This approach, which slightly more
// tedious, is slightly more convenient for users (one less import they have to remember).
pub async fn add_child_realm(
&self,
name: impl Into<String>,
options: ChildOptions,
) -> Result<SubRealmBuilder, Error> {
self.root_realm.add_child_realm(name, options).await
}
/// Adds a new component with a local implementation to the realm
pub async fn add_local_child(
&self,
name: impl Into<String>,
local_component_implementation: impl Fn(LocalComponentHandles) -> BoxFuture<'static, Result<(), anyhow::Error>>
+ Sync
+ Send
+ 'static,
options: ChildOptions,
) -> Result<ChildRef, Error> {
self.root_realm.add_local_child(name, local_component_implementation, options).await
}
/// Adds a new component to the realm by URL
pub async fn add_child(
&self,
name: impl Into<String>,
url: impl Into<String>,
options: ChildOptions,
) -> Result<ChildRef, Error> {
self.root_realm.add_child(name, url, options).await
}
/// Adds a new legacy component to the realm
pub async fn add_legacy_child(
&self,
name: impl Into<String>,
legacy_url: impl Into<String>,
options: ChildOptions,
) -> Result<ChildRef, Error> {
self.root_realm.add_legacy_child(name, legacy_url, options).await
}
/// Adds a new component to the realm with the given component declaration
pub async fn add_child_from_decl(
&self,
name: impl Into<String>,
decl: cm_rust::ComponentDecl,
options: ChildOptions,
) -> Result<ChildRef, Error> {
self.root_realm.add_child_from_decl(name, decl, options).await
}
/// Returns a copy the decl for a child in this realm
pub async fn get_component_decl(
&self,
name: impl Into<ChildRef>,
) -> Result<cm_rust::ComponentDecl, Error> {
self.root_realm.get_component_decl(name).await
}
/// Replaces the decl for a child of this realm
pub async fn replace_component_decl(
&self,
name: impl Into<ChildRef>,
decl: cm_rust::ComponentDecl,
) -> Result<(), Error> {
self.root_realm.replace_component_decl(name, decl).await
}
/// Returns a copy the decl for this realm
pub async fn get_realm_decl(&self) -> Result<cm_rust::ComponentDecl, Error> {
self.root_realm.get_realm_decl().await
}
/// Replaces the decl for this realm
pub async fn replace_realm_decl(&self, decl: cm_rust::ComponentDecl) -> Result<(), Error> {
self.root_realm.replace_realm_decl(decl).await
}
/// Adds a route between components within the realm
pub async fn add_route(&self, route: Route) -> Result<(), Error> {
self.root_realm.add_route(route).await
}
/// Replaces a value of a given configuration field
pub async fn replace_config_value(
&self,
name: impl Into<ChildRef>,
key: &str,
value: cm_rust::ValueSpec,
) -> Result<(), Error> {
self.root_realm.replace_config_value(name, key, value).await
}
/// Replaces a boolean value of a given configuration field
pub async fn replace_config_value_bool(
&self,
name: impl Into<ChildRef>,
key: &str,
value: bool,
) -> Result<(), Error> {
self.root_realm.replace_config_value_bool(name, key, value).await
}
/// Replaces a uint8 value of a given configuration field
pub async fn replace_config_value_uint8(
&self,
name: impl Into<ChildRef>,
key: &str,
value: u8,
) -> Result<(), Error> {
self.root_realm.replace_config_value_uint8(name, key, value).await
}
/// Replaces a uint16 value of a given configuration field
pub async fn replace_config_value_uint16(
&self,
name: impl Into<ChildRef>,
key: &str,
value: u16,
) -> Result<(), Error> {
self.root_realm.replace_config_value_uint16(name, key, value).await
}
/// Replaces a uint32 value of a given configuration field
pub async fn replace_config_value_uint32(
&self,
name: impl Into<ChildRef>,
key: &str,
value: u32,
) -> Result<(), Error> {
self.root_realm.replace_config_value_uint32(name, key, value).await
}
/// Replaces a uint64 value of a given configuration field
pub async fn replace_config_value_uint64(
&self,
name: impl Into<ChildRef>,
key: &str,
value: u64,
) -> Result<(), Error> {
self.root_realm.replace_config_value_uint64(name, key, value).await
}
/// Replaces a int8 value of a given configuration field
pub async fn replace_config_value_int8(
&self,
name: impl Into<ChildRef>,
key: &str,
value: i8,
) -> Result<(), Error> {
self.root_realm.replace_config_value_int8(name, key, value).await
}
/// Replaces a int16 value of a given configuration field
pub async fn replace_config_value_int16(
&self,
name: impl Into<ChildRef>,
key: &str,
value: i16,
) -> Result<(), Error> {
self.root_realm.replace_config_value_int16(name, key, value).await
}
/// Replaces a int32 value of a given configuration field
pub async fn replace_config_value_int32(
&self,
name: impl Into<ChildRef>,
key: &str,
value: i32,
) -> Result<(), Error> {
self.root_realm.replace_config_value_int32(name, key, value).await
}
/// Replaces a int64 value of a given configuration field
pub async fn replace_config_value_int64(
&self,
name: impl Into<ChildRef>,
key: &str,
value: i64,
) -> Result<(), Error> {
self.root_realm.replace_config_value_int64(name, key, value).await
}
/// Replaces a string value of a given configuration field
pub async fn replace_config_value_string(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl ToString,
) -> Result<(), Error> {
self.root_realm.replace_config_value_string(name, key, value).await
}
/// Replaces a boolean vector value of a given configuration field
pub async fn replace_config_value_bool_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = bool>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_bool_vector(name, key, value).await
}
/// Replaces a uint8 vector value of a given configuration field
pub async fn replace_config_value_uint8_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = u8>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_uint8_vector(name, key, value).await
}
/// Replaces a uint16 vector value of a given configuration field
pub async fn replace_config_value_uint16_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = u16>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_uint16_vector(name, key, value).await
}
/// Replaces a uint32 vector value of a given configuration field
pub async fn replace_config_value_uint32_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = u32>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_uint32_vector(name, key, value).await
}
/// Replaces a uint64 vector value of a given configuration field
pub async fn replace_config_value_uint64_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = u64>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_uint64_vector(name, key, value).await
}
/// Replaces a int8 vector value of a given configuration field
pub async fn replace_config_value_int8_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = i8>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_int8_vector(name, key, value).await
}
/// Replaces a int16 vector value of a given configuration field
pub async fn replace_config_value_int16_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = i16>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_int16_vector(name, key, value).await
}
/// Replaces a int32 vector value of a given configuration field
pub async fn replace_config_value_int32_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = i32>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_int32_vector(name, key, value).await
}
/// Replaces a int64 vector value of a given configuration field
pub async fn replace_config_value_int64_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = i64>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_int64_vector(name, key, value).await
}
/// Replaces a string vector value of a given configuration field
pub async fn replace_config_value_string_vector(
&self,
name: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = impl ToString>,
) -> Result<(), Error> {
self.root_realm.replace_config_value_string_vector(name, key, value).await
}
/// Creates and routes a read-only directory capability to the given targets. The directory
/// capability will have the given name, and anyone accessing the directory will see the given
/// contents.
pub async fn read_only_directory(
&self,
directory_name: impl Into<String>,
to: Vec<impl Into<Ref>>,
directory_contents: DirectoryContents,
) -> Result<(), Error> {
self.root_realm.read_only_directory(directory_name, to, directory_contents).await
}
}
#[derive(Debug)]
pub struct SubRealmBuilder {
realm_proxy: ftest::RealmProxy,
realm_path: Vec<String>,
local_component_runner_builder: LocalComponentRunnerBuilder,
/// We don't currently support automatically gracefully tearing down realms built in a nested
/// component manager. This is typically not a big deal, because any resources those components
/// are using (jobs, processes, etc.) live under the nested component manager's job, with the
/// singular and important exception of legacy components, which run under the system's appmgr.
/// To prevent flakiness and resource leakage caused by this, we disallow legacy children in
/// realms constructed in a nested component manager. To accomplish this, we track if legacy
/// children have been added to a realm here.
///
/// In order to share the single boolean with any related SubRealmBuilders, we put it in an
/// Arc<Mutex<_>>
has_legacy_children: Arc<Mutex<bool>>,
}
impl SubRealmBuilder {
pub async fn add_child_realm(
&self,
name: impl Into<String>,
options: ChildOptions,
) -> Result<Self, Error> {
let name: String = name.into();
let (child_realm_proxy, child_realm_server_end) =
create_proxy::<ftest::RealmMarker>().expect("failed to create channel pair");
self.realm_proxy.add_child_realm(&name, options.into(), child_realm_server_end).await??;
let mut child_path = self.realm_path.clone();
child_path.push(name);
Ok(SubRealmBuilder {
realm_proxy: child_realm_proxy,
realm_path: child_path,
local_component_runner_builder: self.local_component_runner_builder.clone(),
has_legacy_children: self.has_legacy_children.clone(),
})
}
/// Adds a new local component to the realm
pub async fn add_local_child<M>(
&self,
name: impl Into<String>,
local_component_implementation: M,
options: ChildOptions,
) -> Result<ChildRef, Error>
where
M: Fn(LocalComponentHandles) -> BoxFuture<'static, Result<(), anyhow::Error>>
+ Sync
+ Send
+ 'static,
{
let name: String = name.into();
self.realm_proxy.add_local_child(&name, options.into()).await??;
let mut child_path = self.realm_path.clone();
child_path.push(name.clone());
self.local_component_runner_builder
.register_local_component(child_path.join("/"), local_component_implementation)
.await?;
Ok(ChildRef::new(name, self.realm_path.clone()))
}
/// Adds a new component to the realm by URL
pub async fn add_child(
&self,
name: impl Into<String>,
url: impl Into<String>,
options: ChildOptions,
) -> Result<ChildRef, Error> {
let name: String = name.into();
self.realm_proxy.add_child(&name, &url.into(), options.into()).await??;
Ok(ChildRef::new(name, self.realm_path.clone()))
}
/// Adds a new legacy component to the realm
pub async fn add_legacy_child(
&self,
name: impl Into<String>,
legacy_url: impl Into<String>,
options: ChildOptions,
) -> Result<ChildRef, Error> {
*self.has_legacy_children.lock().await = true;
let name: String = name.into();
self.realm_proxy.add_legacy_child(&name, &legacy_url.into(), options.into()).await??;
Ok(ChildRef::new(name, self.realm_path.clone()))
}
/// Adds a new component to the realm with the given component declaration
pub async fn add_child_from_decl(
&self,
name: impl Into<String>,
decl: cm_rust::ComponentDecl,
options: ChildOptions,
) -> Result<ChildRef, Error> {
let name: String = name.into();
self.realm_proxy
.add_child_from_decl(&name, decl.native_into_fidl(), options.into())
.await??;
Ok(ChildRef::new(name, self.realm_path.clone()))
}
/// Returns a copy the decl for a child in this realm
pub async fn get_component_decl(
&self,
child_ref: impl Into<ChildRef>,
) -> Result<cm_rust::ComponentDecl, Error> {
let child_ref: ChildRef = child_ref.into();
child_ref.check_scope(&self.realm_path)?;
let decl = self.realm_proxy.get_component_decl(&child_ref.name).await??;
Ok(decl.fidl_into_native())
}
/// Replaces the decl for a child of this realm
pub async fn replace_component_decl(
&self,
child_ref: impl Into<ChildRef>,
decl: cm_rust::ComponentDecl,
) -> Result<(), Error> {
let child_ref: ChildRef = child_ref.into();
child_ref.check_scope(&self.realm_path)?;
self.realm_proxy.replace_component_decl(&child_ref.name, decl.native_into_fidl()).await??;
Ok(())
}
/// Returns a copy the decl for this realm
pub async fn get_realm_decl(&self) -> Result<cm_rust::ComponentDecl, Error> {
Ok(self.realm_proxy.get_realm_decl().await??.fidl_into_native())
}
/// Replaces the decl for this realm
pub async fn replace_realm_decl(&self, decl: cm_rust::ComponentDecl) -> Result<(), Error> {
self.realm_proxy.replace_realm_decl(decl.native_into_fidl()).await?.map_err(Into::into)
}
/// Replaces a value of a given configuration field
pub async fn replace_config_value(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: cm_rust::ValueSpec,
) -> Result<(), Error> {
let child_ref: ChildRef = child_ref.into();
child_ref.check_scope(&self.realm_path)?;
self.realm_proxy
.replace_config_value(&child_ref.name, key, value.native_into_fidl())
.await?
.map_err(Into::into)
}
/// Replaces a boolean value of a given configuration field
pub async fn replace_config_value_bool(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: bool,
) -> Result<(), Error> {
let value =
cm_rust::ValueSpec { value: cm_rust::Value::Single(cm_rust::SingleValue::Bool(value)) };
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a uint8 value of a given configuration field
pub async fn replace_config_value_uint8(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: u8,
) -> Result<(), Error> {
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Single(cm_rust::SingleValue::Uint8(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a uint16 value of a given configuration field
pub async fn replace_config_value_uint16(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: u16,
) -> Result<(), Error> {
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Single(cm_rust::SingleValue::Uint16(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a uint32 value of a given configuration field
pub async fn replace_config_value_uint32(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: u32,
) -> Result<(), Error> {
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Single(cm_rust::SingleValue::Uint32(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a uint64 value of a given configuration field
pub async fn replace_config_value_uint64(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: u64,
) -> Result<(), Error> {
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Single(cm_rust::SingleValue::Uint64(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a int8 value of a given configuration field
pub async fn replace_config_value_int8(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: i8,
) -> Result<(), Error> {
let value =
cm_rust::ValueSpec { value: cm_rust::Value::Single(cm_rust::SingleValue::Int8(value)) };
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a int16 value of a given configuration field
pub async fn replace_config_value_int16(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: i16,
) -> Result<(), Error> {
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Single(cm_rust::SingleValue::Int16(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a int32 value of a given configuration field
pub async fn replace_config_value_int32(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: i32,
) -> Result<(), Error> {
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Single(cm_rust::SingleValue::Int32(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a int64 value of a given configuration field
pub async fn replace_config_value_int64(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: i64,
) -> Result<(), Error> {
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Single(cm_rust::SingleValue::Int64(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a string value of a given configuration field
pub async fn replace_config_value_string(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl ToString,
) -> Result<(), Error> {
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Single(cm_rust::SingleValue::String(value.to_string())),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a boolean vector value of a given configuration field
pub async fn replace_config_value_bool_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = bool>,
) -> Result<(), Error> {
let value = value.into_iter().collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::BoolVector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a uint8 vector value of a given configuration field
pub async fn replace_config_value_uint8_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = u8>,
) -> Result<(), Error> {
let value = value.into_iter().collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::Uint8Vector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a uint16 vector value of a given configuration field
pub async fn replace_config_value_uint16_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = u16>,
) -> Result<(), Error> {
let value = value.into_iter().collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::Uint16Vector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a uint32 vector value of a given configuration field
pub async fn replace_config_value_uint32_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = u32>,
) -> Result<(), Error> {
let value = value.into_iter().collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::Uint32Vector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a uint64 vector value of a given configuration field
pub async fn replace_config_value_uint64_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = u64>,
) -> Result<(), Error> {
let value = value.into_iter().collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::Uint64Vector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a int8 vector value of a given configuration field
pub async fn replace_config_value_int8_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = i8>,
) -> Result<(), Error> {
let value = value.into_iter().collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::Int8Vector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a int16 vector value of a given configuration field
pub async fn replace_config_value_int16_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = i16>,
) -> Result<(), Error> {
let value = value.into_iter().collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::Int16Vector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a int32 vector value of a given configuration field
pub async fn replace_config_value_int32_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = i32>,
) -> Result<(), Error> {
let value = value.into_iter().collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::Int32Vector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a int64 vector value of a given configuration field
pub async fn replace_config_value_int64_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = i64>,
) -> Result<(), Error> {
let value = value.into_iter().collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::Int64Vector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Replaces a string vector value of a given configuration field
pub async fn replace_config_value_string_vector(
&self,
child_ref: impl Into<ChildRef>,
key: &str,
value: impl IntoIterator<Item = impl ToString>,
) -> Result<(), Error> {
let value = value.into_iter().map(|s| s.to_string()).collect();
let value = cm_rust::ValueSpec {
value: cm_rust::Value::Vector(cm_rust::VectorValue::StringVector(value)),
};
self.replace_config_value(child_ref, key, value).await
}
/// Adds a route between components within the realm
pub async fn add_route(&self, mut route: Route) -> Result<(), Error> {
if let Some(source) = &route.from {
source.check_scope(&self.realm_path)?;
}
for target in &route.to {
target.check_scope(&self.realm_path)?;
}
if !route.capabilities.is_empty() {
let mut route_targets =
route.to.into_iter().map(Into::into).collect::<Vec<fdecl::Ref>>();
// If we don't name the future with `let` and then await it in a second step, rustc
// will decide this function is not Send and then Realm Builder won't be usable on
// multi-threaded executors. This is caused by the mutable references held in the
// future generated by `add_route`.
let fut = self.realm_proxy.add_route(
&mut route.capabilities.iter_mut(),
&mut route.from.ok_or(Error::MissingSource)?.into(),
&mut route_targets.iter_mut(),
);
fut.await??;
}
Ok(())
}
/// Creates and routes a read-only directory capability to the given targets. The directory
/// capability will have the given name, and anyone accessing the directory will see the given
/// contents.
pub async fn read_only_directory(
&self,
directory_name: impl Into<String>,
to: Vec<impl Into<Ref>>,
directory_contents: DirectoryContents,
) -> Result<(), Error> {
let to: Vec<Ref> = to.into_iter().map(|t| t.into()).collect();
for target in &to {
target.check_scope(&self.realm_path)?;
}
let mut to = to.into_iter().map(Into::into).collect::<Vec<_>>();
let fut = self.realm_proxy.read_only_directory(
&directory_name.into(),
&mut to.iter_mut(),
&mut directory_contents.into(),
);
fut.await??;
Ok(())
}
}
/// Contains the contents of a read-only directory that Realm Builder should provide to a realm.
/// Used with the `RealmBuilder::read_only_directory` function.
pub struct DirectoryContents {
contents: HashMap<String, fmem::Buffer>,
}
impl DirectoryContents {
pub fn new() -> Self {
Self { contents: HashMap::new() }
}
pub fn add_file(mut self, path: impl Into<String>, contents: impl Into<Vec<u8>>) -> Self {
let contents: Vec<u8> = contents.into();
let vmo = zx::Vmo::create(4096).expect("failed to create a VMO");
vmo.write(&contents, 0).expect("failed to write to VMO");
let buffer = fmem::Buffer { vmo, size: contents.len() as u64 };
self.contents.insert(path.into(), buffer);
self
}
}
impl Clone for DirectoryContents {
fn clone(&self) -> Self {
let mut new_self = Self::new();
for (path, buf) in self.contents.iter() {
new_self.contents.insert(
path.clone(),
fmem::Buffer {
vmo: buf
.vmo
.create_child(zx::VmoChildOptions::SNAPSHOT_AT_LEAST_ON_WRITE, 0, buf.size)
.expect("failed to clone VMO"),
size: buf.size,
},
);
}
new_self
}
}
impl From<DirectoryContents> for ftest::DirectoryContents {
fn from(input: DirectoryContents) -> ftest::DirectoryContents {
ftest::DirectoryContents {
entries: input
.contents
.into_iter()
.map(|(path, buf)| ftest::DirectoryEntry { file_path: path, file_contents: buf })
.collect(),
}
}
}
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum Event {
Started,
Stopped,
Running,
// Filter.name
CapabilityRequested(String),
// Filter.name
DirectoryReady(String),
}
impl Event {
pub fn started() -> Self {
Self::Started
}
pub fn stopped() -> Self {
Self::Stopped
}
pub fn running() -> Self {
Self::Running
}
pub fn capability_requested(filter_name: impl Into<String>) -> Self {
Self::CapabilityRequested(filter_name.into())
}
pub fn directory_ready(filter_name: impl Into<String>) -> Self {
Self::DirectoryReady(filter_name.into())
}
fn name(&self) -> &'static str {
match self {
Event::Started => "started",
Event::Stopped => "stopped",
Event::Running => "running",
Event::CapabilityRequested(_) => "capability_requested",
Event::DirectoryReady(_) => "directory_ready",
}
}
/// Returns the Event Filter that some events (like DirectoryReady and CapabilityRequested)
/// have.
fn filter(&self) -> Option<HashMap<String, cm_rust::DictionaryValue>> {
match self {
Event::CapabilityRequested(name) | Event::DirectoryReady(name) => Some(
hashmap!("name".to_string() => cm_rust::DictionaryValue::Str(name.to_string())),
),
_ => None,
}
}
}
/// The properties for a child being added to a realm
#[derive(Debug, Clone)]
pub struct ChildOptions {
startup: fdecl::StartupMode,
environment: Option<String>,
on_terminate: fdecl::OnTerminate,
}
impl ChildOptions {
pub fn new() -> Self {
Self {
startup: fdecl::StartupMode::Lazy,
environment: None,
on_terminate: fdecl::OnTerminate::None,
}
}
pub fn eager(mut self) -> Self {
self.startup = fdecl::StartupMode::Eager;
self
}
pub fn environment(mut self, environment: impl Into<String>) -> Self {
self.environment = Some(environment.into());
self
}
pub fn reboot_on_terminate(mut self) -> Self {
self.on_terminate = fdecl::OnTerminate::Reboot;
self
}
}
impl Into<ftest::ChildOptions> for ChildOptions {
fn into(self) -> ftest::ChildOptions {
ftest::ChildOptions {
startup: Some(self.startup),
environment: self.environment,
on_terminate: Some(self.on_terminate),
..ftest::ChildOptions::EMPTY
}
}
}
/// Manages the creation of new components within a collection.
pub struct ScopedInstanceFactory {
realm_proxy: Option<fcomponent::RealmProxy>,
collection_name: String,
}
impl ScopedInstanceFactory {
/// Creates a new factory that creates components in the specified collection.
pub fn new(collection_name: impl Into<String>) -> Self {
ScopedInstanceFactory { realm_proxy: None, collection_name: collection_name.into() }
}
/// Use `realm_proxy` instead of the fuchsia.component.Realm protocol in this component's
/// incoming namespace. This can be used to start component's in a collection belonging
/// to another component.
pub fn with_realm_proxy(mut self, realm_proxy: fcomponent::RealmProxy) -> Self {
self.realm_proxy = Some(realm_proxy);
self
}
/// Creates and binds to a new component just like `new_named_instance`, but uses an
/// autogenerated name for the instance.
pub async fn new_instance(
&self,
url: impl Into<String>,
) -> Result<ScopedInstance, anyhow::Error> {
let id: u64 = rand::thread_rng().gen();
let child_name = format!("auto-{:x}", id);
self.new_named_instance(child_name, url).await
}
/// Creates and binds to a new component named `child_name` with `url`.
/// A ScopedInstance is returned on success, representing the component's lifetime and
/// providing access to the component's exposed capabilities.
///
/// When the ScopedInstance is dropped, the component will be asynchronously stopped _and_
/// destroyed.
///
/// This is useful for tests that wish to create components that should be torn down at the
/// end of the test, or to explicitly control the lifecycle of a component.
pub async fn new_named_instance(
&self,
child_name: impl Into<String>,
url: impl Into<String>,
) -> Result<ScopedInstance, anyhow::Error> {
let realm = if let Some(realm_proxy) = self.realm_proxy.as_ref() {
realm_proxy.clone()
} else {
fclient::realm().context("Failed to connect to Realm service")?
};
let child_name = child_name.into();
let mut collection_ref = fdecl::CollectionRef { name: self.collection_name.clone() };
let child_decl = fdecl::Child {
name: Some(child_name.clone()),
url: Some(url.into()),
startup: Some(fdecl::StartupMode::Lazy),
..fdecl::Child::EMPTY
};
let child_args = fcomponent::CreateChildArgs {
numbered_handles: None,
..fcomponent::CreateChildArgs::EMPTY
};
let () = realm
.create_child(&mut collection_ref, child_decl, child_args)
.await
.context("CreateChild FIDL failed.")?
.map_err(|e| format_err!("Failed to create child: {:?}", e))?;
let mut child_ref = fdecl::ChildRef {
name: child_name.clone(),
collection: Some(self.collection_name.clone()),
};
let (exposed_dir, server) = endpoints::create_proxy::<fio::DirectoryMarker>()
.context("Failed to create directory proxy")?;
let () = realm
.open_exposed_dir(&mut child_ref, server)
.await
.context("OpenExposedDir FIDL failed.")?
.map_err(|e|
// NOTE: There could be a flake here that if the collection is single-run, and the
// child we created is short-lived, it's possible that the child has already run
// and terminated, and "open_exposed_dir" would fail with an Internal error.
format_err!("Failed to open exposed dir of child: {:?}", e))?;
Ok(ScopedInstance {
realm,
child_name,
collection: self.collection_name.clone(),
exposed_dir,
destroy_channel: None,
})
}
}
/// RAII object that keeps a component instance alive until it's dropped, and provides convenience
/// functions for using the instance. Components v2 only.
#[must_use = "Dropping `ScopedInstance` will cause the component instance to be stopped and destroyed."]
pub struct ScopedInstance {
realm: fcomponent::RealmProxy,
child_name: String,
collection: String,
exposed_dir: fio::DirectoryProxy,
destroy_channel: Option<
futures::channel::oneshot::Sender<
Result<
fidl::client::QueryResponseFut<fcomponent::RealmDestroyChildResult>,
anyhow::Error,
>,
>,
>,
}
impl ScopedInstance {
/// Creates and binds to a new component just like `new_with_name`, but uses an autogenerated
/// name for the instance.
pub async fn new(coll: String, url: String) -> Result<Self, anyhow::Error> {
ScopedInstanceFactory::new(coll).new_instance(url).await
}
/// Creates and binds to a new component named `child_name` in a collection `coll` with `url`,
/// and returning an object that represents the component's lifetime and can be used to access
/// the component's exposed directory. When the object is dropped, it will be asynchronously
/// stopped _and_ destroyed. This is useful for tests that wish to create components that
/// should be torn down at the end of the test. Components v2 only.
pub async fn new_with_name(
child_name: String,
collection: String,
url: String,
) -> Result<Self, anyhow::Error> {
ScopedInstanceFactory::new(collection).new_named_instance(child_name, url).await
}
/// Connect to exposed fuchsia.component.Binder protocol of instance, thus
/// triggering it to start.
/// Note: This will only work if the component exposes this protocol in its
/// manifest.
pub fn connect_to_binder(&self) -> Result<fcomponent::BinderProxy, anyhow::Error> {
let binder: fcomponent::BinderProxy = self
.connect_to_protocol_at_exposed_dir::<fcomponent::BinderMarker>()
.context("failed to connect to fuchsia.component.Binder")?;
Ok(binder)
}
/// Same as `connect_to_binder` except that it will block until the
/// component has started.
/// Note: This function expects that the instance has not been started yet.
/// If the instance has been started before this method is invoked, then
/// this method will block forever waiting for the Started event.
/// REQUIRED: The manifest of the component executing this code must use
/// the `fuchsia.sys2.EventSource` protocol from the framework and the
/// "started" event.
pub async fn start_with_binder_sync(&self) -> Result<(), anyhow::Error> {
let event_source = EventSource::new().context("failed to create EventSource")?;
let mut event_stream = event_source
.subscribe(vec![EventSubscription::new(vec![Started::NAME])])
.await
.context("failed to subscribe to EventSource")?;
let _ = self
.connect_to_protocol_at_exposed_dir::<fcomponent::BinderMarker>()
.context("failed to connect to fuchsia.component.Binder")?;
let moniker = format!("./{}:{}", self.collection, self.child_name);
let _ = EventMatcher::ok()
.moniker(&moniker)
.wait::<Started>(&mut event_stream)
.await
.context("failed to observe Started event")?;
Ok(())
}
/// Connect to an instance of a FIDL protocol hosted in the component's exposed directory`,
pub fn connect_to_protocol_at_exposed_dir<P: DiscoverableProtocolMarker>(
&self,
) -> Result<P::Proxy, anyhow::Error> {
fclient::connect_to_protocol_at_dir_root::<P>(&self.exposed_dir)
}
/// Connect to an instance of a FIDL protocol hosted in the component's exposed directory`,
pub fn connect_to_named_protocol_at_exposed_dir<P: DiscoverableProtocolMarker>(
&self,
protocol_name: &str,
) -> Result<P::Proxy, anyhow::Error> {
fclient::connect_to_named_protocol_at_dir_root::<P>(&self.exposed_dir, protocol_name)
}
/// Connects to an instance of a FIDL protocol hosted in the component's exposed directory
/// using the given `server_end`.
pub fn connect_request_to_protocol_at_exposed_dir<P: DiscoverableProtocolMarker>(
&self,
server_end: ServerEnd<P>,
) -> Result<(), anyhow::Error> {
self.connect_request_to_named_protocol_at_exposed_dir(
P::PROTOCOL_NAME,
server_end.into_channel(),
)
}
/// Connects to an instance of a FIDL protocol called `protocol_name` hosted in the component's
/// exposed directory using the given `server_end`.
pub fn connect_request_to_named_protocol_at_exposed_dir(
&self,
protocol_name: &str,
server_end: zx::Channel,
) -> Result<(), anyhow::Error> {
self.exposed_dir
.open(
fio::OpenFlags::RIGHT_READABLE | fio::OpenFlags::RIGHT_WRITABLE,
fio::MODE_TYPE_SERVICE,
protocol_name,
ServerEnd::new(server_end),
)
.context("Failed to open protocol in directory")
}
/// Returns a reference to the component's read-only exposed directory.
pub fn get_exposed_dir(&self) -> &fio::DirectoryProxy {
&self.exposed_dir
}
/// Returns true if `take_destroy_waiter` has already been called.
pub fn destroy_waiter_taken(&self) -> bool {
self.destroy_channel.is_some()
}
/// Returns a future which can be awaited on for destruction to complete after the
/// `ScopedInstance` is dropped. Panics if called multiple times.
pub fn take_destroy_waiter(
&mut self,
) -> impl futures::Future<Output = Result<(), anyhow::Error>> {
if self.destroy_channel.is_some() {
panic!("destroy waiter already taken");
}
let (sender, receiver) = futures::channel::oneshot::channel();
self.destroy_channel = Some(sender);
receiver.err_into().and_then(futures::future::ready).and_then(
|fidl_fut: fidl::client::QueryResponseFut<_>| {
fidl_fut.map(|r: Result<Result<(), fidl_fuchsia_component::Error>, fidl::Error>| {
r.context("DestroyChild FIDL error")?
.map_err(|e| format_err!("Failed to destroy child: {:?}", e))
})
},
)
}
/// Return the name of this instance.
pub fn child_name(&self) -> &str {
self.child_name.as_str()
}
}
impl Drop for ScopedInstance {
fn drop(&mut self) {
let Self { realm, collection, child_name, destroy_channel, exposed_dir: _ } = self;
let mut child_ref =
fdecl::ChildRef { name: child_name.clone(), collection: Some(collection.clone()) };
// DestroyChild also stops the component.
//
// Calling destroy child within drop guarantees that the message
// goes out to the realm regardless of there existing a waiter on
// the destruction channel.
let result = Ok(realm.destroy_child(&mut child_ref));
if let Some(chan) = destroy_channel.take() {
let () = chan.send(result).unwrap_or_else(|result| {
warn!("Failed to send result for destroyed scoped instance. Result={:?}", result);
});
}
}
}
#[cfg(test)]
mod tests {
use {
super::Event as RbEvent, // To disambiguate with tracing::Event
super::*,
assert_matches::assert_matches,
fidl::endpoints::create_proxy_and_stream,
fidl_fuchsia_component as fcomponent,
fidl_fuchsia_component_config as fconfig,
futures::{channel::mpsc, future::pending, FutureExt, SinkExt, StreamExt, TryStreamExt},
};
#[fuchsia::test]
fn child_options_to_fidl() {
let options: ftest::ChildOptions = ChildOptions::new().into();
assert_eq!(
options,
ftest::ChildOptions {
startup: Some(fdecl::StartupMode::Lazy),
environment: None,
on_terminate: Some(fdecl::OnTerminate::None),
..ftest::ChildOptions::EMPTY
},
);
let options: ftest::ChildOptions = ChildOptions::new().eager().into();
assert_eq!(
options,
ftest::ChildOptions {
startup: Some(fdecl::StartupMode::Eager),
environment: None,
on_terminate: Some(fdecl::OnTerminate::None),
..ftest::ChildOptions::EMPTY
},
);
let options: ftest::ChildOptions = ChildOptions::new().environment("test_env").into();
assert_eq!(
options,
ftest::ChildOptions {
startup: Some(fdecl::StartupMode::Lazy),
environment: Some("test_env".to_string()),
on_terminate: Some(fdecl::OnTerminate::None),
..ftest::ChildOptions::EMPTY
},
);
let options: ftest::ChildOptions = ChildOptions::new().reboot_on_terminate().into();
assert_eq!(
options,
ftest::ChildOptions {
startup: Some(fdecl::StartupMode::Lazy),
environment: None,
on_terminate: Some(fdecl::OnTerminate::Reboot),
..ftest::ChildOptions::EMPTY
},
);
}
#[fuchsia::test]
async fn child_scope_prevents_cross_realm_usage() {
let (builder, _server_task, receive_server_requests) = new_realm_builder_and_server_task();
let child_a = builder.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
let child_realm_b = builder.add_child_realm("b", ChildOptions::new()).await.unwrap();
let child_c = child_realm_b.add_child("c", "test://c", ChildOptions::new()).await.unwrap();
assert_matches!(
builder.add_route(
Route::new()
.capability(Capability::protocol::<fcomponent::RealmMarker>())
.from(&child_a)
.to(&child_c)
).await,
Err(Error::RefUsedInWrongRealm(ref_, _)) if ref_ == (&child_c).into()
);
assert_matches!(
child_realm_b.add_route(
Route::new()
.capability(Capability::protocol::<fcomponent::RealmMarker>())
.from(&child_a)
.to(&child_c)
).await,
Err(Error::RefUsedInWrongRealm(ref_, _)) if ref_ == (&child_a).into()
);
assert_matches!(
builder.get_component_decl(&child_c).await,
Err(Error::RefUsedInWrongRealm(ref_, _)) if ref_ == (&child_c).into()
);
assert_matches!(
child_realm_b.get_component_decl(&child_a).await,
Err(Error::RefUsedInWrongRealm(ref_, _)) if ref_ == (&child_a).into()
);
assert_matches!(
builder.replace_component_decl(&child_c, cm_rust::ComponentDecl::default()).await,
Err(Error::RefUsedInWrongRealm(ref_, _)) if ref_ == (&child_c).into()
);
assert_matches!(
child_realm_b.replace_component_decl(&child_a, cm_rust::ComponentDecl::default()).await,
Err(Error::RefUsedInWrongRealm(ref_, _)) if ref_ == (&child_a).into()
);
// There should be two server requests from the initial add child calls, and then none of
// the following lines in this test should have sent any requests to the server.
let sub_realm_receiver = confirm_num_server_requests(receive_server_requests, 2).remove(0);
confirm_num_server_requests(sub_realm_receiver, 1);
}
#[fuchsia::test]
async fn child_ref_construction() {
let (builder, _server_task, receive_server_requests) = new_realm_builder_and_server_task();
let child_realm_a = builder.add_child_realm("a", ChildOptions::new()).await.unwrap();
let child_realm_b = child_realm_a.add_child_realm("b", ChildOptions::new()).await.unwrap();
let child_ref_a: ChildRef = (&child_realm_a).into();
let child_ref_b: ChildRef = (&child_realm_b).into();
assert_eq!(child_ref_a, ChildRef::new("a".to_string(), vec![]),);
assert_eq!(child_ref_b, ChildRef::new("b".to_string(), vec!["a".to_string()]),);
let child_ref_c = builder.add_child("c", "test://c", ChildOptions::new()).await.unwrap();
let child_ref_d =
child_realm_a.add_child("d", "test://d", ChildOptions::new()).await.unwrap();
let child_ref_e =
child_realm_b.add_child("e", "test://e", ChildOptions::new()).await.unwrap();
assert_eq!(child_ref_c, ChildRef::new("c".to_string(), vec![]),);
assert_eq!(child_ref_d, ChildRef::new("d".to_string(), vec!["a".to_string()]),);
assert_eq!(
child_ref_e,
ChildRef::new("e".to_string(), vec!["a".to_string(), "b".to_string()]),
);
// There should be two server requests from the initial add child calls, and then none of
// the following lines in this test should have sent any requests to the server.
confirm_num_server_requests(receive_server_requests, 2);
}
#[fuchsia::test]
async fn protocol_capability_construction() {
assert_eq!(
Capability::protocol_by_name("test"),
ProtocolCapability {
name: "test".to_string(),
as_: None,
type_: fdecl::DependencyType::Strong,
path: None,
},
);
assert_eq!(
Capability::protocol::<ftest::RealmBuilderFactoryMarker>(),
ProtocolCapability {
name: ftest::RealmBuilderFactoryMarker::PROTOCOL_NAME.to_string(),
as_: None,
type_: fdecl::DependencyType::Strong,
path: None,
},
);
assert_eq!(
Capability::protocol_by_name("test").as_("test2"),
ProtocolCapability {
name: "test".to_string(),
as_: Some("test2".to_string()),
type_: fdecl::DependencyType::Strong,
path: None,
},
);
assert_eq!(
Capability::protocol_by_name("test").weak(),
ProtocolCapability {
name: "test".to_string(),
as_: None,
type_: fdecl::DependencyType::Weak,
path: None,
},
);
assert_eq!(
Capability::protocol_by_name("test").path("/svc/test2"),
ProtocolCapability {
name: "test".to_string(),
as_: None,
type_: fdecl::DependencyType::Strong,
path: Some("/svc/test2".to_string()),
},
);
}
#[fuchsia::test]
async fn directory_capability_construction() {
assert_eq!(
Capability::directory("test"),
DirectoryCapability {
name: "test".to_string(),
as_: None,
type_: fdecl::DependencyType::Strong,
rights: None,
subdir: None,
path: None,
},
);
assert_eq!(
Capability::directory("test").as_("test2"),
DirectoryCapability {
name: "test".to_string(),
as_: Some("test2".to_string()),
type_: fdecl::DependencyType::Strong,
rights: None,
subdir: None,
path: None,
},
);
assert_eq!(
Capability::directory("test").weak(),
DirectoryCapability {
name: "test".to_string(),
as_: None,
type_: fdecl::DependencyType::Weak,
rights: None,
subdir: None,
path: None,
},
);
assert_eq!(
Capability::directory("test").rights(fio::RX_STAR_DIR),
DirectoryCapability {
name: "test".to_string(),
as_: None,
type_: fdecl::DependencyType::Strong,
rights: Some(fio::RX_STAR_DIR),
subdir: None,
path: None,
},
);
assert_eq!(
Capability::directory("test").subdir("test2"),
DirectoryCapability {
name: "test".to_string(),
as_: None,
type_: fdecl::DependencyType::Strong,
rights: None,
subdir: Some("test2".to_string()),
path: None,
},
);
assert_eq!(
Capability::directory("test").path("/test2"),
DirectoryCapability {
name: "test".to_string(),
as_: None,
type_: fdecl::DependencyType::Strong,
rights: None,
subdir: None,
path: Some("/test2".to_string()),
},
);
}
#[fuchsia::test]
async fn storage_capability_construction() {
assert_eq!(
Capability::storage("test"),
StorageCapability { name: "test".to_string(), as_: None, path: None },
);
assert_eq!(
Capability::storage("test").as_("test2"),
StorageCapability {
name: "test".to_string(),
as_: Some("test2".to_string()),
path: None,
},
);
assert_eq!(
Capability::storage("test").path("/test2"),
StorageCapability {
name: "test".to_string(),
as_: None,
path: Some("/test2".to_string()),
},
);
}
#[fuchsia::test]
async fn service_capability_construction() {
assert_eq!(
Capability::service_by_name("test"),
ServiceCapability { name: "test".to_string(), as_: None, path: None },
);
assert_eq!(
Capability::service_by_name("test").as_("test2"),
ServiceCapability {
name: "test".to_string(),
as_: Some("test2".to_string()),
path: None,
},
);
assert_eq!(
Capability::service_by_name("test").path("/svc/test2"),
ServiceCapability {
name: "test".to_string(),
as_: None,
path: Some("/svc/test2".to_string()),
},
);
}
#[fuchsia::test]
async fn event_capability_construction() {
assert_eq!(
Capability::event(RbEvent::Started),
EventCapability { event: RbEvent::Started },
);
assert_eq!(
Capability::event(RbEvent::directory_ready("hippos")),
EventCapability { event: RbEvent::DirectoryReady("hippos".to_string()) },
);
}
#[fuchsia::test]
async fn route_construction() {
assert_eq!(
Route::new()
.capability(Capability::protocol_by_name("test"))
.capability(Capability::protocol_by_name("test2"))
.from(Ref::child("a"))
.to(Ref::collection("b"))
.to(Ref::parent()),
Route {
capabilities: vec![
Capability::protocol_by_name("test").into(),
Capability::protocol_by_name("test2").into(),
],
from: Some(Ref::child("a").into()),
to: vec![Ref::collection("b").into(), Ref::parent().into(),],
},
);
}
#[derive(Debug)]
enum ServerRequest {
AddChild {
name: String,
url: String,
options: ftest::ChildOptions,
},
AddLegacyChild {
name: String,
legacy_url: String,
options: ftest::ChildOptions,
},
AddChildFromDecl {
name: String,
decl: fdecl::Component,
options: ftest::ChildOptions,
},
AddLocalChild {
name: String,
options: ftest::ChildOptions,
},
AddChildRealm {
name: String,
options: ftest::ChildOptions,
receive_requests: mpsc::UnboundedReceiver<ServerRequest>,
},
GetComponentDecl {
name: String,
},
ReplaceComponentDecl {
name: String,
component_decl: fdecl::Component,
},
GetRealmDecl,
ReplaceRealmDecl {
component_decl: fdecl::Component,
},
AddRoute {
capabilities: Vec<ftest::Capability>,
from: fdecl::Ref,
to: Vec<fdecl::Ref>,
},
ReadOnlyDirectory {
name: String,
to: Vec<fdecl::Ref>,
},
ReplaceConfigValue {
name: String,
key: String,
value: fconfig::ValueSpec,
},
}
fn handle_realm_stream(
mut stream: ftest::RealmRequestStream,
mut report_requests: mpsc::UnboundedSender<ServerRequest>,
) -> BoxFuture<'static, ()> {
async move {
let mut child_realm_streams = vec![];
while let Some(req) = stream.try_next().await.unwrap() {
match req {
ftest::RealmRequest::AddChild { responder, name, url, options } => {
report_requests
.send(ServerRequest::AddChild { name, url, options })
.await
.unwrap();
responder.send(&mut Ok(())).unwrap();
}
ftest::RealmRequest::AddLegacyChild {
responder,
name,
legacy_url,
options,
} => {
report_requests
.send(ServerRequest::AddLegacyChild { name, legacy_url, options })
.await
.unwrap();
responder.send(&mut Ok(())).unwrap();
}
ftest::RealmRequest::AddChildFromDecl { responder, name, decl, options } => {
report_requests
.send(ServerRequest::AddChildFromDecl { name, decl, options })
.await
.unwrap();
responder.send(&mut Ok(())).unwrap();
}
ftest::RealmRequest::AddLocalChild { responder, name, options } => {
report_requests
.send(ServerRequest::AddLocalChild { name, options })
.await
.unwrap();
responder.send(&mut Ok(())).unwrap();
}
ftest::RealmRequest::AddChildRealm {
responder,
child_realm,
name,
options,
} => {
let (child_realm_report_requests, receive_requests) = mpsc::unbounded();
report_requests
.send(ServerRequest::AddChildRealm { name, options, receive_requests })
.await
.unwrap();
let child_realm_stream = child_realm.into_stream().unwrap();
child_realm_streams.push(fasync::Task::spawn(async move {
handle_realm_stream(child_realm_stream, child_realm_report_requests)
.await
}));
responder.send(&mut Ok(())).unwrap();
}
ftest::RealmRequest::GetComponentDecl { responder, name } => {
report_requests
.send(ServerRequest::GetComponentDecl { name })
.await
.unwrap();
responder.send(&mut Ok(fdecl::Component::EMPTY)).unwrap();
}
ftest::RealmRequest::ReplaceComponentDecl {
responder,
name,
component_decl,
} => {
report_requests
.send(ServerRequest::ReplaceComponentDecl { name, component_decl })
.await
.unwrap();
responder.send(&mut Ok(())).unwrap();
}
ftest::RealmRequest::GetRealmDecl { responder } => {
report_requests.send(ServerRequest::GetRealmDecl).await.unwrap();
responder.send(&mut Ok(fdecl::Component::EMPTY)).unwrap();
}
ftest::RealmRequest::ReplaceRealmDecl { responder, component_decl } => {
report_requests
.send(ServerRequest::ReplaceRealmDecl { component_decl })
.await
.unwrap();
responder.send(&mut Ok(())).unwrap();
}
ftest::RealmRequest::AddRoute { responder, capabilities, from, to } => {
report_requests
.send(ServerRequest::AddRoute { capabilities, from, to })
.await
.unwrap();
responder.send(&mut Ok(())).unwrap();
}
ftest::RealmRequest::ReadOnlyDirectory { responder, name, to, .. } => {
report_requests
.send(ServerRequest::ReadOnlyDirectory { name, to })
.await
.unwrap();
responder.send(&mut Ok(())).unwrap();
}
ftest::RealmRequest::ReplaceConfigValue { responder, name, key, value } => {
report_requests
.send(ServerRequest::ReplaceConfigValue { name, key, value })
.await
.unwrap();
responder.send(&mut Ok(())).unwrap();
}
}
}
}
.boxed()
}
fn new_realm_builder_and_server_task(
) -> (RealmBuilder, fasync::Task<()>, mpsc::UnboundedReceiver<ServerRequest>) {
let (realm_proxy, realm_stream) = create_proxy_and_stream::<ftest::RealmMarker>().unwrap();
let (builder_proxy, mut builder_stream) =
create_proxy_and_stream::<ftest::BuilderMarker>().unwrap();
let builder_task = fasync::Task::spawn(async move {
while let Some(req) = builder_stream.try_next().await.unwrap() {
match req {
ftest::BuilderRequest::Build { runner, responder } => {
drop(runner);
responder.send(&mut Ok("test://hippo".to_string())).unwrap();
}
}
}
});
let (realm_report_requests, realm_receive_requests) = mpsc::unbounded();
let server_task = fasync::Task::spawn(async move {
let _builder_task = builder_task;
handle_realm_stream(realm_stream, realm_report_requests).await
});
(
RealmBuilder::build_struct(
realm_proxy,
builder_proxy,
crate::DEFAULT_COLLECTION_NAME.to_string(),
)
.unwrap(),
server_task,
realm_receive_requests,
)
}
// Checks that there are exactly `num` messages currently waiting in the `server_requests`
// stream. Returns any mpsc receivers found in ServerRequest::AddChildRealm.
fn confirm_num_server_requests(
mut server_requests: mpsc::UnboundedReceiver<ServerRequest>,
num: usize,
) -> Vec<mpsc::UnboundedReceiver<ServerRequest>> {
let mut discovered_receivers = vec![];
for i in 0..num {
match server_requests.next().now_or_never() {
Some(Some(ServerRequest::AddChildRealm { receive_requests, .. })) => {
discovered_receivers.push(receive_requests)
}
Some(Some(_)) => (),
Some(None) => panic!("server_requests ended unexpectedly"),
None => panic!("server_requests had less messages in it than we expected: {}", i),
}
}
assert_matches!(server_requests.next().now_or_never(), None);
discovered_receivers
}
fn assert_add_child_realm(
receive_server_requests: &mut mpsc::UnboundedReceiver<ServerRequest>,
expected_name: &str,
expected_options: ftest::ChildOptions,
) -> mpsc::UnboundedReceiver<ServerRequest> {
match receive_server_requests.next().now_or_never() {
Some(Some(ServerRequest::AddChildRealm { name, options, receive_requests }))
if &name == expected_name && options == expected_options =>
{
receive_requests
}
req => panic!("match failed, received unexpected server request: {:?}", req),
}
}
fn assert_read_only_directory(
receive_server_requests: &mut mpsc::UnboundedReceiver<ServerRequest>,
expected_directory_name: &str,
expected_targets: Vec<impl Into<Ref>>,
) {
let expected_targets = expected_targets
.into_iter()
.map(|t| {
let t: Ref = t.into();
t
})
.map(|t| {
let t: fdecl::Ref = t.into();
t
})
.collect::<Vec<_>>();
match receive_server_requests.next().now_or_never() {
Some(Some(ServerRequest::ReadOnlyDirectory { name, to, .. }))
if &name == expected_directory_name && to == expected_targets =>
{
return;
}
req => panic!("match failed, received unexpected server request: {:?}", req),
}
}
#[fuchsia::test]
async fn add_child() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let _child_a = builder.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_legacy_child() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let _child_a =
builder.add_legacy_child("a", "test://a", ChildOptions::new()).await.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddLegacyChild { name, legacy_url, options })
if &name == "a"
&& &legacy_url == "test://a"
&& options == ChildOptions::new().into()
);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_child_from_decl() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let _child_a = builder
.add_child_from_decl("a", cm_rust::ComponentDecl::default(), ChildOptions::new())
.await
.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddChildFromDecl { name, decl, options })
if &name == "a"
&& decl == fdecl::Component::EMPTY
&& options == ChildOptions::new().into()
);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_local_child() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let _child_a = builder
.add_local_child("a", |_| async move { Ok(()) }.boxed(), ChildOptions::new())
.await
.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddLocalChild { name, options })
if &name == "a" && options == ChildOptions::new().into()
);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_child_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm_a = builder.add_child_realm("a", ChildOptions::new()).await.unwrap();
let _child_b = child_realm_a.add_child("b", "test://b", ChildOptions::new()).await.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "a", ChildOptions::new().into());
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "b" && &url == "test://b" && options == ChildOptions::new().into()
);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn get_component_decl() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_a = builder.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
let _decl = builder.get_component_decl(&child_a).await.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::GetComponentDecl { name }) if &name == "a"
);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn replace_component_decl() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_a = builder.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
builder.replace_component_decl(&child_a, cm_rust::ComponentDecl::default()).await.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::ReplaceComponentDecl { name, component_decl })
if &name == "a" && component_decl == fdecl::Component::EMPTY
);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn get_realm_decl() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let _decl = builder.get_realm_decl().await.unwrap();
assert_matches!(receive_server_requests.next().await, Some(ServerRequest::GetRealmDecl));
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn replace_realm_decl() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
builder.replace_realm_decl(cm_rust::ComponentDecl::default()).await.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::ReplaceRealmDecl { component_decl })
if component_decl == fdecl::Component::EMPTY
);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn replace_config_value() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_a = builder.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
builder.replace_config_value_bool(&child_a, "test_bool", false).await.unwrap();
builder.replace_config_value_int16(&child_a, "test_int16", -2).await.unwrap();
builder.replace_config_value_string(&child_a, "test_string", "test").await.unwrap();
builder
.replace_config_value_string_vector(
&child_a,
"test_string_vector",
["hello", "fuchsia"],
)
.await
.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::ReplaceConfigValue { name, key, value: fconfig::ValueSpec {
value: Some(fconfig::Value::Single(fconfig::SingleValue::Bool(boolean))), ..
}}) if &name == "a" && &key == "test_bool" && boolean == false
);
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::ReplaceConfigValue { name, key, value: fconfig::ValueSpec {
value: Some(fconfig::Value::Single(fconfig::SingleValue::Int16(int16))), ..
}}) if &name == "a" && &key == "test_int16" && int16 == -2
);
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::ReplaceConfigValue { name, key, value: fconfig::ValueSpec {
value: Some(fconfig::Value::Single(fconfig::SingleValue::String(string))), ..
}}) if &name == "a" && &key == "test_string" && &string == "test"
);
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::ReplaceConfigValue { name, key, value: fconfig::ValueSpec {
value: Some(fconfig::Value::Vector(fconfig::VectorValue::StringVector(string_vector))), ..
}}) if &name == "a" && &key == "test_string_vector" && string_vector == vec!["hello", "fuchsia"]
);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_route() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_a = builder.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
builder
.add_route(
Route::new()
.capability(Capability::protocol_by_name("test"))
.capability(Capability::directory("test2"))
.from(&child_a)
.to(Ref::parent()),
)
.await
.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddRoute { capabilities, from, to })
if capabilities == vec![
Capability::protocol_by_name("test").into(),
Capability::directory("test2").into(),
]
&& from == Ref::child("a").into()
&& to == vec![Ref::parent().into()]
);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_child_to_sub_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
let _child_a = child_realm.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_legacy_child_to_sub_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
let _child_a =
child_realm.add_legacy_child("a", "test://a", ChildOptions::new()).await.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::AddLegacyChild { name, legacy_url, options })
if &name == "a"
&& &legacy_url == "test://a"
&& options == ChildOptions::new().into()
);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_child_from_decl_to_sub_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
let _child_a = child_realm
.add_child_from_decl("a", cm_rust::ComponentDecl::default(), ChildOptions::new())
.await
.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::AddChildFromDecl { name, decl, options })
if &name == "a"
&& decl == fdecl::Component::EMPTY
&& options == ChildOptions::new().into()
);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_local_child_to_sub_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
let _child_a = child_realm
.add_local_child("a", |_| async move { Ok(()) }.boxed(), ChildOptions::new())
.await
.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::AddLocalChild { name, options })
if &name == "a" && options == ChildOptions::new().into()
);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_child_realm_to_child_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
let child_realm_a = child_realm.add_child_realm("a", ChildOptions::new()).await.unwrap();
let _child_b = child_realm_a.add_child("b", "test://b", ChildOptions::new()).await.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
let mut receive_sub_sub_realm_requests = assert_add_child_realm(
&mut receive_sub_realm_requests,
"a",
ChildOptions::new().into(),
);
assert_matches!(
receive_sub_sub_realm_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "b" && &url == "test://b" && options == ChildOptions::new().into()
);
assert_matches!(receive_sub_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn get_component_decl_in_sub_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
let child_a = child_realm.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
let _decl = child_realm.get_component_decl(&child_a).await.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::GetComponentDecl { name }) if &name == "a"
);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn replace_component_decl_in_sub_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
let child_a = child_realm.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
child_realm
.replace_component_decl(&child_a, cm_rust::ComponentDecl::default())
.await
.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::ReplaceComponentDecl { name, component_decl })
if &name == "a" && component_decl == fdecl::Component::EMPTY
);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn get_realm_decl_in_sub_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
let _decl = child_realm.get_realm_decl().await.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
assert_matches!(receive_sub_realm_requests.next().await, Some(ServerRequest::GetRealmDecl));
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn replace_realm_decl_in_sub_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
child_realm.replace_realm_decl(cm_rust::ComponentDecl::default()).await.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::ReplaceRealmDecl { component_decl })
if component_decl == fdecl::Component::EMPTY
);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn add_route_in_sub_realm() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm = builder.add_child_realm("1", ChildOptions::new()).await.unwrap();
let child_a = child_realm.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
child_realm
.add_route(
Route::new()
.capability(Capability::protocol_by_name("test"))
.capability(Capability::directory("test2"))
.from(&child_a)
.to(Ref::parent()),
)
.await
.unwrap();
let mut receive_sub_realm_requests =
assert_add_child_realm(&mut receive_server_requests, "1", ChildOptions::new().into());
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_matches!(
receive_sub_realm_requests.next().await,
Some(ServerRequest::AddRoute { capabilities, from, to })
if capabilities == vec![
Capability::protocol_by_name("test").into(),
Capability::directory("test2").into(),
]
&& from == Ref::child("a").into()
&& to == vec![Ref::parent().into()]
);
assert_matches!(receive_sub_realm_requests.next().now_or_never(), None);
assert_matches!(receive_server_requests.next().now_or_never(), None);
}
#[fuchsia::test]
async fn read_only_directory() {
let (builder, _server_task, mut receive_server_requests) =
new_realm_builder_and_server_task();
let child_a = builder.add_child("a", "test://a", ChildOptions::new()).await.unwrap();
builder
.read_only_directory(
"config",
vec![&child_a],
DirectoryContents::new().add_file("config.json", "{ \"hippos\": \"rule!\" }"),
)
.await
.unwrap();
assert_matches!(
receive_server_requests.next().await,
Some(ServerRequest::AddChild { name, url, options })
if &name == "a" && &url == "test://a" && options == ChildOptions::new().into()
);
assert_read_only_directory(&mut receive_server_requests, "config", vec![&child_a]);
}
#[test]
fn realm_builder_works_with_send() {
// This test exercises realm builder on a multi-threaded executor, so that we can guarantee
// that the library works in this situation.
let mut executor = fasync::SendExecutor::new(2).expect("failed to create send executor");
executor.run(async {
let (builder, _server_task, _receive_server_requests) =
new_realm_builder_and_server_task();
let child_realm_a = builder.add_child_realm("a", ChildOptions::new()).await.unwrap();
let child_b = builder
.add_local_child("b", |_handles| pending().boxed(), ChildOptions::new())
.await
.unwrap();
let child_c = builder.add_child("c", "test://c", ChildOptions::new()).await.unwrap();
let child_d =
builder.add_legacy_child("d", "test://d.cmx", ChildOptions::new()).await.unwrap();
let child_e = builder
.add_child_from_decl("e", cm_rust::ComponentDecl::default(), ChildOptions::new())
.await
.unwrap();
let decl_for_e = builder.get_component_decl(&child_e).await.unwrap();
builder.replace_component_decl(&child_e, decl_for_e).await.unwrap();
let realm_decl = builder.get_realm_decl().await.unwrap();
builder.replace_realm_decl(realm_decl).await.unwrap();
builder
.add_route(
Route::new()
.capability(Capability::protocol::<fcomponent::RealmMarker>())
.from(&child_e)
.to(&child_d)
.to(&child_c)
.to(&child_b)
.to(&child_realm_a)
.to(Ref::parent()),
)
.await
.unwrap();
builder
.read_only_directory(
"config",
vec![&child_e],
DirectoryContents::new().add_file("config.json", "{ \"hippos\": \"rule!\" }"),
)
.await
.unwrap();
});
}
}