// Copyright (c) 2011 The Chromium 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 "chrome/browser/chromeos/dbus/bluetooth_manager_client.h"

#include "base/bind.h"
#include "base/logging.h"
#include "chrome/browser/chromeos/system/runtime_environment.h"
#include "dbus/bus.h"
#include "dbus/message.h"
#include "dbus/object_proxy.h"
#include "third_party/cros_system_api/dbus/service_constants.h"

namespace chromeos {

// The BluetoothManagerClient implementation used in production.
class BluetoothManagerClientImpl : public BluetoothManagerClient {
 public:
  explicit BluetoothManagerClientImpl(dbus::Bus* bus)
      : weak_ptr_factory_(this),
        bluetooth_manager_proxy_(NULL) {
    VLOG(1) << "Creating BluetoothManagerClientImpl";

    DCHECK(bus);

    bluetooth_manager_proxy_ = bus->GetObjectProxy(
        bluetooth_manager::kBluetoothManagerServiceName,
        bluetooth_manager::kBluetoothManagerServicePath);

    bluetooth_manager_proxy_->ConnectToSignal(
        bluetooth_manager::kBluetoothManagerInterface,
        bluetooth_manager::kAdapterRemovedSignal,
        base::Bind(&BluetoothManagerClientImpl::AdapterRemovedReceived,
                   weak_ptr_factory_.GetWeakPtr()),
        base::Bind(&BluetoothManagerClientImpl::AdapterRemovedConnected,
                   weak_ptr_factory_.GetWeakPtr()));

    bluetooth_manager_proxy_->ConnectToSignal(
        bluetooth_manager::kBluetoothManagerInterface,
        bluetooth_manager::kDefaultAdapterChangedSignal,
        base::Bind(&BluetoothManagerClientImpl::DefaultAdapterChangedReceived,
                   weak_ptr_factory_.GetWeakPtr()),
        base::Bind(&BluetoothManagerClientImpl::DefaultAdapterChangedConnected,
                   weak_ptr_factory_.GetWeakPtr()));
  }

  virtual ~BluetoothManagerClientImpl() {
  }

  // BluetoothManagerClient override.
  virtual void AddObserver(Observer* observer) {
    VLOG(1) << "AddObserver";
    DCHECK(observer);
    observers_.AddObserver(observer);
  }

  // BluetoothManagerClient override.
  virtual void RemoveObserver(Observer* observer) {
    VLOG(1) << "RemoveObserver";
    DCHECK(observer);
    observers_.RemoveObserver(observer);
  }

  // BluetoothManagerClient override.
  virtual void DefaultAdapter(const DefaultAdapterCallback& callback) {
    LOG(INFO) << "DefaultAdapter";

    dbus::MethodCall method_call(
      bluetooth_manager::kBluetoothManagerInterface,
      bluetooth_manager::kDefaultAdapter);

    DCHECK(bluetooth_manager_proxy_);
    bluetooth_manager_proxy_->CallMethod(
      &method_call,
      dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
      base::Bind(&BluetoothManagerClientImpl::OnDefaultAdapter,
                 weak_ptr_factory_.GetWeakPtr(), callback));
  }

 private:
  // Called by dbus:: when an AdapterRemoved signal is received.
  void AdapterRemovedReceived(dbus::Signal* signal) {
    DCHECK(signal);
    dbus::MessageReader reader(signal);
    std::string adapter;
    if (!reader.PopObjectPath(&adapter)) {
      LOG(ERROR) << "AdapterRemoved signal has incorrect parameters: "
          << signal->ToString();
      return;
    }
    VLOG(1) << "Adapter removed: " << adapter;
    FOR_EACH_OBSERVER(Observer, observers_, AdapterRemoved(adapter));
  }

  // Called by dbus:: when the AdapterRemoved signal is initially connected.
  void AdapterRemovedConnected(const std::string& interface_name,
                               const std::string& signal_name,
                               bool success) {
    LOG_IF(WARNING, !success) << "Failed to connect to AdapterRemoved signal.";
  }

  // Called by dbus:: when a DefaultAdapterChanged signal is received.
  void DefaultAdapterChangedReceived(dbus::Signal* signal) {
    DCHECK(signal);
    dbus::MessageReader reader(signal);
    std::string adapter;
    if (!reader.PopObjectPath(&adapter)) {
      LOG(ERROR) << "DefaultAdapterChanged signal has incorrect parameters: "
          << signal->ToString();
      return;
    }
    VLOG(1) << "Default adapter changed: " << adapter;
    FOR_EACH_OBSERVER(Observer, observers_, DefaultAdapterChanged(adapter));
  }

  // Called by dbus:: when the DefaultAdapterChanged signal is initially
  // connected.
  void DefaultAdapterChangedConnected(const std::string& interface_name,
                                      const std::string& signal_name,
                                      bool success) {
    LOG_IF(WARNING, !success)
        << "Failed to connect to DefaultAdapterChanged signal.";
  }

  // Called when a response for DefaultAdapter() is received.
  void OnDefaultAdapter(const DefaultAdapterCallback& callback,
                        dbus::Response* response) {
    // Parse response.
    bool success = false;
    std::string adapter;
    if (response != NULL) {
      dbus::MessageReader reader(response);
      if (!reader.PopObjectPath(&adapter)) {
        LOG(ERROR) << "DefaultAdapter response has incorrect parameters: "
            << response->ToString();
      } else {
        success = true;
        LOG(INFO) << "OnDefaultAdapter: " << adapter;
      }
    } else {
      LOG(ERROR) << "Failed to get default adapter.";
    }

    // Notify client.
    callback.Run(adapter, success);
  }

  // Weak pointer factory for generating 'this' pointers that might live longer
  // than we do.
  base::WeakPtrFactory<BluetoothManagerClientImpl> weak_ptr_factory_;

  // D-Bus proxy for BlueZ Manager interface.
  dbus::ObjectProxy* bluetooth_manager_proxy_;

  // List of observers interested in event notifications from us.
  ObserverList<Observer> observers_;

  DISALLOW_COPY_AND_ASSIGN(BluetoothManagerClientImpl);
};

// The BluetoothManagerClient implementation used on Linux desktop, which does
// nothing.
class BluetoothManagerClientStubImpl : public BluetoothManagerClient {
 public:
  // BluetoothManagerClient override.
  virtual void AddObserver(Observer* observer) {
  }

  // BluetoothManagerClient override.
  virtual void RemoveObserver(Observer* observer) {
  }

  // BluetoothManagerClient override.
  virtual void DefaultAdapter(const DefaultAdapterCallback& callback) {
    VLOG(1) << "Requested default adapter.";
  }
};

BluetoothManagerClient::BluetoothManagerClient() {
}

BluetoothManagerClient::~BluetoothManagerClient() {
}

BluetoothManagerClient* BluetoothManagerClient::Create(dbus::Bus* bus) {
  if (system::runtime_environment::IsRunningOnChromeOS()) {
    return new BluetoothManagerClientImpl(bus);
  } else {
    return new BluetoothManagerClientStubImpl();
  }
}

}  // namespace chromeos