MediaKeySession.cpp [plain text]
#include "config.h"
#include "MediaKeySession.h"
#if ENABLE(ENCRYPTED_MEDIA_V2)
#include "CDM.h"
#include "Event.h"
#include "GenericEventQueue.h"
#include "MediaKeyError.h"
#include "MediaKeyMessageEvent.h"
#include "MediaKeys.h"
namespace WebCore {
PassRefPtr<MediaKeySession> MediaKeySession::create(ScriptExecutionContext* context, MediaKeys* keys, const String& keySystem)
{
return adoptRef(new MediaKeySession(context, keys, keySystem));
}
MediaKeySession::MediaKeySession(ScriptExecutionContext* context, MediaKeys* keys, const String& keySystem)
: ContextDestructionObserver(context)
, m_keys(keys)
, m_keySystem(keySystem)
, m_asyncEventQueue(GenericEventQueue::create(this))
, m_session(keys->cdm()->createSession())
, m_keyRequestTimer(this, &MediaKeySession::keyRequestTimerFired)
, m_addKeyTimer(this, &MediaKeySession::addKeyTimerFired)
{
}
MediaKeySession::~MediaKeySession()
{
close();
}
void MediaKeySession::setError(MediaKeyError* error)
{
m_error = error;
}
void MediaKeySession::close()
{
if (m_session)
m_session->releaseKeys();
m_session = 0;
m_asyncEventQueue->cancelAllEvents();
}
const String& MediaKeySession::sessionId() const
{
return m_session->sessionId();
}
void MediaKeySession::generateKeyRequest(const String& mimeType, Uint8Array* initData)
{
m_pendingKeyRequests.append(PendingKeyRequest(mimeType, initData));
m_keyRequestTimer.startOneShot(0);
}
void MediaKeySession::keyRequestTimerFired(Timer<MediaKeySession>*)
{
ASSERT(m_pendingKeyRequests.size());
if (!m_session)
return;
while (!m_pendingKeyRequests.isEmpty()) {
PendingKeyRequest request = m_pendingKeyRequests.takeFirst();
String destinationURL;
MediaKeyError::Code errorCode = 0;
unsigned long systemCode = 0;
RefPtr<Uint8Array> keyRequest = m_session->generateKeyRequest(request.mimeType, request.initData.get(), destinationURL, errorCode, systemCode);
if (!keyRequest) {
RefPtr<MediaKeyError> error = MediaKeyError::create(errorCode, systemCode).get();
setError(error.get());
RefPtr<Event> event = Event::create(eventNames().webkitkeyerrorEvent, false, false);
event->setTarget(this);
m_asyncEventQueue->enqueueEvent(event.release());
continue;
}
MediaKeyMessageEventInit init;
init.bubbles = false;
init.cancelable = false;
init.message = keyRequest;
init.destinationURL = destinationURL;
RefPtr<MediaKeyMessageEvent> event = MediaKeyMessageEvent::create(eventNames().webkitkeymessageEvent, init);
event->setTarget(this);
m_asyncEventQueue->enqueueEvent(event);
}
}
void MediaKeySession::update(Uint8Array* key, ExceptionCode& ec)
{
if (!key || !key->length()) {
ec = INVALID_ACCESS_ERR;
return;
}
m_pendingKeys.append(key);
m_addKeyTimer.startOneShot(0);
}
void MediaKeySession::addKeyTimerFired(Timer<MediaKeySession>*)
{
ASSERT(m_pendingKeys.size());
if (!m_session)
return;
while (!m_pendingKeys.isEmpty()) {
RefPtr<Uint8Array> pendingKey = m_pendingKeys.takeFirst();
unsigned short errorCode = 0;
unsigned long systemCode = 0;
bool didStoreKey = false;
RefPtr<Uint8Array> nextMessage;
didStoreKey = m_session->update(pendingKey.get(), nextMessage, errorCode, systemCode);
if (nextMessage) {
MediaKeyMessageEventInit init;
init.bubbles = false;
init.cancelable = false;
init.message = nextMessage;
RefPtr<MediaKeyMessageEvent> event = MediaKeyMessageEvent::create(eventNames().webkitkeymessageEvent, init);
event->setTarget(this);
m_asyncEventQueue->enqueueEvent(event);
}
if (didStoreKey) {
RefPtr<Event> keyaddedEvent = Event::create(eventNames().webkitkeyaddedEvent, false, false);
keyaddedEvent->setTarget(this);
m_asyncEventQueue->enqueueEvent(keyaddedEvent);
}
if (!didStoreKey) {
RefPtr<MediaKeyError> error = MediaKeyError::create(errorCode, systemCode).get();
setError(error.get());
RefPtr<Event> keyerrorEvent = Event::create(eventNames().webkitkeyerrorEvent, false, false);
keyerrorEvent->setTarget(this);
m_asyncEventQueue->enqueueEvent(keyerrorEvent.release());
}
}
}
const AtomicString& MediaKeySession::interfaceName() const
{
return eventNames().interfaceForMediaKeySession;
}
ScriptExecutionContext* MediaKeySession::scriptExecutionContext() const
{
return ContextDestructionObserver::scriptExecutionContext();
}
}
#endif