Added tcp host candidate

2 files changed, 33 insertions, 8 deletions

diff --git a/example/index.js b/example/index.js
index a161a10..6eae9b3 100644
--- a/example/index.js
+++ b/example/index.js
@@ -1,4 +1,5 @@
 window.onload = function demo() {
+
   // create peer connection
   let pc = new RTCPeerConnection({
     iceCandidatePoolSize: 4
@@ -27,10 +28,13 @@ window.onload = function demo() {
       if ('candidate' in d) {
         if (d.candidate) {
           console.log("remote candidate:\n%c%s", "color: blue;", d.candidate);
+					pc.addIceCandidate(d).catch((e) => {
+						console.log("addIceCandidate:\n%c%s", "color: red;", e);
+					});
         }
       } else if ('sdp' in d) {
 				pc.setRemoteDescription(d).catch((e) => {
-					console.log("local error:\n%c%s", "color: red;", e);
+					console.log("setRemoteDescription:\n%c%s", "color: red;", e);
 				});
         console.log("remote answer:\n%c%s", "color: blue;", d.sdp);
       }
diff --git a/example/main.c b/example/main.c
index 33ef4bb..e850a40 100644
--- a/example/main.c
+++ b/example/main.c
@@ -4,6 +4,7 @@
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
+#include <syslog.h>
 #include <unistd.h>
 
 #include "jsmn.h"
@@ -60,7 +61,7 @@ struct trtc_ice_candidate_t parse_ice_candidate(const char *s)
 }
 
 // (callback) Called for each discovered local ICE candidate
-int on_ice_candidate(const struct trtc_ice_candidate_t c, void *arg) {
+void on_ice_candidate(const struct trtc_ice_candidate_t c, void *arg) {
 	// send ice candidate over signaling channel
 	printf("{"
 		"\"candidate\":\"%s\","
@@ -68,15 +69,18 @@ int on_ice_candidate(const struct trtc_ice_candidate_t c, void *arg) {
 		"\"sdpMid\":\"%s\","
 		"\"usernameFragment\":null"
 	"}\n", c.candidate, c.sdp_mline_index, c.sdp_mid);
-
-	return 0;
 }
 
 int main(int argc, char **argv)
 {
+	openlog(NULL, LOG_PERROR, LOG_USER);
+
 	// disable stdout buffering to ensure signaling messages send immediately
 	setvbuf(stdout, NULL, _IONBF, 0);
 
+	// initialize tinyrtc library
+	trtc_init();
+
 	// create peer connection
 	struct trtc_config_t cfg = {
 		.ice_servers = {
@@ -88,6 +92,12 @@ int main(int argc, char **argv)
 		}
 	};
 	struct trtc_peerconn_t* pc = trtc_peer_connection(cfg);
+	if (!pc) {
+		syslog(LOG_ERR, "trtc_peer_connection() failed");
+		return -1;
+	}
+
+	trtc_set_on_ice_candidate(pc, on_ice_candidate, NULL);
 
 	while (true) {
 		int n;
@@ -96,21 +106,32 @@ int main(int argc, char **argv)
 
 
 		if (n = getline(&msg, &msglen, stdin), -1 == n) {
+			syslog(LOG_ERR, "%m");
 			return -1;
 		}
 
+		// case: sdp offer
 		if (strstr(msg, "\"sdp\"")) {
-			// got offer. send answer.
-			printf("{\"sdp\":\"%s\",\"type\":\"answer\"}\n", trtc_create_answer(pc));
+			// XXX trtc_set_remote_description(pc, offer);
+			const char *answer = trtc_create_answer(pc);
+
+			/* send SDP answer via stdout signaling channel */
+			printf("{\"sdp\":\"%s\",\"type\":\"answer\"}\n", answer);
+
+			trtc_set_local_description(pc, answer);
+
+		// case: ice candidate
 		} else if (strstr(msg, "\"candidate\"")) {
 			struct trtc_ice_candidate_t c = parse_ice_candidate(msg);
-			on_ice_candidate(c, NULL);
 			trtc_add_ice_candidate(pc, c);
+
+		// case: error
 		} else {
 			printf("unrecognized signaling message\n");
 		}
-
 	}
+	
+	syslog(LOG_ERR, "terminating");
 
 	return 0;
 }