// Copyright 2022 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "chrome/services/system_signals/public/cpp/browser/system_signals_service_host_impl.h"

#include "base/check.h"
#include "base/time/time.h"
#include "chrome/grit/generated_resources.h"  // nogncheck
#include "components/device_signals/core/common/mojom/system_signals.mojom.h"
#include "content/public/browser/service_process_host.h"  // nogncheck

namespace system_signals {

SystemSignalsServiceHostImpl::SystemSignalsServiceHostImpl() = default;
SystemSignalsServiceHostImpl::~SystemSignalsServiceHostImpl() = default;

device_signals::mojom::SystemSignalsService*
SystemSignalsServiceHostImpl::GetService() {
  // To prevent any impact on Chrome's stability and memory footprint, run
  // this service in its own process on Windows (since it interacts with, e.g.,
  // WMI).
  if (!remote_service_) {
    remote_service_ = content::ServiceProcessHost::Launch<
        device_signals::mojom::SystemSignalsService>(
        content::ServiceProcessHost::Options()
            .WithDisplayName(IDS_UTILITY_PROCESS_SYSTEM_SIGNALS_NAME)
            .Pass());
    DCHECK(remote_service_);

    remote_service_.reset_on_idle_timeout(base::Seconds(10));
    remote_service_.set_disconnect_handler(
        base::BindOnce(&SystemSignalsServiceHostImpl::NotifyServiceDisconnect,
                       weak_factory_.GetWeakPtr()));
  }

  return remote_service_.get();
}

void SystemSignalsServiceHostImpl::AddObserver(
    device_signals::SystemSignalsServiceHost::Observer* observer) {
  DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
  observers_.AddObserver(observer);
}

void SystemSignalsServiceHostImpl::RemoveObserver(
    device_signals::SystemSignalsServiceHost::Observer* observer) {
  DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
  observers_.RemoveObserver(observer);
}

void SystemSignalsServiceHostImpl::NotifyServiceDisconnect() {
  DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
  observers_.Notify(
      &device_signals::SystemSignalsServiceHost::Observer::OnServiceDisconnect);
}

void SystemSignalsServiceHostImpl::BindRemoteForTesting(
    mojo::PendingRemote<device_signals::mojom::SystemSignalsService> remote) {
  remote_service_.Bind(std::move(remote));
  remote_service_.set_disconnect_handler(
      base::BindOnce(&SystemSignalsServiceHostImpl::NotifyServiceDisconnect,
                     weak_factory_.GetWeakPtr()));
}

}  // namespace system_signals