1//
2//  Copyright (C) 2015 Google, Inc.
3//
4//  Licensed under the Apache License, Version 2.0 (the "License");
5//  you may not use this file except in compliance with the License.
6//  You may obtain a copy of the License at:
7//
8//  http://www.apache.org/licenses/LICENSE-2.0
9//
10//  Unless required by applicable law or agreed to in writing, software
11//  distributed under the License is distributed on an "AS IS" BASIS,
12//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13//  See the License for the specific language governing permissions and
14//  limitations under the License.
15//
16
17#include "service/gatt_client.h"
18
19#include <base/logging.h>
20
21using std::lock_guard;
22using std::mutex;
23
24namespace bluetooth {
25
26// GattClient implementation
27// ========================================================
28
29GattClient::GattClient(const UUID& uuid, int client_id)
30    : app_identifier_(uuid),
31      client_id_(client_id) {
32}
33
34GattClient::~GattClient() {
35  // Automatically unregister the client.
36  VLOG(1) << "GattClient unregistering client: " << client_id_;
37
38  hal::BluetoothGattInterface::Get()->GetClientHALInterface()->
39      unregister_client(client_id_);
40}
41
42const UUID& GattClient::GetAppIdentifier() const {
43  return app_identifier_;
44}
45
46int GattClient::GetInstanceId() const {
47  return client_id_;
48}
49
50// GattClientFactory implementation
51// ========================================================
52
53GattClientFactory::GattClientFactory() {
54  hal::BluetoothGattInterface::Get()->AddClientObserver(this);
55}
56
57GattClientFactory::~GattClientFactory() {
58  hal::BluetoothGattInterface::Get()->RemoveClientObserver(this);
59}
60
61bool GattClientFactory::RegisterInstance(
62    const UUID& uuid,
63    const RegisterCallback& callback) {
64  VLOG(1) << __func__ << " - UUID: " << uuid.ToString();
65  lock_guard<mutex> lock(pending_calls_lock_);
66
67  if (pending_calls_.find(uuid) != pending_calls_.end()) {
68    LOG(ERROR) << "GATT client with given UUID already registered - "
69               << "UUID: " << uuid.ToString();
70    return false;
71  }
72
73  const btgatt_client_interface_t* hal_iface =
74      hal::BluetoothGattInterface::Get()->GetClientHALInterface();
75  bt_uuid_t app_uuid = uuid.GetBlueDroid();
76
77  if (hal_iface->register_client(&app_uuid) != BT_STATUS_SUCCESS)
78    return false;
79
80  pending_calls_[uuid] = callback;
81
82  return true;
83}
84
85void GattClientFactory::RegisterClientCallback(
86    hal::BluetoothGattInterface* /* gatt_iface */,
87    int status, int client_id,
88    const bt_uuid_t& app_uuid) {
89  UUID uuid(app_uuid);
90
91  auto iter = pending_calls_.find(uuid);
92  if (iter == pending_calls_.end()) {
93    VLOG(1) << "Ignoring callback for unknown app_id: " << uuid.ToString();
94    return;
95  }
96
97  bool success = (status == BT_STATUS_SUCCESS);
98  BLEStatus result = success ? BLE_STATUS_SUCCESS : BLE_STATUS_FAILURE;
99
100  // No need to construct a client if the call wasn't successful.
101  std::unique_ptr<GattClient> client;
102  if (success)
103    client.reset(new GattClient(uuid, client_id));
104
105  // Notify the result via the result callback.
106  iter->second(result, uuid, std::move(client));
107
108  pending_calls_.erase(iter);
109}
110
111}  // namespace bluetooth
112