//
//  Copyright (C) 2015 Google, Inc.
//
//  Licensed under the Apache License, Version 2.0 (the "License");
//  you may not use this file except in compliance with the License.
//  You may obtain a copy of the License at:
//
//  http://www.apache.org/licenses/LICENSE-2.0
//
//  Unless required by applicable law or agreed to in writing, software
//  distributed under the License is distributed on an "AS IS" BASIS,
//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//  See the License for the specific language governing permissions and
//  limitations under the License.
//

#include "service/common/bluetooth/binder/IBluetoothLowEnergyCallback.h"

#include <base/logging.h>
#include <binder/Parcel.h>

#include "service/common/bluetooth/binder/parcel_helpers.h"

using android::IBinder;
using android::Parcel;
using android::sp;
using android::status_t;

using bluetooth::AdvertiseData;
using bluetooth::AdvertiseSettings;

namespace ipc {
namespace binder {

// static
const char IBluetoothLowEnergyCallback::kServiceName[] =
    "bluetooth-low-energy-callback-service";

// BnBluetoothLowEnergyCallback (server) implementation
// ========================================================

status_t BnBluetoothLowEnergyCallback::onTransact(
    uint32_t code,
    const Parcel& data,
    Parcel* reply,
    uint32_t flags) {
  VLOG(2) << "IBluetoothLowEnergyCallback: " << code;
  if (!data.checkInterface(this))
    return android::PERMISSION_DENIED;

  switch (code) {
  case ON_CLIENT_REGISTERED_TRANSACTION: {
    int status = data.readInt32();
    int client_if = data.readInt32();
    OnClientRegistered(status, client_if);
    return android::NO_ERROR;
  }
  case ON_CONNECTION_STATE_TRANSACTION: {
    int status = data.readInt32();
    int client_id = data.readInt32();
    const char* address = data.readCString();
    bool connected = data.readBool();

    OnConnectionState(status, client_id, address, connected);
    return android::NO_ERROR;
  }
  case ON_MTU_CHANGED_TRANSACTION: {
    int status = data.readInt32();
    const char *address = data.readCString();
    int mtu = data.readInt32();

    OnMtuChanged(status, address, mtu);
    return android::NO_ERROR;
  }
  case ON_SEARCH_COMPLETE_TRANSACTION: {
    int status = data.readInt32();
    const char *address = data.readCString();

    OnServicesDiscovered(status, address);
    return android::NO_ERROR;
  }
  case ON_GATT_DB_UPDATED_TRANSACTION: {
    const char *address = data.readCString();
    btgatt_db_element_t* db;
    int size;
    CreateBtGattDbArrayFromParcel(data, &db, &size);
    OnGattDbUpdated(address, db, size);
    return android::NO_ERROR;
  }
  case ON_CHARACTERISTIC_READ_TRANSACTION: {
    const char *address = data.readCString();
    int status = data.readInt32();
    btgatt_read_params_t* p_data;
    CreateBtGattReadParamsFromParcel(data, &p_data);
    OnCharacteristicRead(address, status, p_data);
    return android::NO_ERROR;
  }
  case ON_CHARACTERISTIC_WRITE_TRANSACTION: {
    const char *address = data.readCString();
    int status = data.readInt32();
    uint16_t handle = (uint16_t) data.readInt32();
    OnCharacteristicWrite(address, status, handle);
    return android::NO_ERROR;
  }
  case ON_DESCRIPTOR_WRITE_TRANSACTION: {
    const char *address = data.readCString();
    int status = data.readInt32();
    uint16_t handle = (uint16_t) data.readInt32();
    OnDescriptorWrite(address, status, handle);
    return android::NO_ERROR;
  }
  case ON_REGISTER_FOR_NOTIFICATION_CALLBACK_TRANSACTION: {
    const char *address = data.readCString();
    int registered = data.readInt32();
    int status = data.readInt32();
    uint16_t handle = (uint16_t) data.readInt32();
    OnCharacteristicNotificationRegistration(address, registered, status, handle);
    return android::NO_ERROR;
  }
  case ON_NOTIFY_TRANSACTION: {
    const char *address = data.readCString();
    btgatt_notify_params_t* notification;
    CreateBtGattNotifyParamsFromParcel(data, &notification);
    OnCharacteristicChanged(address, notification);
    return android::NO_ERROR;
  }
  case ON_SCAN_RESULT_TRANSACTION: {
    auto scan_result = CreateScanResultFromParcel(data);
    CHECK(scan_result.get());
    OnScanResult(*scan_result);
    return android::NO_ERROR;
  }
  case ON_MULTI_ADVERTISE_CALLBACK_TRANSACTION: {
    int status = data.readInt32();
    bool is_start = data.readInt32();
    std::unique_ptr<AdvertiseSettings> settings =
        CreateAdvertiseSettingsFromParcel(data);
    OnMultiAdvertiseCallback(status, is_start, *settings);
    return android::NO_ERROR;
  }
  default:
    return BBinder::onTransact(code, data, reply, flags);
  }
}

// BpBluetoothLowEnergyCallback (client) implementation
// ========================================================

BpBluetoothLowEnergyCallback::BpBluetoothLowEnergyCallback(
    const sp<IBinder>& impl)
    : BpInterface<IBluetoothLowEnergyCallback>(impl) {
}

void BpBluetoothLowEnergyCallback::OnClientRegistered(
    int status, int client_if) {
  Parcel data, reply;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeInt32(status);
  data.writeInt32(client_if);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_CLIENT_REGISTERED_TRANSACTION,
      data, &reply,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnConnectionState(
    int status, int client_id, const char* address, bool connected) {

  Parcel data;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeInt32(status);
  data.writeInt32(client_id);
  data.writeCString(address);
  data.writeBool(connected);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_CONNECTION_STATE_TRANSACTION,
      data, NULL,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnMtuChanged(
    int status, const char* address, int mtu) {
  Parcel data;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeInt32(status);
  data.writeCString(address);
  data.writeInt32(mtu);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_MTU_CHANGED_TRANSACTION,
      data, NULL,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnServicesDiscovered(
    int status, const char* address) {
  Parcel data;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeInt32(status);
  data.writeCString(address);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_SEARCH_COMPLETE_TRANSACTION,
      data, NULL,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnGattDbUpdated(
     const char* address, btgatt_db_element_t* db, int size) {
  Parcel data;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeCString(address);
  WriteBtGattDbArrayToParcel(db, size, &data);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_GATT_DB_UPDATED_TRANSACTION,
      data, NULL,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnCharacteristicRead(
    const char* address, int status, btgatt_read_params_t* p_data) {
  Parcel data;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeCString(address);
  data.writeInt32(status);
  WriteBtGattReadParamsToParcel(p_data, &data);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_CHARACTERISTIC_READ_TRANSACTION,
      data, NULL,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnCharacteristicWrite(
    const char* address, int status, uint16_t handle) {
  Parcel data;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeCString(address);
  data.writeInt32(status);
  data.writeInt32(handle);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_CHARACTERISTIC_WRITE_TRANSACTION,
      data, NULL,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnDescriptorWrite(
    const char* address, int status, uint16_t handle) {
  Parcel data;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeCString(address);
  data.writeInt32(status);
  data.writeInt32(handle);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_DESCRIPTOR_WRITE_TRANSACTION,
      data, NULL,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnCharacteristicNotificationRegistration(
    const char* address, int registered, int status, uint16_t handle) {
  Parcel data;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeCString(address);
  data.writeInt32(registered);
  data.writeInt32(status);
  data.writeInt32(handle);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_REGISTER_FOR_NOTIFICATION_CALLBACK_TRANSACTION,
      data, NULL,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnCharacteristicChanged(
    const char* address, btgatt_notify_params_t* notification) {
  Parcel data;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeCString(address);
  WriteBtGattNotifyParamsToParcel(notification, &data);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_NOTIFY_TRANSACTION,
      data, NULL,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnScanResult(
    const bluetooth::ScanResult& scan_result) {
  Parcel data, reply;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  WriteScanResultToParcel(scan_result, &data);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_SCAN_RESULT_TRANSACTION,
      data, &reply,
      IBinder::FLAG_ONEWAY);
}

void BpBluetoothLowEnergyCallback::OnMultiAdvertiseCallback(
    int status, bool is_start,
    const AdvertiseSettings& settings) {
  Parcel data, reply;

  data.writeInterfaceToken(
      IBluetoothLowEnergyCallback::getInterfaceDescriptor());
  data.writeInt32(status);
  data.writeInt32(is_start);
  WriteAdvertiseSettingsToParcel(settings, &data);

  remote()->transact(
      IBluetoothLowEnergyCallback::ON_MULTI_ADVERTISE_CALLBACK_TRANSACTION,
      data, &reply,
      IBinder::FLAG_ONEWAY);
}

IMPLEMENT_META_INTERFACE(BluetoothLowEnergyCallback,
                         IBluetoothLowEnergyCallback::kServiceName);

}  // namespace binder
}  // namespace ipc