CDMProxyThunder.cpp [plain text]
#include "config.h"
#include "CDMProxyThunder.h"
#if ENABLE(ENCRYPTED_MEDIA) && ENABLE(THUNDER)
#include "CDMThunder.h"
#include "Logging.h"
#include <open_cdm_adapter.h>
#include <wtf/ByteOrder.h>
GST_DEBUG_CATEGORY_EXTERN(webkitMediaThunderDecryptDebugCategory);
#define GST_CAT_DEFAULT webkitMediaThunderDecryptDebugCategory
namespace WebCore {
const WTF::Seconds s_licenseKeyResponseTimeout = WTF::Seconds(6);
BoxPtr<OpenCDMSession> CDMProxyThunder::getDecryptionSession(const DecryptionContext& in) const
{
GstMappedBuffer mappedKeyID(in.keyIDBuffer, GST_MAP_READ);
if (!mappedKeyID) {
GST_ERROR("Failed to map key ID buffer");
return nullptr;
}
auto keyID = mappedKeyID.createVector();
auto keyHandle = getOrWaitForKeyHandle(keyID);
if (!keyHandle.hasValue() || !keyHandle.value()->isStatusCurrentlyValid())
return nullptr;
KeyHandleValueVariant keyData = keyHandle.value()->value();
ASSERT(WTF::holds_alternative<BoxPtr<OpenCDMSession>>(keyData));
BoxPtr<OpenCDMSession> keyValue = WTF::get<BoxPtr<OpenCDMSession>>(keyData);
if (!keyValue) {
keyValue = adoptInBoxPtr(opencdm_get_system_session(&static_cast<const CDMInstanceThunder*>(instance())->thunderSystem(), keyID.data(),
keyID.size(), s_licenseKeyResponseTimeout.millisecondsAs<uint32_t>()));
ASSERT(keyValue);
keyHandle.value()->takeValueIfDifferent(BoxPtr<OpenCDMSession>(keyValue));
}
return keyValue;
}
bool CDMProxyThunder::decrypt(CDMProxyThunder::DecryptionContext& input)
{
BoxPtr<OpenCDMSession> session = getDecryptionSession(input);
if (!session) {
GST_ERROR("there is no valid session to decrypt for the provided key ID");
return false;
}
GST_TRACE("decrypting");
OpenCDMError errorCode = opencdm_gstreamer_session_decrypt(session->get(), input.dataBuffer, input.subsamplesBuffer, input.numSubsamples,
input.ivBuffer, input.keyIDBuffer, 0);
if (errorCode) {
GST_ERROR("decryption failed, error code %X", errorCode);
return false;
}
return true;
}
}
#endif // ENABLE(ENCRYPTED_MEDIA) && ENABLE(THUNDER)