| 167 | */ |
| 168 | bool connected = false; |
| 169 | int run_webrtc_data_test() { |
| 170 | |
| 171 | internal_callbacks_t caller; |
| 172 | internal_callbacks_t callee; |
| 173 | |
| 174 | memset(&caller, 0, sizeof(caller)); |
| 175 | memset(&callee, 0, sizeof(callee)); |
| 176 | |
| 177 | internal_socket_t* left = internal_create_webrtc(context); |
| 178 | internal_socket_t* right = internal_create_webrtc(context); |
| 179 | |
| 180 | caller.on_sdp = on_sdp_offer; |
| 181 | caller.on_ice_candidate = on_ice_candidate; |
| 182 | caller.on_connect = on_connected; |
| 183 | caller.on_connect_channel = [] ( internal_socket_t* socket, const char* name, void* user_data ) -> int { |
| 184 | printf("connected sockets using channel: %s\n", name ); |
| 185 | connected = true; |
| 186 | return 0; |
| 187 | }; |
| 188 | |
| 189 | callee.on_sdp = on_sdp_answer; |
| 190 | callee.on_ice_candidate = on_ice_candidate; |
| 191 | |
| 192 | internal_set_callbacks( left, &caller ); |
| 193 | internal_set_callbacks( right, &callee ); |
| 194 | |
| 195 | internal_set_data(left, right); |
| 196 | internal_set_data(right,left); |
| 197 | |
| 198 | // this will trigger the whole process. |
| 199 | internal_create_offer(left); |
| 200 | |
| 201 | int timeout = 5000; |
| 202 | connected = false; |
| 203 | while( ! connected ) { |
| 204 | wait(&timeout); |
| 205 | |
| 206 | if( timeout <= 0 ) { |
| 207 | printf("call setup timed out\n"); |
| 208 | return 0; |
| 209 | } |
| 210 | } |
| 211 | |
| 212 | return run_message_test("webrtc", left, right) ? 1 : 0; |
| 213 | } |
| 214 | |
| 215 | |
| 216 | int main(int argc, char **argv) |
no test coverage detected