examples/components/config/integration_test/rust/lib.rs

// Copyright 2022 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 diagnostics_reader::{ArchiveReader, Inspect};
use fuchsia_component_test::{Capability, ChildOptions, RealmBuilder, Ref, Route};
use fuchsia_inspect::assert_data_tree;

const CHILD_URL: &str = "#meta/config_example.cm";

#[fuchsia::test]
async fn inspect_rust() {
    let builder = RealmBuilder::new().await.unwrap();
    let config_component = builder
        .add_child("config_example_replace_none", CHILD_URL, ChildOptions::new().eager())
        .await
        .unwrap();

    builder
        .add_route(
            Route::new()
                .capability(Capability::protocol_by_name("fuchsia.logger.LogSink"))
                .from(Ref::parent())
                .to(&config_component),
        )
        .await
        .unwrap();

    let _instance = builder.build().await.unwrap();

    let inspector = ArchiveReader::new()
        .add_selector("*/config_example_replace_none:root")
        .with_minimum_schema_count(1)
        .snapshot::<Inspect>()
        .await
        .unwrap()
        .into_iter()
        .next()
        .and_then(|result| result.payload)
        .unwrap();

    assert_eq!(inspector.children.len(), 1, "selector must return exactly one child");

    // Ensure the published values match the static package definition.
    assert_data_tree!(inspector, root: {
        config: {
            greeting: "World",
            delay_ms: 100u64,
        }
    })
}

#[fuchsia::test]
async fn inspect_rust_replace_some_values() {
    let builder = RealmBuilder::new().await.unwrap();
    let config_component = builder
        .add_child("config_example_replace_some", CHILD_URL, ChildOptions::new().eager())
        .await
        .unwrap();

    builder
        .add_route(
            Route::new()
                .capability(Capability::protocol_by_name("fuchsia.logger.LogSink"))
                .from(Ref::parent())
                .to(&config_component),
        )
        .await
        .unwrap();

    // [START config_load]
    builder.init_mutable_config_from_package(&config_component).await.unwrap();
    // [END config_load]

    // [START config_replace]
    builder.set_config_value_string(&config_component, "greeting", "Fuchsia").await.unwrap();
    // [END config_replace]

    let _instance = builder.build().await.unwrap();

    let inspector = ArchiveReader::new()
        .add_selector("*/config_example_replace_some:root")
        .with_minimum_schema_count(1)
        .snapshot::<Inspect>()
        .await
        .unwrap()
        .into_iter()
        .next()
        .and_then(|result| result.payload)
        .unwrap();

    assert_eq!(inspector.children.len(), 1, "selector must return exactly one child");

    assert_data_tree!(inspector, root: {
        config: {
            greeting: "Fuchsia",
            delay_ms: 100u64,
        }
    })
}

#[fuchsia::test]
async fn inspect_rust_replace_all_values() {
    let builder = RealmBuilder::new().await.unwrap();
    let config_component = builder
        .add_child("config_example_replace_all", CHILD_URL, ChildOptions::new().eager())
        .await
        .unwrap();

    builder
        .add_route(
            Route::new()
                .capability(Capability::protocol_by_name("fuchsia.logger.LogSink"))
                .from(Ref::parent())
                .to(&config_component),
        )
        .await
        .unwrap();

    // [START config_empty]
    builder.init_mutable_config_to_empty(&config_component).await.unwrap();
    // [END config_empty]

    builder.set_config_value_string(&config_component, "greeting", "Fuchsia").await.unwrap();
    builder.set_config_value_uint64(&config_component, "delay_ms", 200).await.unwrap();

    let _instance = builder.build().await.unwrap();

    let inspector = ArchiveReader::new()
        .add_selector("*/config_example_replace_all:root")
        .with_minimum_schema_count(1)
        .snapshot::<Inspect>()
        .await
        .unwrap()
        .into_iter()
        .next()
        .and_then(|result| result.payload)
        .unwrap();

    assert_eq!(inspector.children.len(), 1, "selector must return exactly one child");

    assert_data_tree!(inspector, root: {
        config: {
            greeting: "Fuchsia",
            delay_ms: 200u64,
        }
    })
}