test_nua.c: moved initialization into test_init.c, test operations to test_ops.c

darcs-hash:20060925210557-65a35-d268f3418eae746e449e24832d82ba9daf3d2a0a.gz

libsofia-sip-ua/nua/Makefile.am

@@ -74,7 +74,8 @@ LDADD = 		libnua.la \
 
 test_nua_LDFLAGS = 	-static
 
-test_nua_SOURCES = 	test_nua.c test_nua.h \
+test_nua_SOURCES = 	test_nua.c test_nua.h test_ops.c \
+			test_init.c \
 			test_nua_api.c test_nua_params.c \
 			test_register.c test_basic_call.c \
 			test_call_reject.c test_cancel_bye.c \

libsofia-sip-ua/nua/test_init.c

+/*
+ * This file is part of the Sofia-SIP package
+ *
+ * Copyright (C) 2005 Nokia Corporation.
+ *
+ * Contact: Pekka Pessi <pekka.pessi@nokia.com>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public License
+ * as published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA
+ *
+ */
+
+/**@CFILE test_init.c
+ * @brief Init nua test context 
+ *
+ * @author Pekka Pessi <Pekka.Pessi@nokia.com>
+ * @author Martti Mela <Martti Mela@nokia.com>
+ *
+ * @date Created: Wed Aug 17 12:12:12 EEST 2005 ppessi
+ */
+
+#include "config.h"
+
+#include "test_nua.h"
+
+#if HAVE_FUNC
+#elif HAVE_FUNCTION
+#define __func__ __FUNCTION__
+#else
+#define __func__ name
+#endif
+
+static char passwd_name[] = "tmp_sippasswd.XXXXXX";
+
+static void remove_tmp(void)
+{
+  if (passwd_name[0])
+    unlink(passwd_name);
+}
+
+static char const passwd[] =
+  "alice:secret:\n"
+  "bob:secret:\n"
+  "charlie:secret:\n";
+
+int test_nua_init(struct context *ctx,
+		  int start_proxy,
+		  url_t const *o_proxy,
+		  int start_nat,
+		  tag_type_t tag, tag_value_t value, ...)
+{
+  BEGIN();
+  struct event *e;
+  sip_contact_t const *m = NULL;
+  sip_from_t const *sipaddress = NULL;
+  url_t const *p_uri, *a_uri;		/* Proxy URI */
+  char const *a_bind, *a_bind2;
+
+  a_bind = a_bind2 = "sip:0.0.0.0:*";
+
+  ctx->root = su_root_create(NULL); TEST_1(ctx->root);
+
+  /* Disable threading by command line switch? */
+  su_root_threading(ctx->root, ctx->threading);
+
+  if (start_proxy && !o_proxy) {
+    int temp;
+
+    if (print_headings)
+      printf("TEST NUA-2.1.1: init proxy P\n");
+
+#ifndef _WIN32
+    temp = mkstemp(passwd_name);
+#else
+    temp = open(passwd_name, O_WRONLY|O_CREAT|O_TRUNC, 666);
+#endif
+    TEST_1(temp != -1);
+    atexit(remove_tmp);		/* Make sure temp file is unlinked */
+
+    TEST(write(temp, passwd, strlen(passwd)), strlen(passwd));
+
+    TEST_1(close(temp) == 0);
+
+    ctx->p = test_proxy_create(ctx->root,
+			       AUTHTAG_METHOD("Digest"),
+			       AUTHTAG_REALM("test-proxy"),
+			       AUTHTAG_OPAQUE("kuik"),
+			       AUTHTAG_DB(passwd_name),
+			       AUTHTAG_QOP("auth-int"),
+			       AUTHTAG_ALGORITHM("md5-sess"),
+			       TAG_END());
+
+    ctx->proxy_tests = ctx->p != NULL;
+
+    if (print_headings)
+      printf("TEST NUA-2.1.1: PASSED\n");
+  }
+
+  p_uri = a_uri = test_proxy_uri(ctx->p);
+
+  if (start_nat && p_uri == NULL)
+    p_uri = url_hdup(ctx->home, (void *)o_proxy);
+
+  if (start_nat && p_uri != NULL) {
+    int family = 0;
+    su_sockaddr_t su[1];
+    socklen_t sulen = sizeof su;
+    char b[64];
+    int len;
+    ta_list ta;
+
+    if (print_headings)
+      printf("TEST NUA-2.1.2: creating test NAT\n");
+
+    /* Try to use different family than proxy. */
+    if (p_uri->url_host[0] == '[')
+      family = AF_INET;
+#if defined(SU_HAVE_IN6)
+    else
+      family = AF_INET6;
+#endif
+
+    ta_start(ta, tag, value);
+    ctx->nat = test_nat_create(ctx->root, family, ta_tags(ta));
+    ta_end(ta);
+
+    /*
+     * NAT thingy works so that we set the outgoing proxy URI to point
+     * towards its "private" address and give the real address of the proxy
+     * as its "public" address. If we use different IP families here, we may
+     * even manage to test real connectivity problems as proxy and endpoint
+     * can not talk to each other.
+     */
+
+    if (test_nat_private(ctx->nat, su, &sulen) < 0) {
+      printf("%s:%u: NUA-2.1.2: failed to get private NAT address\n",
+	     __FILE__, __LINE__);
+    }
+
+#if defined(SU_HAVE_IN6)
+    else if (su->su_family == AF_INET6) {
+      a_uri = (void *)
+	su_sprintf(ctx->home, "sip:[%s]:%u",
+		   inet_ntop(su->su_family, SU_ADDR(su), b, sizeof b),
+		   ntohs(su->su_port));
+      a_bind = "sip:[::]:*";
+    }
+#endif
+    else if (su->su_family == AF_INET) {
+      a_uri = (void *)
+	su_sprintf(ctx->home, "sip:%s:%u",
+		   inet_ntop(su->su_family, SU_ADDR(su), b, sizeof b),
+		   ntohs(su->su_port));
+    }
+
+#if defined(SU_HAVE_IN6)
+    if (p_uri->url_host[0] == '[') {
+      su->su_len = sulen = (sizeof su->su_sin6), su->su_family = AF_INET6;
+      len = strcspn(p_uri->url_host + 1, "]"); assert(len < sizeof b);
+      memcpy(b, p_uri->url_host + 1, len); b[len] = '\0';
+      inet_pton(su->su_family, b, SU_ADDR(su));
+    }
+    else {
+      su->su_len = sulen = (sizeof su->su_sin), su->su_family = AF_INET;
+      inet_pton(su->su_family, p_uri->url_host, SU_ADDR(su));
+    }
+#else
+    su->su_len = sulen = (sizeof su->su_sin), su->su_family = AF_INET;
+    inet_pton(su->su_family, p_uri->url_host, SU_ADDR(su));
+#endif
+
+    su->su_port = htons(strtoul(url_port(p_uri), NULL, 10));
+
+    if (test_nat_public(ctx->nat, su, sulen) < 0) {
+      printf("%s:%u: NUA-2.1.2: failed to set public address\n",
+	     __FILE__, __LINE__);
+      a_uri = NULL;
+    }
+
+    if (print_headings) {
+      if (ctx->nat && a_uri) {
+	printf("TEST NUA-2.1.2: PASSED\n");
+      } else {
+	printf("TEST NUA-2.1.2: FAILED\n");
+      }
+    }
+  }
+
+  if (print_headings)
+    printf("TEST NUA-2.2.1: init endpoint A\n");
+
+  if (a_uri == NULL)
+    a_uri = p_uri;
+
+  ctx->a.instance = nua_generate_instance_identifier(ctx->home);
+
+  ctx->a.nua = nua_create(ctx->root, a_callback, ctx,
+			  NUTAG_PROXY(a_uri ? a_uri : o_proxy),
+			  SIPTAG_FROM_STR("sip:alice@example.com"),
+			  NUTAG_URL(a_bind),
+			  TAG_IF(a_bind != a_bind2, NUTAG_SIPS_URL(a_bind2)),
+			  SOATAG_USER_SDP_STR("m=audio 5004 RTP/AVP 0 8"),
+			  NTATAG_SIP_T1X64(4000),
+			  NUTAG_INSTANCE(ctx->a.instance),
+			  TAG_END());
+  TEST_1(ctx->a.nua);
+
+  nua_get_params(ctx->a.nua, TAG_ANY(), TAG_END());
+  run_a_until(ctx, nua_r_get_params, save_until_final_response);
+  TEST_1(e = ctx->a.events->head);
+  TEST(tl_gets(e->data->e_tags,
+	       NTATAG_CONTACT_REF(m),
+	       SIPTAG_FROM_REF(sipaddress),
+	       TAG_END()), 2); TEST_1(m);
+  TEST_1(ctx->a.contact = sip_contact_dup(ctx->home, m));
+  TEST_1(ctx->a.to = sip_to_dup(ctx->home, sipaddress));
+
+  free_events_in_list(ctx, ctx->a.events);
+
+  if (print_headings)
+    printf("TEST NUA-2.2.1: PASSED\n");
+
+  if (print_headings)
+    printf("TEST NUA-2.2.2: init endpoint B\n");
+
+  ctx->b.instance = nua_generate_instance_identifier(ctx->home);
+
+  ctx->b.nua = nua_create(ctx->root, b_callback, ctx,
+			  NUTAG_PROXY(p_uri ? p_uri : o_proxy),
+			  SIPTAG_FROM_STR("sip:bob@example.org"),
+			  NUTAG_URL("sip:0.0.0.0:*"),
+			  SOATAG_USER_SDP_STR("m=audio 5006 RTP/AVP 8 0"),
+			  NUTAG_INSTANCE(ctx->b.instance),
+			  TAG_END());
+  TEST_1(ctx->b.nua);
+
+  nua_get_params(ctx->b.nua, TAG_ANY(), TAG_END());
+  run_b_until(ctx, nua_r_get_params, save_until_final_response);
+  TEST_1(e = ctx->b.events->head);
+  TEST(tl_gets(e->data->e_tags,
+	       NTATAG_CONTACT_REF(m),
+	       SIPTAG_FROM_REF(sipaddress),
+	       TAG_END()), 2); TEST_1(m);
+  TEST_1(ctx->b.contact = sip_contact_dup(ctx->home, m));
+  TEST_1(ctx->b.to = sip_to_dup(ctx->home, sipaddress));
+  free_events_in_list(ctx, ctx->b.events);
+
+  if (print_headings)
+    printf("TEST NUA-2.2.2: PASSED\n");
+
+  if (print_headings)
+    printf("TEST NUA-2.2.3: init endpoint C\n");
+
+  /* ctx->c.instance = nua_generate_instance_identifier(ctx->home); */
+
+  ctx->c.nua = nua_create(ctx->root, c_callback, ctx,
+			  NUTAG_PROXY(p_uri ? p_uri : o_proxy),
+			  SIPTAG_FROM_STR("sip:charlie@example.net"),
+			  NUTAG_URL("sip:0.0.0.0:*"),
+			  SOATAG_USER_SDP_STR("m=audio 5400 RTP/AVP 8 0"),
+			  NUTAG_INSTANCE(ctx->c.instance),
+			  TAG_END());
+  TEST_1(ctx->c.nua);
+
+  nua_get_params(ctx->c.nua, TAG_ANY(), TAG_END());
+  run_c_until(ctx, nua_r_get_params, save_until_final_response);
+  TEST_1(e = ctx->c.events->head);
+  TEST(tl_gets(e->data->e_tags,
+	       NTATAG_CONTACT_REF(m),
+	       SIPTAG_FROM_REF(sipaddress),
+	       TAG_END()), 2); TEST_1(m);
+  TEST_1(ctx->c.contact = sip_contact_dup(ctx->home, m));
+  TEST_1(ctx->c.to = sip_to_dup(ctx->home, sipaddress));
+  free_events_in_list(ctx, ctx->c.events);
+
+  if (print_headings)
+    printf("TEST NUA-2.2.3: PASSED\n");
+
+  END();
+}
+
+
+/* ====================================================================== */
+
+int test_deinit(struct context *ctx)
+{
+  BEGIN();
+
+  struct call *call;
+
+  if (!ctx->threading)
+    su_root_step(ctx->root, 100);
+
+  if (ctx->a.nua) {
+    for (call = ctx->a.call; call; call = call->next)
+      nua_handle_destroy(call->nh), call->nh = NULL;
+
+    nua_shutdown(ctx->a.nua);
+    run_a_until(ctx, nua_r_shutdown, until_final_response);
+    free_events_in_list(ctx, ctx->a.specials);
+    nua_destroy(ctx->a.nua), ctx->a.nua = NULL;
+  }
+
+  if (ctx->b.nua) {
+    for (call = ctx->b.call; call; call = call->next)
+      nua_handle_destroy(call->nh), call->nh = NULL;
+
+    nua_shutdown(ctx->b.nua);
+    run_b_until(ctx, nua_r_shutdown, until_final_response);
+    free_events_in_list(ctx, ctx->b.specials);
+    nua_destroy(ctx->b.nua), ctx->b.nua = NULL;
+  }
+
+  if (ctx->c.nua) {
+    for (call = ctx->c.call; call; call = call->next)
+      nua_handle_destroy(call->nh), call->nh = NULL;
+
+    nua_shutdown(ctx->c.nua);
+    run_c_until(ctx, nua_r_shutdown, until_final_response);
+    free_events_in_list(ctx, ctx->c.specials);
+    nua_destroy(ctx->c.nua), ctx->c.nua = NULL;
+  }
+
+  test_proxy_destroy(ctx->p), ctx->p = NULL;
+
+  test_nat_destroy(ctx->nat), ctx->nat = NULL;
+
+  su_root_destroy(ctx->root);
+
+  END();
+}

libsofia-sip-ua/nua/test_nua.h

@@ -271,6 +271,15 @@ int is_offer_answer_done(tagi_t const *tags);
 int audio_activity(tagi_t const *tags);
 int video_activity(tagi_t const *tags);
 
+void print_event(nua_event_t event,
+		 char const *operation,
+		 int status, char const *phrase,
+		 nua_t *nua, struct context *ctx,
+		 struct endpoint *ep,
+		 nua_handle_t *nh, struct call *call,
+		 sip_t const *sip,
+		 tagi_t tags[]);
+
 static inline
 void eventlist_init(struct eventlist *list)
 {
@@ -284,6 +293,14 @@ void call_init(struct call *call)
 
 void endpoint_init(struct context *ctx, struct endpoint *e, char id);
 
+int test_nua_init(struct context *ctx,
+		  int start_proxy,
+		  url_t const *o_proxy,
+		  int start_nat,
+		  tag_type_t tag, tag_value_t value, ...);
+
+int test_deinit(struct context *ctx);
+
 int test_nua_api_errors(struct context *ctx);
 int test_stack_errors(struct context *ctx);
 int test_tag_filter(void);

libsofia-sip-ua/nua/test_ops.c

+/*
+ * This file is part of the Sofia-SIP package
+ *
+ * Copyright (C) 2005 Nokia Corporation.
+ *
+ * Contact: Pekka Pessi <pekka.pessi@nokia.com>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public License
+ * as published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA
+ *
+ */
+
+/**@CFILE test_ops.c
+ * @brief High-level test framework for Sofia SIP User Agent Engine
+ *
+ * @author Pekka Pessi <Pekka.Pessi@nokia.com>
+ * @author Martti Mela <Martti Mela@nokia.com>
+ *
+ * @date Created: Wed Aug 17 12:12:12 EEST 2005 ppessi
+ */
+
+#include "config.h"
+
+#include "test_nua.h"
+
+#if HAVE_FUNC
+#elif HAVE_FUNCTION
+#define __func__ __FUNCTION__
+#else
+#define __func__ name
+#endif
+
+int save_events(CONDITION_PARAMS)
+{
+  return save_event_in_list(ctx, event, ep, ep->call) == event_is_normal;
+}
+
+int until_final_response(CONDITION_PARAMS)
+{ 
+  return status >= 200;
+}
+
+int save_until_final_response(CONDITION_PARAMS)
+{
+  save_event_in_list(ctx, event, ep, ep->call);
+  return event >= nua_r_set_params && status >= 200;
+}
+
+/** Save events.
+ *
+ * Terminate when a event is saved.
+ */
+int save_until_received(CONDITION_PARAMS)
+{
+  return save_event_in_list(ctx, event, ep, ep->call) == event_is_normal;
+}
+
+/** Save events until nua_i_outbound is received.  */
+int save_until_special(CONDITION_PARAMS)
+{
+  return save_event_in_list(ctx, event, ep, ep->call) == event_is_special;
+}
+
+/* Return call state from event tag list */
+int callstate(tagi_t const *tags)
+{
+  tagi_t const *ti = tl_find(tags, nutag_callstate);
+  return ti ? ti->t_value : -1;
+}
+
+/* Return true if offer is sent */
+int is_offer_sent(tagi_t const *tags)
+{
+  tagi_t const *ti = tl_find(tags, nutag_offer_sent);
+  return ti ? ti->t_value : 0;
+}
+
+/* Return true if answer is sent */
+int is_answer_sent(tagi_t const *tags)
+{
+  tagi_t const *ti = tl_find(tags, nutag_answer_sent);
+  return ti ? ti->t_value : 0;
+}
+
+/* Return true if offer is recv */
+int is_offer_recv(tagi_t const *tags)
+{
+  tagi_t const *ti = tl_find(tags, nutag_offer_recv);
+  return ti ? ti->t_value : 0;
+}
+
+/* Return true if answer is recv */
+int is_answer_recv(tagi_t const *tags)
+{
+  tagi_t const *ti = tl_find(tags, nutag_answer_recv);
+  return ti ? ti->t_value : 0;
+}
+
+/* Return true if offer/answer is sent/recv */
+int is_offer_answer_done(tagi_t const *tags)
+{
+  tagi_t const *ti;
+
+  return 
+    ((ti = tl_find(tags, nutag_answer_recv)) && ti->t_value) ||
+    ((ti = tl_find(tags, nutag_offer_sent)) && ti->t_value) ||
+    ((ti = tl_find(tags, nutag_offer_recv)) && ti->t_value) ||
+    ((ti = tl_find(tags, nutag_answer_sent)) && ti->t_value);
+}
+
+/* Return audio state from event tag list */
+int audio_activity(tagi_t const *tags)
+{
+  tagi_t const *ti = tl_find(tags, soatag_active_audio);
+  return ti ? ti->t_value : -1;
+}
+
+/* Return video state from event tag list */
+int video_activity(tagi_t const *tags)
+{
+  tagi_t const *ti = tl_find(tags, soatag_active_video);
+  return ti ? ti->t_value : -1;
+}
+
+void print_event(nua_event_t event,
+		 char const *operation,
+		 int status, char const *phrase,
+		 nua_t *nua, struct context *ctx,
+		 struct endpoint *ep,
+		 nua_handle_t *nh, struct call *call,
+		 sip_t const *sip,
+		 tagi_t tags[])
+{
+  if (event == nua_i_state) {
+    fprintf(stderr, "%s.nua(%p): event %s %s\n",
+	    ep->name, nh, nua_event_name(event),
+	    nua_callstate_name(callstate(tags)));
+  }
+  else if ((int)event >= nua_r_set_params) {
+    fprintf(stderr, "%s.nua(%p): event %s status %u %s\n",
+	    ep->name, nh, nua_event_name(event), status, phrase);
+  }
+  else if ((int)event >= 0) {
+    fprintf(stderr, "%s.nua(%p): event %s %s\n",
+	    ep->name, nh, nua_event_name(event), phrase);
+  }
+  else if (status > 0) {
+    fprintf(stderr, "%s.nua(%p): call %s() with status %u %s\n",
+	    ep->name, nh, operation, status, phrase);
+  }
+  else {
+    tagi_t const *t;
+    t = tl_find(tags, siptag_subject_str);
+    if (t && t->t_value) {
+      char const *subject = (char const *)t->t_value;
+      fprintf(stderr, "%s.nua(%p): call %s() \"%s\"\n",
+	      ep->name, nh, operation, subject);
+    }
+    else
+      fprintf(stderr, "%s.nua(%p): call %s()\n",
+	      ep->name, nh, operation);
+  }
+
+  if ((tstflags & tst_verbatim) && tags)
+    tl_print(stderr, "", tags);
+}
+
+void ep_callback(nua_event_t event,
+		 int status, char const *phrase,
+		 nua_t *nua, struct context *ctx,
+		 struct endpoint *ep,
+		 nua_handle_t *nh, struct call *call,
+		 sip_t const *sip,
+		 tagi_t tags[])
+{
+  if (ep->printer)
+    ep->printer(event, "", status, phrase, nua, ctx, ep, nh, call, sip, tags);
+
+  if (call == NULL && nh) {
+    for (call = ep->call; call; call = call->next) {
+      if (!call->nh)
+	break;
+      if (nh == call->nh)
+	break;
+    }
+
+    if (call && call->nh == NULL) {
+      call->nh = nh;
+      nua_handle_bind(nh, call);
+    }
+  }
+
+  if ((ep->next_event == -1 || ep->next_event == event) &&
+      (ep->next_condition == NULL ||
+       ep->next_condition(event, status, phrase,
+			  nua, ctx, ep, nh, call, sip, tags)))
+    ep->running = 0;
+
+  ep->last_event = event;
+