PcmSourceInterface.hpp

#ifndef ZEP_AUDIO_PCM_SOURCE_INTERFACE_HPP_
#define ZEP_AUDIO_PCM_SOURCE_INTERFACE_HPP_

#include <future>
#include <memory>
#include <string>
#include <vector>
#include <zep/audio/PcmBufferWriter.hpp>

#include "../SourceStreamInterface.hpp"
#include "../StreamInterface.hpp"
#include "PcmFormat.hpp"

namespace zep {

class TimestampInterface;

namespace audio {

class PcmSourceCallbackInterface;

class PcmSourceInterface : public StreamInterface,
                           public SourceStreamInterface {
 public:
  virtual void SetAcceptableFormats(const std::vector<PcmFormat>& formats) = 0;

  virtual bool GetDecidedFormat(PcmFormat& format) const noexcept = 0;

  virtual std::shared_future<PcmFormat> GetFormatDecisionStatus()
      const noexcept = 0;

  virtual std::weak_ptr<PcmBufferPoolWriterInterface> GetPcmBufferPool() = 0;

  virtual void SendStatistics(/*TODO*/) = 0;

  virtual void RegisterCallback(
      const std::shared_ptr<PcmSourceCallbackInterface>& listener,
      bool use_weak_ptr = false) = 0;

  virtual void RegisterCallback(
      std::unique_ptr<PcmSourceCallbackInterface>&& listener) = 0;

  virtual ~PcmSourceInterface() noexcept = default;
};

class PcmSourceCallbackInterface : public StreamCallbackInterface,
                                   public SourceStreamCallbackInterface {
 public:
  enum class EventType {
    kUnknown = 0,

    kDisconnected,

    kUnlinked,

    kEncodeError,

    kFailedFormatNegotiation,
  };

  virtual bool OnRequestSourceFormat(const PcmFormat& format) = 0;

  virtual void OnDecideSourceFormat(const PcmFormat* format) = 0;

  virtual void OnNotifySourceEvent(EventType type, const std::string& message) {
  }

  virtual ~PcmSourceCallbackInterface() noexcept = default;
};

}  // namespace audio
}  // namespace zep

#endif  // ZEP_AUDIO_PCM_SOURCE_INTERFACE_HPP_