#include "config.h"
#if ENABLE(WEB_RTC)
#include "RTCDTMFSender.h"
#include "ExceptionCode.h"
#include "MediaStreamTrack.h"
#include "RTCDTMFSenderHandler.h"
#include "RTCDTMFToneChangeEvent.h"
#include "RTCPeerConnectionHandler.h"
#include "ScriptExecutionContext.h"
namespace WebCore {
static const long minToneDurationMs = 40;
static const long defaultToneDurationMs = 100;
static const long maxToneDurationMs = 6000;
static const long minInterToneGapMs = 30;
static const long defaultInterToneGapMs = 70;
RefPtr<RTCDTMFSender> RTCDTMFSender::create(ScriptExecutionContext* context, RTCPeerConnectionHandler* peerConnectionHandler, PassRefPtr<MediaStreamTrack> prpTrack, ExceptionCode& ec)
{
RefPtr<MediaStreamTrack> track = prpTrack;
std::unique_ptr<RTCDTMFSenderHandler> handler = peerConnectionHandler->createDTMFSender(&track->source());
if (!handler) {
ec = NOT_SUPPORTED_ERR;
return nullptr;
}
RefPtr<RTCDTMFSender> dtmfSender = adoptRef(new RTCDTMFSender(context, track, WTFMove(handler)));
dtmfSender->suspendIfNeeded();
return dtmfSender;
}
RTCDTMFSender::RTCDTMFSender(ScriptExecutionContext* context, PassRefPtr<MediaStreamTrack> track, std::unique_ptr<RTCDTMFSenderHandler> handler)
: ActiveDOMObject(context)
, m_track(track)
, m_duration(defaultToneDurationMs)
, m_interToneGap(defaultInterToneGapMs)
, m_handler(WTFMove(handler))
, m_stopped(false)
, m_scheduledEventTimer(*this, &RTCDTMFSender::scheduledEventTimerFired)
{
m_handler->setClient(this);
}
RTCDTMFSender::~RTCDTMFSender()
{
}
bool RTCDTMFSender::canInsertDTMF() const
{
return m_handler->canInsertDTMF();
}
MediaStreamTrack* RTCDTMFSender::track() const
{
return m_track.get();
}
String RTCDTMFSender::toneBuffer() const
{
return m_handler->currentToneBuffer();
}
void RTCDTMFSender::insertDTMF(const String& tones, Optional<int> duration, Optional<int> interToneGap, ExceptionCode& ec)
{
if (!canInsertDTMF()) {
ec = NOT_SUPPORTED_ERR;
return;
}
if (duration && (duration.value() > maxToneDurationMs || duration.value() < minToneDurationMs)) {
ec = SYNTAX_ERR;
return;
}
if (interToneGap && interToneGap.value() < minInterToneGapMs) {
ec = SYNTAX_ERR;
return;
}
m_duration = duration.valueOr(defaultToneDurationMs);
m_interToneGap = interToneGap.valueOr(defaultInterToneGapMs);
if (!m_handler->insertDTMF(tones, m_duration, m_interToneGap))
ec = SYNTAX_ERR;
}
void RTCDTMFSender::didPlayTone(const String& tone)
{
scheduleDispatchEvent(RTCDTMFToneChangeEvent::create(tone));
}
void RTCDTMFSender::stop()
{
m_stopped = true;
m_handler->setClient(nullptr);
}
const char* RTCDTMFSender::activeDOMObjectName() const
{
return "RTCDTMFSender";
}
bool RTCDTMFSender::canSuspendForDocumentSuspension() const
{
return false;
}
void RTCDTMFSender::scheduleDispatchEvent(Ref<Event>&& event)
{
m_scheduledEvents.append(WTFMove(event));
if (!m_scheduledEventTimer.isActive())
m_scheduledEventTimer.startOneShot(0);
}
void RTCDTMFSender::scheduledEventTimerFired()
{
if (m_stopped)
return;
Vector<Ref<Event>> events;
events.swap(m_scheduledEvents);
for (auto& event : events)
dispatchEvent(event);
}
}
#endif // ENABLE(WEB_RTC)