Home | History | Annotate | Download | only in dbus 
      1 // Copyright 2014 The Chromium Authors. All rights reserved.
      2 // Use of this source code is governed by a BSD-style license that can be
      3 // found in the LICENSE file.
      4 
      5 #include "chromeos/dbus/bluetooth_gatt_manager_client.h"
      6 
      7 #include "base/bind.h"
      8 #include "base/memory/weak_ptr.h"
      9 #include "dbus/bus.h"
     10 #include "dbus/message.h"
     11 #include "dbus/object_proxy.h"
     12 #include "third_party/cros_system_api/dbus/service_constants.h"
     13 
     14 namespace chromeos {
     15 
     16 const char BluetoothGattManagerClient::kNoResponseError[] =
     17     "org.chromium.Error.NoResponse";
     18 
     19 // The BluetoothGattManagerClient implementation used in production.
     20 class BluetoothGattManagerClientImpl : public BluetoothGattManagerClient {
     21  public:
     22   BluetoothGattManagerClientImpl()
     23       : object_proxy_(NULL),
     24         weak_ptr_factory_(this) {
     25   }
     26 
     27   virtual ~BluetoothGattManagerClientImpl() {
     28   }
     29 
     30   // BluetoothGattManagerClient override.
     31   virtual void RegisterService(const dbus::ObjectPath& service_path,
     32                                const Options& options,
     33                                const base::Closure& callback,
     34                                const ErrorCallback& error_callback) OVERRIDE {
     35     dbus::MethodCall method_call(
     36         bluetooth_gatt_manager::kBluetoothGattManagerInterface,
     37         bluetooth_gatt_manager::kRegisterService);
     38 
     39     dbus::MessageWriter writer(&method_call);
     40     writer.AppendObjectPath(service_path);
     41 
     42     // TODO(armansito): The parameters of the Options dictionary are undefined
     43     // but the method signature still requires a value dictionary. Pass an
     44     // empty dictionary and fill in the contents later once this is defined.
     45     dbus::MessageWriter array_writer(NULL);
     46     writer.OpenArray("{sv}", &array_writer);
     47     writer.CloseContainer(&array_writer);
     48 
     49     DCHECK(object_proxy_);
     50     object_proxy_->CallMethodWithErrorCallback(
     51         &method_call,
     52         dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
     53         base::Bind(&BluetoothGattManagerClientImpl::OnSuccess,
     54                    weak_ptr_factory_.GetWeakPtr(), callback),
     55         base::Bind(&BluetoothGattManagerClientImpl::OnError,
     56                    weak_ptr_factory_.GetWeakPtr(), error_callback));
     57   }
     58 
     59   // BluetoothGattManagerClient override.
     60   virtual void UnregisterService(const dbus::ObjectPath& service_path,
     61                                  const base::Closure& callback,
     62                                  const ErrorCallback& error_callback) OVERRIDE {
     63     dbus::MethodCall method_call(
     64         bluetooth_gatt_manager::kBluetoothGattManagerInterface,
     65         bluetooth_gatt_manager::kUnregisterService);
     66 
     67     dbus::MessageWriter writer(&method_call);
     68     writer.AppendObjectPath(service_path);
     69 
     70     DCHECK(object_proxy_);
     71     object_proxy_->CallMethodWithErrorCallback(
     72         &method_call,
     73         dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
     74         base::Bind(&BluetoothGattManagerClientImpl::OnSuccess,
     75                    weak_ptr_factory_.GetWeakPtr(), callback),
     76         base::Bind(&BluetoothGattManagerClientImpl::OnError,
     77                    weak_ptr_factory_.GetWeakPtr(), error_callback));
     78   }
     79 
     80  protected:
     81   // chromeos::DBusClient override.
     82   virtual void Init(dbus::Bus* bus) OVERRIDE {
     83     DCHECK(bus);
     84     object_proxy_ = bus->GetObjectProxy(
     85         bluetooth_gatt_manager::kBluetoothGattManagerServiceName,
     86         dbus::ObjectPath(
     87             bluetooth_gatt_manager::kBluetoothGattManagerInterface));
     88   }
     89 
     90  private:
     91   // Called when a response for a successful method call is received.
     92   void OnSuccess(const base::Closure& callback, dbus::Response* response) {
     93     DCHECK(response);
     94     callback.Run();
     95   }
     96 
     97   // Called when a response for a failed method call is received.
     98   void OnError(const ErrorCallback& error_callback,
     99                dbus::ErrorResponse* response) {
    100     // Error response has optional error message argument.
    101     std::string error_name;
    102     std::string error_message;
    103     if (response) {
    104       dbus::MessageReader reader(response);
    105       error_name = response->GetErrorName();
    106       reader.PopString(&error_message);
    107     } else {
    108       error_name = kNoResponseError;
    109     }
    110     error_callback.Run(error_name, error_message);
    111   }
    112 
    113   // The proxy to the remote GATT manager object.
    114   dbus::ObjectProxy* object_proxy_;
    115 
    116   // Weak pointer factory for generating 'this' pointers that might live longer
    117   // than we do.
    118   // Note: This should remain the last member so it'll be destroyed and
    119   // invalidate its weak pointers before any other members are destroyed.
    120   base::WeakPtrFactory<BluetoothGattManagerClientImpl> weak_ptr_factory_;
    121 
    122   DISALLOW_COPY_AND_ASSIGN(BluetoothGattManagerClientImpl);
    123 };
    124 
    125 BluetoothGattManagerClient::BluetoothGattManagerClient() {
    126 }
    127 
    128 BluetoothGattManagerClient::~BluetoothGattManagerClient() {
    129 }
    130 
    131 // static
    132 BluetoothGattManagerClient* BluetoothGattManagerClient::Create() {
    133   return new BluetoothGattManagerClientImpl();
    134 }
    135 
    136 }  // namespace chromeos
    137