blob: 96132e69737ae98a60f954f1f31183841071e0a9 [file] [log] [blame]
/*
* Copyright (C) 2017 Apple Inc. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' AND ANY
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
* ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#include "config.h"
#include "RTCController.h"
#if ENABLE(WEB_RTC)
#include "LibWebRTCProvider.h"
#include "RTCPeerConnection.h"
namespace WebCore {
RTCController::~RTCController()
{
for (RTCPeerConnection& connection : m_peerConnections)
connection.clearController();
}
void RTCController::reset(bool shouldFilterICECandidates)
{
m_shouldFilterICECandidates = shouldFilterICECandidates;
for (RTCPeerConnection& connection : m_peerConnections)
connection.clearController();
m_peerConnections.clear();
m_filteringDisabledOrigins.clear();
}
void RTCController::remove(RTCPeerConnection& connection)
{
m_peerConnections.removeFirstMatching([&connection](auto item) {
return &connection == &item.get();
});
}
static inline bool matchDocumentOrigin(Document& document, SecurityOrigin& topOrigin, SecurityOrigin& clientOrigin)
{
if (originsMatch(topOrigin, document.securityOrigin()))
return true;
return originsMatch(topOrigin, document.topOrigin()) && originsMatch(clientOrigin, document.securityOrigin());
}
bool RTCController::shouldDisableICECandidateFiltering(Document& document)
{
if (!m_shouldFilterICECandidates)
return true;
return notFound != m_filteringDisabledOrigins.findMatching([&] (const auto& origin) {
return matchDocumentOrigin(document, origin.topOrigin, origin.clientOrigin);
});
}
void RTCController::add(RTCPeerConnection& connection)
{
m_peerConnections.append(connection);
if (shouldDisableICECandidateFiltering(downcast<Document>(*connection.scriptExecutionContext())))
connection.disableICECandidateFiltering();
}
void RTCController::disableICECandidateFilteringForAllOrigins()
{
if (!LibWebRTCProvider::webRTCAvailable())
return;
m_shouldFilterICECandidates = false;
for (RTCPeerConnection& connection : m_peerConnections)
connection.disableICECandidateFiltering();
}
void RTCController::disableICECandidateFilteringForDocument(Document& document)
{
if (!LibWebRTCProvider::webRTCAvailable())
return;
m_filteringDisabledOrigins.append(PeerConnectionOrigin { document.topOrigin(), document.securityOrigin() });
for (RTCPeerConnection& connection : m_peerConnections) {
if (auto* peerConnectionDocument = downcast<Document>(connection.scriptExecutionContext())) {
if (matchDocumentOrigin(*peerConnectionDocument, document.topOrigin(), document.securityOrigin()))
connection.disableICECandidateFiltering();
}
}
}
void RTCController::enableICECandidateFiltering()
{
if (!LibWebRTCProvider::webRTCAvailable())
return;
m_filteringDisabledOrigins.clear();
m_shouldFilterICECandidates = true;
for (RTCPeerConnection& connection : m_peerConnections)
connection.enableICECandidateFiltering();
}
} // namespace WebCore
#endif