d3v1l/matrixion
1
0
Fork 0
mirror of https://github.com/Nheko-Reborn/nheko.git synced 2024-11-25 20:48:52 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix percent-encoding of TURN server URI

Browse source
This commit is contained in:
trilene 2020-07-13 19:16:28 -04:00
parent c73cfe1810
commit e85652e7e7
2 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/CallManager.cpp
View file

@ -274,7 +274,8 @@ CallManager::retrieveTurnServer()
void void
CallManager::setTurnServers() CallManager::setTurnServers()
{ {
// gstreamer expects (percent-encoded): turn(s)://username:password@host:port?transport=udp(tcp) // gstreamer expects: turn(s)://username:password@host:port?transport=udp(tcp)
// where username and password are percent-encoded
std::vector<std::string> uris; std::vector<std::string> uris;
for (const auto &uri : turnServer_.uris) { for (const auto &uri : turnServer_.uris) {
if (auto c = uri.find(':'); c == std::string::npos) { if (auto c = uri.find(':'); c == std::string::npos) {
@ -287,9 +288,11 @@ CallManager::setTurnServers()
nhlog::ui()->error("Invalid TURN server uri: {}", uri); nhlog::ui()->error("Invalid TURN server uri: {}", uri);
continue; continue;
} }
std::string res = scheme + "://" + turnServer_.username + ":" + turnServer_.password
+ "@" + std::string(uri, ++c); QString encodedUri = QString::fromStdString(scheme) + "://" +
QString encodedUri = QUrl::toPercentEncoding(QString::fromStdString(res)); QUrl::toPercentEncoding(QString::fromStdString(turnServer_.username)) + ":" +
QUrl::toPercentEncoding(QString::fromStdString(turnServer_.password)) + "@" +
QString::fromStdString(std::string(uri, ++c));
uris.push_back(encodedUri.toStdString()); uris.push_back(encodedUri.toStdString());
} }
} }

11
src/WebRTCSession.cpp
View file

@ -143,7 +143,7 @@ WebRTCSession::startPipeline(int opusPayloadType)
webrtc_ = gst_bin_get_by_name(GST_BIN(pipe_), "webrtcbin"); webrtc_ = gst_bin_get_by_name(GST_BIN(pipe_), "webrtcbin");
if (!stunServer_.empty()) { if (!stunServer_.empty()) {
nhlog::ui()->info("WebRTC: Setting stun server: {}", stunServer_); nhlog::ui()->info("WebRTC: Setting STUN server: {}", stunServer_);
g_object_set(webrtc_, "stun-server", stunServer_.c_str(), nullptr); g_object_set(webrtc_, "stun-server", stunServer_.c_str(), nullptr);
} }
addTurnServers(); addTurnServers();
@ -265,12 +265,9 @@ WebRTCSession::addTurnServers()
return; return;
for (const auto &uri : turnServers_) { for (const auto &uri : turnServers_) {
gboolean res; nhlog::ui()->info("WebRTC: Setting TURN server: {}", uri);
g_signal_emit_by_name(webrtc_, "add-turn-server", uri.c_str(), (gpointer)(&res)); gboolean udata;
if (res) g_signal_emit_by_name(webrtc_, "add-turn-server", uri.c_str(), (gpointer)(&udata));
nhlog::ui()->info("WebRTC: Set TURN server: {}", uri);
else
nhlog::ui()->error("WebRTC: Failed to set TURN server: {}", uri);
} }
} }