#include "config.h"
#if ENABLE(MEDIA_STREAM)
#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;
PassRefPtr<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, WTF::move(handler)));
dtmfSender->suspendIfNeeded();
return dtmfSender.release();
}
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(WTF::move(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, ExceptionCode& ec)
{
insertDTMF(tones, defaultToneDurationMs, defaultInterToneGapMs, ec);
}
void RTCDTMFSender::insertDTMF(const String& tones, long duration, ExceptionCode& ec)
{
insertDTMF(tones, duration, defaultInterToneGapMs, ec);
}
void RTCDTMFSender::insertDTMF(const String& tones, long duration, long interToneGap, ExceptionCode& ec)
{
if (!canInsertDTMF()) {
ec = NOT_SUPPORTED_ERR;
return;
}
if (duration > maxToneDurationMs || duration < minToneDurationMs) {
ec = SYNTAX_ERR;
return;
}
if (interToneGap < minInterToneGapMs) {
ec = SYNTAX_ERR;
return;
}
m_duration = duration;
m_interToneGap = interToneGap;
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(0);
}
void RTCDTMFSender::scheduleDispatchEvent(PassRefPtr<Event> event)
{
m_scheduledEvents.append(event);
if (!m_scheduledEventTimer.isActive())
m_scheduledEventTimer.startOneShot(0);
}
void RTCDTMFSender::scheduledEventTimerFired(Timer<RTCDTMFSender>*)
{
if (m_stopped)
return;
Vector<RefPtr<Event>> events;
events.swap(m_scheduledEvents);
Vector<RefPtr<Event>>::iterator it = events.begin();
for (; it != events.end(); ++it)
dispatchEvent((*it).release());
}
}
#endif // ENABLE(MEDIA_STREAM)