#ifndef MS_RTC_AUDIO_LEVEL_OBSERVER_HPP
#define MS_RTC_AUDIO_LEVEL_OBSERVER_HPP
#include "handles/TimerHandleInterface.hpp"
#include "RTC/RtpObserver.hpp"
#include "SharedInterface.hpp"
#include <absl/container/flat_hash_map.h>
namespace RTC
{
class AudioLevelObserver : public RTC::RtpObserver, public TimerHandleInterface::Listener
{
private:
struct DBovs
{
uint16_t totalSum{ 0u }; size_t count{ 0u }; };
public:
AudioLevelObserver(
SharedInterface* shared,
const std::string& id,
RTC::RtpObserver::Listener* listener,
const FBS::AudioLevelObserver::AudioLevelObserverOptions* options);
~AudioLevelObserver() override;
public:
void AddProducer(RTC::Producer* producer) override;
void RemoveProducer(RTC::Producer* producer) override;
void ReceiveRtpPacket(RTC::Producer* producer, RTC::RTP::Packet* packet) override;
void ProducerPaused(RTC::Producer* producer) override;
void ProducerResumed(RTC::Producer* producer) override;
private:
void Paused() override;
void Resumed() override;
void Update();
void ResetMapProducerDBovs();
protected:
void OnTimer(TimerHandleInterface* timer) override;
private:
uint16_t maxEntries{ 1u };
int8_t threshold{ -80 };
uint16_t interval{ 1000u };
TimerHandleInterface* periodicTimer{ nullptr };
absl::flat_hash_map<RTC::Producer*, DBovs> mapProducerDBovs;
bool silence{ true };
};
}
#endif