src/developer/forensics/crash_reports/privacy_settings_ptr.cc

// 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.

#include "src/developer/forensics/crash_reports/privacy_settings_ptr.h"

#include <lib/async/cpp/task.h>
#include <lib/fit/result.h>
#include <lib/fostr/fidl/fuchsia/settings/formatting.h>
#include <lib/syslog/cpp/macros.h>
#include <lib/zx/time.h>
#include <zircon/types.h>

#include <optional>

#include "src/developer/forensics/crash_reports/settings.h"

namespace forensics {
namespace crash_reports {

PrivacySettingsWatcher::PrivacySettingsWatcher(async_dispatcher_t* dispatcher,
                                               std::shared_ptr<sys::ServiceDirectory> services,
                                               Settings* crash_reporter_settings)
    : dispatcher_(dispatcher),
      services_(services),
      crash_reporter_settings_(crash_reporter_settings),
      retry_backoff_(/*initial_delay=*/zx::min(1), /*retry_factor=*/2u, /*max_delay=*/zx::hour(1)) {
}

void PrivacySettingsWatcher::StartWatching() {
  Connect();
  Watch();
}

void PrivacySettingsWatcher::Connect() {
  privacy_settings_ptr_ = services_->Connect<fuchsia::settings::Privacy>();
  privacy_settings_ptr_.set_error_handler([this](zx_status_t status) {
    FX_PLOGS(ERROR, status) << "Lost connection to fuchsia.settings.Privacy";
    Reset();

    retry_task_.Reset([this]() mutable { StartWatching(); });
    async::PostDelayedTask(
        dispatcher_, [retry_task = retry_task_.callback()]() { retry_task(); },
        retry_backoff_.GetNext());
  });
}

void PrivacySettingsWatcher::Watch() {
  privacy_settings_ptr_->Watch([this](fuchsia::settings::PrivacySettings settings) {
    retry_backoff_.Reset();
    privacy_settings_ = std::move(settings);
    Update();

    // We watch for the next update, following the hanging get pattern.
    Watch();
  });
}

void PrivacySettingsWatcher::Reset() {
  privacy_settings_.clear_user_data_sharing_consent();
  Update();
}

void PrivacySettingsWatcher::Update() {
  if (!privacy_settings_.has_user_data_sharing_consent()) {
    crash_reporter_settings_->set_upload_policy(Settings::UploadPolicy::LIMBO);
  } else if (privacy_settings_.user_data_sharing_consent()) {
    crash_reporter_settings_->set_upload_policy(Settings::UploadPolicy::ENABLED);
  } else {
    crash_reporter_settings_->set_upload_policy(Settings::UploadPolicy::DISABLED);
  }
}

}  // namespace crash_reports
}  // namespace forensics