add jingle-test-server

darcs-hash:20070203104503-c9803-5feadbf33d308d15fceff4b2c0307bf6c149df21.gz

2 files changed, 169 insertions, 2 deletions

diff --git a/nice/Makefile.am b/nice/Makefile.am
index e74bf3f..3d6fadc 100644
--- a/nice/Makefile.am
+++ b/nice/Makefile.am
@@ -9,15 +9,19 @@ libnice_la_LIBADD = \
 
 libnice_la_LDFLAGS = -Wl,--version-script,$(srcdir)/libnice.ver
 
-noinst_PROGRAMS = ice-test-client ice-test-server
-
 AM_CFLAGS = -Wall -Werror \
+	-I $(top_srcdir) \
 	-I $(top_srcdir)/agent \
 	-I $(top_srcdir)/random \
 	-I $(top_srcdir)/udp \
 	-I $(top_srcdir)/stun \
 	$(GLIB_CFLAGS)
 
+noinst_PROGRAMS = \
+	ice-test-client \
+	ice-test-server \
+	jingle-test-server
+
 COMMON_LDADD = libnice.la $(GLIB_LIBS)
 
 ice_test_client_SOURCES = \
@@ -38,6 +42,8 @@ ice_test_server_SOURCES = \
 
 ice_test_server_LDADD = $(COMMON_LDADD)
 
+jingle_test_server_LDADD = $(COMMON_LDADD)
+
 check_PROGRAMS = \
 	test-readline \
 	test-util
diff --git a/nice/jingle-test-server.c b/nice/jingle-test-server.c
new file mode 100644
index 0000000..0ace86e
--- /dev/null
+++ b/nice/jingle-test-server.c
@@ -0,0 +1,161 @@
+
+/*
+ * This program interoperates with the test-rtp-jingle program from the
+ * farsight tests/ directory.
+ */
+
+#include <stdlib.h>
+#include <string.h>
+
+#include <nice/nice.h>
+
+static void
+recv_cb (
+    NiceAgent *agent,
+    guint stream_id,
+    guint candidate_id,
+    guint len,
+    gchar *buf,
+    gpointer user_data)
+{
+  g_debug ("got media");
+}
+
+static NiceAgent *
+make_agent (NiceUDPSocketFactory *factory)
+{
+  NiceAgent *agent;
+  NiceAddress addr;
+
+  agent = nice_agent_new (factory);
+
+  if (!nice_address_set_ipv4_from_string (&addr, "127.0.0.1"))
+    g_assert_not_reached ();
+
+  nice_agent_add_local_address (agent, &addr);
+  nice_agent_add_stream (agent, recv_cb, NULL);
+  return agent;
+}
+
+static guint
+accept_connection (
+  NiceUDPSocketFactory *factory,
+  NiceUDPSocket *sock)
+{
+  NiceAgent *agent;
+  struct sockaddr_in sin_recv, sin_send;
+  guint len;
+  gchar buf[1024];
+  guint ret = 0;
+  GSList *fds = NULL;
+
+  agent = make_agent (factory);
+
+  // accept incoming handshake
+
+  len = nice_udp_socket_recv (sock, &sin_recv, 1, buf);
+
+  if (len != 1)
+    {
+      ret = 1;
+      goto OUT;
+    }
+
+  if (buf[0] != '2')
+    {
+      ret = 2;
+      goto OUT;
+    }
+
+  g_debug ("got handshake packet");
+
+  // send handshake reply
+
+  sin_send = sin_recv;
+  sin_send.sin_port = htons (1235);
+  nice_udp_socket_send (sock, &sin_send, 1, buf);
+
+  // send codec
+
+  strcpy (buf, "1 0 PCMU 0 8000 0");
+  nice_udp_socket_send (sock, &sin_send, strlen (buf), buf);
+  strcpy (buf, "1 0 LAST 0 0 0");
+  nice_udp_socket_send (sock, &sin_send, strlen (buf), buf);
+
+  // send candidate
+
+    {
+      NiceCandidate *candidate;
+
+      candidate = nice_agent_get_local_candidates (agent)->data;
+      len = g_snprintf (buf, 1024, "0 0 X1 127.0.0.1 %d %s %s",
+          candidate->addr.port, candidate->username, candidate->password);
+      nice_udp_socket_send (sock, &sin_send, len, buf);
+    }
+
+  // IO loop
+
+  fds = g_slist_append (fds, GUINT_TO_POINTER (sock->fileno));
+
+  for (;;)
+    {
+      gchar **bits;
+      NiceAddress addr;
+
+      if (nice_agent_poll_read (agent, fds) == NULL)
+        continue;
+
+      len = nice_udp_socket_recv (sock, &sin_recv, 1024, buf);
+      buf[len] = '\0';
+      g_debug ("%s", buf);
+
+      if (buf[0] != '0')
+        continue;
+
+      bits = g_strsplit (buf, " ", 7);
+
+      if (g_strv_length (bits) != 7)
+        {
+          g_strfreev (bits);
+          return 3;
+        }
+
+      if (!nice_address_set_ipv4_from_string (&addr, bits[3]))
+        g_assert_not_reached ();
+
+      addr.port = atoi (bits[4]);
+      g_debug ("username = %s", bits[5]);
+      g_debug ("password = %s", bits[6]);
+      nice_agent_add_remote_candidate (agent, 1, 1, NICE_CANDIDATE_TYPE_HOST,
+          &addr, bits[5], bits[6]);
+    }
+
+OUT:
+  g_slist_free (fds);
+  nice_agent_free (agent);
+  return ret;
+}
+
+int
+main (gint argc, gchar *argv[])
+{
+  NiceUDPSocketFactory factory;
+  NiceUDPSocket sock;
+  struct sockaddr_in sin;
+  guint ret;
+
+  sin.sin_family = AF_INET;
+  sin.sin_addr.s_addr = INADDR_ANY;
+  sin.sin_port = htons (1234);
+
+  nice_udp_bsd_socket_factory_init (&factory);
+
+  if (!nice_udp_socket_factory_make (&factory, &sock, &sin))
+    g_assert_not_reached ();
+
+  ret = accept_connection (&factory, &sock);
+  nice_udp_socket_close (&sock);
+  nice_udp_socket_factory_close (&factory);
+  return ret;
+}
+