// Copyright 2017 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#pragma once

#include <fbl/unique_fd.h>
#include <async/wait.h>
#include <zircon/types.h>
#include <zx/channel.h>

#include "garnet/drivers/bluetooth/lib/hci/control_packets.h"

// Sends and receives events from a command channel that it retrieves from a
// Zircon Bluetooth HCI device.  It parses the incoming event packets, only
// returning complete and valid event packets on to the event handler set.
class CommandChannel {
 public:
  // |hcidev_path| is a path to the hci device (e.g. /dev/class/bt-hci/000)
  CommandChannel(std::string hcidev_path);
  ~CommandChannel();

  // Indicates whether this channel is valid.  This should be checked after
  // construction.
  bool is_valid() { return channel_.is_valid(); }

  using EventCallback =
      std::function<void(const bluetooth::hci::EventPacket& event_packet)>;
  // Sets the event callback to be called when an HCI Event arrives on the
  // channel.
  void SetEventCallback(const EventCallback& callback);

  // Sends the command in |command| to the controller. The channel must
  // be Ready when this is called.
  void SendCommand(
      const bluetooth::common::PacketView<bluetooth::hci::CommandHeader>&
          command);

  // Sends the command in |command| to the controller and waits for
  // an Event, which is delivered to |callback| before this function
  // returns.
  void SendCommandSync(const bluetooth::common::PacketView<
                           bluetooth::hci::CommandHeader>& command,
                       const EventCallback& callback);

 private:
  // Common read handler for signalled channels
  async_wait_result_t HandleChannelReady(const zx::channel& channel,
                                         async_t* async,
                                         zx_status_t status,
                                         const zx_packet_signal_t* signal);

  // Read ready handler for |channel_|
  async_wait_result_t OnChannelReady(async_t* async,
                                     zx_status_t status,
                                     const zx_packet_signal_t* signal);

  // Read ready handler for |acl_channel_|
  async_wait_result_t OnAclChannelReady(async_t* async, zx_status_t status, const zx_packet_signal_t* signal);

  EventCallback event_callback_;
  fbl::unique_fd hci_fd_;
  zx::channel channel_;
  async::Wait channel_wait_;
  zx::channel acl_channel_;
  async::Wait acl_channel_wait_;
};