// Copyright 2019 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#[cfg(test)]
use {
    crate::registry::device_storage::{testing::*, DeviceStorage},
    crate::switchboard::base::{PrivacyInfo, SettingType},
    crate::tests::test_failure_utils::create_test_env_with_failures,
    crate::EnvironmentBuilder,
    fidl::Error::ClientChannelClosed,
    fidl_fuchsia_settings::{Error, PrivacyMarker, PrivacyProxy},
    fuchsia_zircon::Status,
    futures::lock::Mutex,
    std::sync::Arc,
};

const ENV_NAME: &str = "settings_service_privacy_test_environment";
const CONTEXT_ID: u64 = 0;

/// Creates an environment that will fail on a get request.
async fn create_privacy_test_env_with_failures() -> PrivacyProxy {
    let storage_factory = InMemoryStorageFactory::create();
    create_test_env_with_failures(storage_factory, ENV_NAME, SettingType::Privacy)
        .await
        .connect_to_service::<PrivacyMarker>()
        .unwrap()
}

/// Creates an environment for privacy.
async fn create_test_privacy_env(
    storage_factory: Arc<Mutex<InMemoryStorageFactory>>,
) -> (PrivacyProxy, Arc<Mutex<DeviceStorage<PrivacyInfo>>>) {
    let store = storage_factory
        .lock()
        .await
        .get_device_storage::<PrivacyInfo>(StorageAccessContext::Test, CONTEXT_ID);

    let env = EnvironmentBuilder::new(storage_factory)
        .settings(&[SettingType::Privacy])
        .spawn_and_get_nested_environment(ENV_NAME)
        .await
        .unwrap();

    let privacy_service = env.connect_to_service::<PrivacyMarker>().unwrap();

    (privacy_service, store)
}

#[fuchsia_async::run_until_stalled(test)]
async fn test_privacy() {
    let initial_value = PrivacyInfo { user_data_sharing_consent: None };
    let changed_value = PrivacyInfo { user_data_sharing_consent: Some(true) };
    let factory = InMemoryStorageFactory::create();

    // Create and fetch a store from device storage so we can read stored value for testing.
    let (privacy_service, store) = create_test_privacy_env(factory).await;

    // Ensure retrieved value matches set value
    let settings = privacy_service.watch2().await.expect("watch completed");
    assert_eq!(settings.user_data_sharing_consent, initial_value.user_data_sharing_consent);

    // Ensure setting interface propagates correctly
    let mut privacy_settings = fidl_fuchsia_settings::PrivacySettings::empty();
    privacy_settings.user_data_sharing_consent = Some(true);
    privacy_service.set(privacy_settings).await.expect("set completed").expect("set successful");

    // Verify the value we set is persisted in DeviceStorage.
    let mut store_lock = store.lock().await;
    let retrieved_struct = store_lock.get().await;
    assert_eq!(changed_value, retrieved_struct);

    // Ensure retrieved value matches set value
    let settings = privacy_service.watch2().await.expect("watch completed");
    assert_eq!(settings.user_data_sharing_consent, changed_value.user_data_sharing_consent);
}

#[fuchsia_async::run_until_stalled(test)]
async fn test_channel_failure_watch() {
    let privacy_service = create_privacy_test_env_with_failures().await;
    let result = privacy_service.watch().await.ok();
    assert_eq!(result, Some(Err(Error::Failed)));
}

#[fuchsia_async::run_until_stalled(test)]
async fn test_channel_failure_watch2() {
    let privacy_service = create_privacy_test_env_with_failures().await;
    let result = privacy_service.watch2().await;
    assert!(result.is_err());
    assert_eq!(
        ClientChannelClosed(Status::INTERNAL).to_string(),
        result.err().unwrap().to_string()
    );
}

#[fuchsia_async::run_until_stalled(test)]
async fn test_simultaneous_watch() {
    let factory = InMemoryStorageFactory::create();
    let (privacy_service, _) = create_test_privacy_env(factory).await;

    let settings =
        privacy_service.watch().await.expect("watch completed").expect("watch successful");
    let settings2 = privacy_service.watch2().await.expect("watch completed");
    assert_eq!(settings, settings2);
}