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

#ifndef GARNET_BIN_COBALT_APP_COBALT_CONTROLLER_IMPL_H_
#define GARNET_BIN_COBALT_APP_COBALT_CONTROLLER_IMPL_H_

#include <fuchsia/cobalt/cpp/fidl.h>
#include <lib/async/cpp/task.h>

#include "third_party/cobalt/encoder/shipping_manager.h"

namespace cobalt {

class CobaltControllerImpl : public fuchsia::cobalt::Controller {
 public:
  // Does not take ownerhsip of any of the pointers in |shipping_managers|.
  // There may be more than one ShippingManager because we maintain a
  // ShippingManager for each backend to which we ship Observations.
  CobaltControllerImpl(
      async_dispatcher_t* dispatcher,
      std::vector<encoder::ShippingManager*> shipping_managers);

 private:
  void RequestSendSoon(RequestSendSoonCallback callback) override;

  void BlockUntilEmpty(uint32_t max_wait_seconds,
                       BlockUntilEmptyCallback callback) override;

  void GetNumSendAttempts(GetNumSendAttemptsCallback callback) override;

  void GetFailedSendAttempts(GetFailedSendAttemptsCallback callback) override;

  async_dispatcher_t* const dispatcher_;
  // None of the pointers in the vector below are owned by this class.
  std::vector<encoder::ShippingManager*> shipping_managers_;

  FXL_DISALLOW_COPY_AND_ASSIGN(CobaltControllerImpl);
};
}  // namespace cobalt

#endif  // GARNET_BIN_COBALT_APP_COBALT_CONTROLLER_IMPL_H_