SpeechRecognitionRemoteRealtimeMediaSourceManager.cpp [plain text]
#include "config.h"
#include "SpeechRecognitionRemoteRealtimeMediaSourceManager.h"
#if ENABLE(MEDIA_STREAM)
#include "SpeechRecognitionRealtimeMediaSourceManagerMessages.h"
#include "SpeechRecognitionRemoteRealtimeMediaSource.h"
namespace WebKit {
SpeechRecognitionRemoteRealtimeMediaSourceManager::SpeechRecognitionRemoteRealtimeMediaSourceManager(Ref<IPC::Connection>&& connection)
: m_connection(WTFMove(connection))
{
}
void SpeechRecognitionRemoteRealtimeMediaSourceManager::addSource(SpeechRecognitionRemoteRealtimeMediaSource& source, const WebCore::CaptureDevice& captureDevice)
{
auto identifier = source.identifier();
ASSERT(!m_sources.contains(identifier));
m_sources.add(identifier, makeWeakPtr(source));
#if ENABLE(SANDBOX_EXTENSIONS)
if (!captureDevice.isMockDevice()) {
m_sourcesNeedingSandboxExtension.add(identifier);
if (m_sourcesNeedingSandboxExtension.size() == 1) {
SandboxExtension::Handle handleForTCCD;
SandboxExtension::createHandleForMachLookup("com.apple.tccd"_s, m_connection->getAuditToken(), handleForTCCD);
SandboxExtension::Handle handleForMicrophone;
SandboxExtension::createHandleForGenericExtension("com.apple.webkit.microphone"_s, handleForMicrophone);
send(Messages::SpeechRecognitionRealtimeMediaSourceManager::GrantSandboxExtensions(handleForTCCD, handleForMicrophone));
}
}
#endif
send(Messages::SpeechRecognitionRealtimeMediaSourceManager::CreateSource(identifier, captureDevice));
}
void SpeechRecognitionRemoteRealtimeMediaSourceManager::removeSource(SpeechRecognitionRemoteRealtimeMediaSource& source)
{
auto identifier = source.identifier();
ASSERT(m_sources.get(identifier) == &source);
m_sources.remove(identifier);
#if ENABLE(SANDBOX_EXTENSIONS)
if (m_sourcesNeedingSandboxExtension.remove(identifier)) {
if (m_sourcesNeedingSandboxExtension.isEmpty())
send(Messages::SpeechRecognitionRealtimeMediaSourceManager::RevokeSandboxExtensions());
}
#endif
send(Messages::SpeechRecognitionRealtimeMediaSourceManager::DeleteSource(identifier));
}
void SpeechRecognitionRemoteRealtimeMediaSourceManager::remoteAudioSamplesAvailable(WebCore::RealtimeMediaSourceIdentifier identifier, const WTF::MediaTime& time, uint64_t numberOfFrames)
{
if (auto source = m_sources.get(identifier))
source->remoteAudioSamplesAvailable(time, numberOfFrames);
}
void SpeechRecognitionRemoteRealtimeMediaSourceManager::remoteCaptureFailed(WebCore::RealtimeMediaSourceIdentifier identifier)
{
if (auto source = m_sources.get(identifier))
source->remoteCaptureFailed();
}
void SpeechRecognitionRemoteRealtimeMediaSourceManager::remoteSourceStopped(WebCore::RealtimeMediaSourceIdentifier identifier)
{
if (auto source = m_sources.get(identifier))
source->remoteSourceStopped();
}
IPC::Connection* SpeechRecognitionRemoteRealtimeMediaSourceManager::messageSenderConnection() const
{
return m_connection.ptr();
}
uint64_t SpeechRecognitionRemoteRealtimeMediaSourceManager::messageSenderDestinationID() const
{
return 0;
}
#if PLATFORM(COCOA)
void SpeechRecognitionRemoteRealtimeMediaSourceManager::setStorage(WebCore::RealtimeMediaSourceIdentifier identifier, const SharedMemory::IPCHandle& ipcHandle, const WebCore::CAAudioStreamDescription& description, uint64_t numberOfFrames)
{
if (auto source = m_sources.get(identifier))
source->setStorage(ipcHandle.handle, description, numberOfFrames);
}
#endif
}
#endif