diagnostics/cros_healthd/events/bluetooth_events_impl.cc

// Copyright 2020 The Chromium OS 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 "diagnostics/cros_healthd/events/bluetooth_events_impl.h"

#include <utility>

#include <base/check.h>

namespace diagnostics {

BluetoothEventsImpl::BluetoothEventsImpl(Context* context) : context_(context) {
  DCHECK(context_);
}

BluetoothEventsImpl::~BluetoothEventsImpl() {
  if (is_observing_bluetooth_client_)
    context_->bluetooth_client()->RemoveObserver(this);
}

void BluetoothEventsImpl::AddObserver(
    mojo::PendingRemote<
        chromeos::cros_healthd::mojom::CrosHealthdBluetoothObserver> observer) {
  if (!is_observing_bluetooth_client_) {
    context_->bluetooth_client()->AddObserver(this);
    is_observing_bluetooth_client_ = true;
  }

  observers_.Add(std::move(observer));
}

void BluetoothEventsImpl::AdapterAdded(
    const dbus::ObjectPath& adapter_path,
    const BluetoothClient::AdapterProperties& properties) {
  for (auto& observer : observers_)
    observer->OnAdapterAdded();
  StopObservingBluetoothClientIfNecessary();
}

void BluetoothEventsImpl::AdapterRemoved(const dbus::ObjectPath& adapter_path) {
  for (auto& observer : observers_)
    observer->OnAdapterRemoved();
  StopObservingBluetoothClientIfNecessary();
}

void BluetoothEventsImpl::AdapterPropertyChanged(
    const dbus::ObjectPath& adapter_path,
    const BluetoothClient::AdapterProperties& properties) {
  for (auto& observer : observers_)
    observer->OnAdapterPropertyChanged();
  StopObservingBluetoothClientIfNecessary();
}

void BluetoothEventsImpl::DeviceAdded(
    const dbus::ObjectPath& device_path,
    const BluetoothClient::DeviceProperties& properties) {
  for (auto& observer : observers_)
    observer->OnDeviceAdded();
  StopObservingBluetoothClientIfNecessary();
}

void BluetoothEventsImpl::DeviceRemoved(const dbus::ObjectPath& device_path) {
  for (auto& observer : observers_)
    observer->OnDeviceRemoved();
  StopObservingBluetoothClientIfNecessary();
}

void BluetoothEventsImpl::DevicePropertyChanged(
    const dbus::ObjectPath& device_path,
    const BluetoothClient::DeviceProperties& properties) {
  for (auto& observer : observers_)
    observer->OnDevicePropertyChanged();
  StopObservingBluetoothClientIfNecessary();
}

void BluetoothEventsImpl::StopObservingBluetoothClientIfNecessary() {
  if (!observers_.empty())
    return;

  context_->bluetooth_client()->RemoveObserver(this);
  is_observing_bluetooth_client_ = false;
}

}  // namespace diagnostics