src/connectivity/bluetooth/core/bt-host/testing/controller_test_double_base.cc

// 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.

#include "src/connectivity/bluetooth/core/bt-host/public/pw_bluetooth_sapphire/internal/host/testing/controller_test_double_base.h"

namespace bt::testing {

ControllerTestDoubleBase::ControllerTestDoubleBase(
    pw::async::Dispatcher& pw_dispatcher)
    : pw_dispatcher_(pw_dispatcher), heap_dispatcher_(pw_dispatcher) {}

ControllerTestDoubleBase::~ControllerTestDoubleBase() {
  // When this destructor gets called any subclass state will be undefined. If
  // Stop() has not been called before reaching this point this can cause
  // runtime errors when our event loop handlers attempt to invoke the pure
  // virtual methods of this class.
}

bool ControllerTestDoubleBase::SendCommandChannelPacket(
    const ByteBuffer& packet) {
  if (!event_cb_) {
    return false;
  }

  // Post packet to simulate async behavior that many tests expect.
  DynamicByteBuffer buffer(packet);
  auto self = weak_self_.GetWeakPtr();
  (void)heap_dispatcher().Post(
      [self, buffer = std::move(buffer)](pw::async::Context /*ctx*/,
                                         pw::Status status) {
        if (self.is_alive() && status.ok()) {
          self->event_cb_({reinterpret_cast<const std::byte*>(buffer.data()),
                           buffer.size()});
        }
      });
  return true;
}

bool ControllerTestDoubleBase::SendACLDataChannelPacket(
    const ByteBuffer& packet) {
  if (!acl_cb_) {
    return false;
  }

  // Post packet to simulate async behavior that some tests expect.
  DynamicByteBuffer buffer(packet);
  auto self = weak_self_.GetWeakPtr();
  (void)heap_dispatcher().Post(
      [self, buffer = std::move(buffer)](pw::async::Context /*ctx*/,
                                         pw::Status status) {
        if (self.is_alive() && status.ok()) {
          self->acl_cb_({reinterpret_cast<const std::byte*>(buffer.data()),
                         buffer.size()});
        }
      });
  return true;
}

bool ControllerTestDoubleBase::SendScoDataChannelPacket(
    const ByteBuffer& packet) {
  if (!sco_cb_) {
    return false;
  }

  sco_cb_({reinterpret_cast<const std::byte*>(packet.data()), packet.size()});
  return true;
}

void ControllerTestDoubleBase::Initialize(PwStatusCallback complete_callback,
                                          PwStatusCallback error_callback) {
  error_cb_ = std::move(error_callback);
  complete_callback(PW_STATUS_OK);
}

void ControllerTestDoubleBase::Close(PwStatusCallback callback) {
  event_cb_ = nullptr;
  acl_cb_ = nullptr;
  sco_cb_ = nullptr;
  callback(PW_STATUS_OK);
}

void ControllerTestDoubleBase::ConfigureSco(
    ScoCodingFormat coding_format,
    ScoEncoding encoding,
    ScoSampleRate sample_rate,
    pw::Callback<void(pw::Status)> callback) {
  if (!configure_sco_cb_) {
    return;
  }

  // Post the callback to simulate async behavior with a real controller.
  auto callback_wrapper =
      [dispatcher = &pw_dispatcher_,
       cb = std::move(callback)](pw::Status cb_status) mutable {
        (void)pw::async::HeapDispatcher(*dispatcher)
            .Post([cb_status, cb = std::move(cb)](pw::async::Context /*ctx*/,
                                                  pw::Status status) mutable {
              if (status.ok()) {
                cb(cb_status);
              }
            });
      };
  configure_sco_cb_(
      coding_format, encoding, sample_rate, std::move(callback_wrapper));
}

void ControllerTestDoubleBase::ResetSco(
    pw::Callback<void(pw::Status)> callback) {
  if (!reset_sco_cb_) {
    return;
  }

  // Post the callback to simulate async behavior with a real controller.
  auto callback_wrapper =
      [dispatcher = &pw_dispatcher_,
       cb = std::move(callback)](pw::Status cb_status) mutable {
        (void)pw::async::HeapDispatcher(*dispatcher)
            .Post([cb_status, cb = std::move(cb)](pw::async::Context /*ctx*/,
                                                  pw::Status status) mutable {
              if (status.ok()) {
                cb(cb_status);
              }
            });
      };
  reset_sco_cb_(std::move(callback_wrapper));
}

}  // namespace bt::testing