turn_connectivity.cpp 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275
  1. /**
  2. * Copyright (c) 2019 Paul-Louis Ageneau
  3. *
  4. * This library is free software; you can redistribute it and/or
  5. * modify it under the terms of the GNU Lesser General Public
  6. * License as published by the Free Software Foundation; either
  7. * version 2.1 of the License, or (at your option) any later version.
  8. *
  9. * This library is distributed in the hope that it will be useful,
  10. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  12. * Lesser General Public License for more details.
  13. *
  14. * You should have received a copy of the GNU Lesser General Public
  15. * License along with this library; if not, write to the Free Software
  16. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  17. */
  18. #include "rtc/rtc.hpp"
  19. #include <atomic>
  20. #include <chrono>
  21. #include <iostream>
  22. #include <memory>
  23. #include <thread>
  24. using namespace rtc;
  25. using namespace std;
  26. template <class T> weak_ptr<T> make_weak_ptr(shared_ptr<T> ptr) { return ptr; }
  27. void test_turn_connectivity() {
  28. InitLogger(LogLevel::Debug);
  29. Configuration config1;
  30. config1.iceTransportPolicy = TransportPolicy::Relay; // force relay
  31. // STUN server example (not necessary, just here for testing)
  32. // Please do not use outside of libdatachannel tests
  33. config1.iceServers.emplace_back("stun:stun.ageneau.net:3478");
  34. // TURN server example
  35. // Please do not use outside of libdatachannel tests
  36. config1.iceServers.emplace_back("turn:datachannel_test:[email protected]:3478");
  37. PeerConnection pc1(config1);
  38. Configuration config2;
  39. config2.iceTransportPolicy = TransportPolicy::Relay; // force relay
  40. // STUN server example (not necessary, just here for testing)
  41. // Please do not use outside of libdatachannel tests
  42. config1.iceServers.emplace_back("stun:stun.ageneau.net:3478");
  43. // TURN server example (note that the reserved special character '@' is percent-encoded)
  44. // Please do not use outside of libdatachannel tests
  45. config2.iceServers.emplace_back("turn:datachannel_test_speci%40l:[email protected]:3478");
  46. PeerConnection pc2(config2);
  47. pc1.onLocalDescription([&pc2](Description sdp) {
  48. cout << "Description 1: " << sdp << endl;
  49. pc2.setRemoteDescription(string(sdp));
  50. });
  51. pc1.onLocalCandidate([&pc2](Candidate candidate) {
  52. cout << "Candidate 1: " << candidate << endl;
  53. pc2.addRemoteCandidate(string(candidate));
  54. });
  55. pc1.onStateChange([](PeerConnection::State state) { cout << "State 1: " << state << endl; });
  56. pc1.onGatheringStateChange([](PeerConnection::GatheringState state) {
  57. cout << "Gathering state 1: " << state << endl;
  58. });
  59. pc1.onSignalingStateChange([](PeerConnection::SignalingState state) {
  60. cout << "Signaling state 1: " << state << endl;
  61. });
  62. pc2.onLocalDescription([&pc1](Description sdp) {
  63. cout << "Description 2: " << sdp << endl;
  64. pc1.setRemoteDescription(string(sdp));
  65. });
  66. pc2.onLocalCandidate([&pc1](Candidate candidate) {
  67. cout << "Candidate 2: " << candidate << endl;
  68. pc1.addRemoteCandidate(string(candidate));
  69. });
  70. pc2.onStateChange([](PeerConnection::State state) { cout << "State 2: " << state << endl; });
  71. pc2.onGatheringStateChange([](PeerConnection::GatheringState state) {
  72. cout << "Gathering state 2: " << state << endl;
  73. });
  74. pc2.onSignalingStateChange([](PeerConnection::SignalingState state) {
  75. cout << "Signaling state 2: " << state << endl;
  76. });
  77. shared_ptr<DataChannel> dc2;
  78. pc2.onDataChannel([&dc2](shared_ptr<DataChannel> dc) {
  79. cout << "DataChannel 2: Received with label \"" << dc->label() << "\"" << endl;
  80. if (dc->label() != "test") {
  81. cerr << "Wrong DataChannel label" << endl;
  82. return;
  83. }
  84. dc->onOpen([wdc = make_weak_ptr(dc)]() {
  85. if (auto dc = wdc.lock()) {
  86. cout << "DataChannel 2: Open" << endl;
  87. dc->send("Hello from 2");
  88. }
  89. });
  90. dc->onMessage([](variant<binary, string> message) {
  91. if (holds_alternative<string>(message)) {
  92. cout << "Message 2: " << get<string>(message) << endl;
  93. }
  94. });
  95. std::atomic_store(&dc2, dc);
  96. });
  97. auto dc1 = pc1.createDataChannel("test");
  98. dc1->onOpen([wdc1 = make_weak_ptr(dc1)]() {
  99. auto dc1 = wdc1.lock();
  100. if (!dc1)
  101. return;
  102. cout << "DataChannel 1: Open" << endl;
  103. dc1->send("Hello from 1");
  104. });
  105. dc1->onClosed([]() {
  106. cout << "DataChannel 1: Closed" << endl;
  107. });
  108. dc1->onMessage([](const variant<binary, string> &message) {
  109. if (holds_alternative<string>(message)) {
  110. cout << "Message 1: " << get<string>(message) << endl;
  111. }
  112. });
  113. // Wait a bit
  114. int attempts = 10;
  115. shared_ptr<DataChannel> adc2;
  116. while ((!(adc2 = std::atomic_load(&dc2)) || !adc2->isOpen() || !dc1->isOpen()) && attempts--)
  117. this_thread::sleep_for(1s);
  118. if (pc1.state() != PeerConnection::State::Connected &&
  119. pc2.state() != PeerConnection::State::Connected)
  120. throw runtime_error("PeerConnection is not connected");
  121. if (!adc2 || !adc2->isOpen() || !dc1->isOpen())
  122. throw runtime_error("DataChannel is not open");
  123. if (auto addr = pc1.localAddress())
  124. cout << "Local address 1: " << *addr << endl;
  125. if (auto addr = pc1.remoteAddress())
  126. cout << "Remote address 1: " << *addr << endl;
  127. if (auto addr = pc2.localAddress())
  128. cout << "Local address 2: " << *addr << endl;
  129. if (auto addr = pc2.remoteAddress())
  130. cout << "Remote address 2: " << *addr << endl;
  131. Candidate local, remote;
  132. if (!pc1.getSelectedCandidatePair(&local, &remote))
  133. throw runtime_error("getSelectedCabndidatePair failed");
  134. cout << "Local candidate 1: " << local << endl;
  135. cout << "Remote candidate 1: " << remote << endl;
  136. if (local.type() != Candidate::Type::Relayed || remote.type() != Candidate::Type::Relayed)
  137. throw runtime_error("Connection is not relayed as expected");
  138. if (!pc2.getSelectedCandidatePair(&local, &remote))
  139. throw runtime_error("getSelectedCabndidatePair failed");
  140. cout << "Local candidate 2: " << local << endl;
  141. cout << "Remote candidate 2: " << remote << endl;
  142. if (local.type() != Candidate::Type::Relayed || remote.type() != Candidate::Type::Relayed)
  143. throw runtime_error("Connection is not relayed as expected");
  144. // Try to open a second data channel with another label
  145. shared_ptr<DataChannel> second2;
  146. pc2.onDataChannel([&second2](shared_ptr<DataChannel> dc) {
  147. cout << "Second DataChannel 2: Received with label \"" << dc->label() << "\"" << endl;
  148. if (dc->label() != "second") {
  149. cerr << "Wrong second DataChannel label" << endl;
  150. return;
  151. }
  152. dc->onOpen([wdc = make_weak_ptr(dc)]() {
  153. if (auto dc = wdc.lock())
  154. dc->send("Second hello from 2");
  155. });
  156. dc->onMessage([](variant<binary, string> message) {
  157. if (holds_alternative<string>(message)) {
  158. cout << "Second Message 2: " << get<string>(message) << endl;
  159. }
  160. });
  161. std::atomic_store(&second2, dc);
  162. });
  163. auto second1 = pc1.createDataChannel("second");
  164. second1->onOpen([wsecond1 = make_weak_ptr(second1)]() {
  165. auto second1 = wsecond1.lock();
  166. if (!second1)
  167. return;
  168. cout << "Second DataChannel 1: Open" << endl;
  169. second1->send("Second hello from 1");
  170. });
  171. second1->onClosed([]() {
  172. cout << "Second DataChannel 1: Closed" << endl;
  173. });
  174. second1->onMessage([](const variant<binary, string> &message) {
  175. if (holds_alternative<string>(message)) {
  176. cout << "Second Message 1: " << get<string>(message) << endl;
  177. }
  178. });
  179. // Wait a bit
  180. attempts = 10;
  181. shared_ptr<DataChannel> asecond2;
  182. while (
  183. (!(asecond2 = std::atomic_load(&second2)) || !asecond2->isOpen() || !second1->isOpen()) &&
  184. attempts--)
  185. this_thread::sleep_for(1s);
  186. if (!asecond2 || !asecond2->isOpen() || !second1->isOpen())
  187. throw runtime_error("Second DataChannel is not open");
  188. // Try to open a negotiated channel
  189. DataChannelInit init;
  190. init.negotiated = true;
  191. init.id = 42;
  192. auto negotiated1 = pc1.createDataChannel("negotiated", init);
  193. auto negotiated2 = pc2.createDataChannel("negoctated", init);
  194. if (!negotiated1->isOpen() || !negotiated2->isOpen())
  195. throw runtime_error("Negotiated DataChannel is not open");
  196. std::atomic<bool> received = false;
  197. negotiated2->onMessage([&received](const variant<binary, string> &message) {
  198. if (holds_alternative<string>(message)) {
  199. cout << "Second Message 2: " << get<string>(message) << endl;
  200. received = true;
  201. }
  202. });
  203. negotiated1->send("Hello from negotiated channel");
  204. // Wait a bit
  205. attempts = 5;
  206. while (!received && attempts--)
  207. this_thread::sleep_for(1s);
  208. if (!received)
  209. throw runtime_error("Negotiated DataChannel failed");
  210. // Delay close of peer 2 to check closing works properly
  211. pc1.close();
  212. this_thread::sleep_for(1s);
  213. pc2.close();
  214. this_thread::sleep_for(1s);
  215. cout << "Success" << endl;
  216. }