1 files changed, 113 insertions, 0 deletions
diff --git a/test/sip_server.c b/test/sip_server.c
new file mode 100644
index 0000000..0e637de
--- /dev/null
+++ b/test/sip_server.c
@@ -0,0 +1,113 @@
+/**
+ * @file sip_server.c  Selftest for Baresip core -- SIP Server
+ *
+ * Copyright (C) 2010 Creytiv.com
+ */
+#include <string.h>
+#include <re.h>
+#include <baresip.h>
+#include "test.h"
+
+
+static void udp_recv(const struct sa *src, struct mbuf *mb, void *arg)
+{
+	struct sip_server *srv = arg;
+	struct sip_msg *msg;
+	int err;
+
+#if 0
+	re_printf("sip: %zu bytes from %J\n", mbuf_get_left(mb), src);
+	re_printf("%b\n", mb->buf, mb->end);
+#endif
+
+	err = sip_msg_decode(&msg, mb);
+	if (err) {
+		warning("selftest: sip_msg_decode: %m\n", err);
+		return;
+	}
+
+	if (0 == pl_strcmp(&msg->met, "REGISTER"))
+		srv->got_register_req = true;
+
+	msg->sock = mem_ref(srv->us);
+	msg->src  = *src;
+	msg->dst  = srv->laddr;
+	msg->tp   = SIP_TRANSP_UDP;
+
+	if (srv->terminate)
+		err = sip_reply(srv->sip, msg, 503, "Server Error");
+	else
+		err = sip_reply(srv->sip, msg, 200, "OK");
+	if (err) {
+		warning("selftest: could not reply: %m\n", err);
+	}
+
+	mem_deref(msg);
+
+	if (srv->terminate)
+		re_cancel();
+}
+
+
+static void destructor(void *arg)
+{
+	struct sip_server *srv = arg;
+
+	sip_close(srv->sip, false);
+	mem_deref(srv->sip);
+
+	mem_deref(srv->us);
+}
+
+
+int sip_server_create(struct sip_server **srvp)
+{
+	struct sip_server *srv;
+	struct sa laddr_tp;
+	int err;
+
+	srv = mem_zalloc(sizeof *srv, destructor);
+	if (!srv)
+		return ENOMEM;
+
+	err  = sa_set_str(&laddr_tp, "127.0.0.1", 0);
+	err |= sa_set_str(&srv->laddr, "127.0.0.1", 0);
+	if (err)
+		goto out;
+
+	err = sip_alloc(&srv->sip, NULL, 16, 16, 16,
+			"dummy SIP registrar", NULL, NULL);
+	if (err)
+		goto out;
+
+	err = sip_transp_add(srv->sip, SIP_TRANSP_UDP, &laddr_tp);
+	if (err) {
+		warning("failed to add sip transport (%m)\n", err);
+		goto out;
+	}
+
+	err = udp_listen(&srv->us, &srv->laddr, udp_recv, srv);
+	if (err) {
+		warning("sip: udp_listen on '%J' failed (%d/%m)\n",
+			&srv->laddr, err, err);
+		goto out;
+	}
+
+	err = udp_local_get(srv->us, &srv->laddr);
+	if (err) {
+		warning("sip: udp_local_get\n");
+		goto out;
+	}
+
+#if 0
+	re_printf("sip: listen on %J\n", &srv->laddr);
+#endif
+
+ out:
+	if (err)
+		mem_deref(srv);
+	else
+		*srvp = srv;
+
+	return err;
+}