/*
 * SIP Stress testing Agent -- by amoizard@gmail.com
 *
 * This program is Free Software, released under the GNU General
 * Public License v2.0 http://www.gnu.org/licenses/gpl
 *
 * This program will do some stress testing on exosip.
 *
 */

#if !defined(WIN32)
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <syslog.h>
#ifndef OSIP_MONOTHREAD
#include <pthread.h>
#endif
#include <string.h>
#ifdef __linux
#include <signal.h>
#endif
#endif

#include <sys/time.h>

#include <osip2/osip_mt.h>
#include <eXosip2/eXosip.h>
#include <osip2/osip.h>

#if !defined(WIN32)
#define _GNU_SOURCE
#include <getopt.h>
#endif

#define PROG_NAME "sip_storm"
#define SYSLOG_FACILITY LOG_DAEMON

static volatile int keepRunning = 2;
static int debug = 0;
static char transport[5];

#ifdef __linux

static void intHandler(int dummy) {
  keepRunning = 0;
}
#endif

#if defined(WIN32)
static void syslog_wrapper(int a, const char *fmt, ...) {
  va_list args;

  va_start(args, fmt);
  vfprintf(stdout, fmt, args);
  va_end(args);
}

#define LOG_INFO 0
#define LOG_ERR 0
#define LOG_WARNING 0
#define LOG_DEBUG 0

#elif defined(LOG_PERROR)
/* If we can, we use syslog() to emit the debugging messages to stderr. */
#define syslog_wrapper syslog
#else
#define syslog_wrapper(a, b...) \
  fprintf(stderr, b);           \
  fprintf(stderr, "\n")
#endif

static void usage(void);

static void usage(void) {
  printf(PROG_NAME
         " v%s\n"
         "\nUsage: " PROG_NAME
         " [required_options] [optional_options]\n"
         "\n[required_options]\n"
         "  -r --proxy       sip:proxyhost[:port],sip:proxyhost2[:port2],...\n"
         "  -u --from        sip:user@host[:port],sip:user@host[:port],...\n"
         "  -x --to          sip:user@host[:port],sip:user@host[:port],...\n"
         "\n[optional_options]\n"
         "  -d --daemon                                 (fork in daemon mode)\n"
         "  -s --syslogandconsole                       (output syslog to stderr)\n"
         "  -v --verbose     number                     (show exosip logs to stdout)\n"
         "  -f --rate        number                     (default 2000 - interval between each outgoing message - ms)\n"
         "\n[optional_sip_options]\n"
         "  -U --username    username,username2,...     (authentication username list)\n"
         "  -P --password    password,password2,...     (authentication password list)\n"
         "  -o --outbound    sip:proxyhost[:port],sip:proxyhost2[:port2],...\n"
         "                                              (outbound proxy list)\n"
         "  -t --transport   UDP|TCP|TLS|DTLS           (default UDP)\n"
         "  -e --expiry      number                     (default 0 second - ie: fetch bindings)\n"
         "  -S --sslrootcapath /etc/path                (default /etc/ssl/certs/)\n"
         "\n[very_optional_sip_options]\n"
         "  -p --port        number                     (default 0 - random)\n"
         "  -c --contact     sip:user@host[:port]\n"
         "  -m --automasquerade                         (auto discover NAT IP:PORT)\n"
         "\n"
         "  -h --help\n",
         eXosip_get_version());
}

struct reg_param {
  int regid;
  int expiry;
  int auth;
};

#define MAX_SIP_CONFIG 10

struct sip_config_ua {
  char *fromuser;
  char *touser;
  char *proxy;
  char *outbound;
  char *username;
  char *password;
  struct reg_param regparam;
};

struct eXosip_t *context_eXosip;

#if defined(WIN32) || defined(__linux)
#define HAVE_LOCALTIME
#endif
#define MAX_LENGTH_TR 2024

static void __osip_trace_func(const char *fi, int li, osip_trace_level_t level, const char *chfr, va_list args) {
  char time_buffer[80] = {'\0'};
#if defined(HAVE_LOCALTIME)
  {
    time_t timestamp;
    struct timeval now;
    struct tm *ptm;
#ifdef __USE_POSIX
    struct tm local_tm;
#endif
    int tenths_ms;
    osip_gettimeofday(&now, NULL);

    timestamp = now.tv_sec;
    tenths_ms = now.tv_usec / (100L);
#ifdef __USE_POSIX
    ptm = localtime_r(&timestamp, &local_tm);
#else
    ptm = localtime(&timestamp);
#endif

    snprintf(time_buffer, 80, "%04d-%02d-%02d %02d:%02d:%02d.%04d", 1900 + ptm->tm_year, ptm->tm_mon + 1, ptm->tm_mday, ptm->tm_hour, ptm->tm_min, ptm->tm_sec, tenths_ms);
  }
#endif

  {
    char buffer[MAX_LENGTH_TR];
    int in = 0;

    memset(buffer, 0, sizeof(buffer));

    if (level == OSIP_FATAL) {
      in = snprintf(buffer, MAX_LENGTH_TR - 1, "| FATAL | %s <%10.10s:%5i> ", time_buffer, fi, li);

    } else if (level == OSIP_BUG) {
      in = snprintf(buffer, MAX_LENGTH_TR - 1, "|  BUG  | %s <%10.10s:%5i> ", time_buffer, fi, li);

    } else if (level == OSIP_ERROR) {
      in = snprintf(buffer, MAX_LENGTH_TR - 1, "| ERROR | %s <%10.10s:%5i> ", time_buffer, fi, li);

    } else if (level == OSIP_WARNING) {
      in = snprintf(buffer, MAX_LENGTH_TR - 1, "|WARNING| %s <%10.10s:%5i> ", time_buffer, fi, li);

    } else if (level == OSIP_INFO1) {
      in = snprintf(buffer, MAX_LENGTH_TR - 1, "| INFO1 | %s <%10.10s:%5i> ", time_buffer, fi, li);

    } else if (level == OSIP_INFO2) {
      in = snprintf(buffer, MAX_LENGTH_TR - 1, "| INFO2 | %s <%10.10s:%5i> ", time_buffer, fi, li);

    } else if (level == OSIP_INFO3) {
      in = snprintf(buffer, MAX_LENGTH_TR - 1, "| INFO3 | %s <%10.10s:%5i> ", time_buffer, fi, li);

    } else if (level == OSIP_INFO4) {
      in = snprintf(buffer, MAX_LENGTH_TR - 1, "| INFO4 | %s <%10.10s:%5i> ", time_buffer, fi, li);
    }

    vsnprintf(buffer + in, MAX_LENGTH_TR - 1 - in, chfr, args);
    buffer[MAX_LENGTH_TR - 1] = '\0';

    if (debug > (int) level) {
      printf("%s", buffer);
    }

  }
}

#ifdef TEST_NAPTR

static int _naptr_lookup(const char *sip_server, struct osip_naptr *naptr_lookup, int keep_in_cache) {
  osip_naptr_t *naptr_record;
  naptr_record = eXosip_dnsutils_naptr(context_eXosip, sip_server, "sip", "tcp", keep_in_cache);

  if (naptr_record != NULL) {
    while (1) {
      /* 1: make sure there is no pending DNS */
      eXosip_dnsutils_dns_process(naptr_record, 1);

      if (naptr_record->naptr_state == OSIP_NAPTR_STATE_NAPTRDONE || naptr_record->naptr_state == OSIP_NAPTR_STATE_SRVINPROGRESS) {
        eXosip_dnsutils_dns_process(naptr_record, 1);
      }

      if (naptr_record->naptr_state == OSIP_NAPTR_STATE_UNKNOWN) {
        /* fallback to DNS A */
        /* should never happen? */
        eXosip_dnsutils_release(naptr_record);
        return OSIP_NOTFOUND;

      } else if (naptr_record->naptr_state == OSIP_NAPTR_STATE_INPROGRESS) {
        /* 2: keep waiting (naptr answer not received) */
        osip_usleep(10000);
        continue;

      } else if (naptr_record->naptr_state == OSIP_NAPTR_STATE_NAPTRDONE) {
        /* 3: keep waiting (naptr answer received/no srv answer received) */
        osip_usleep(1000);
        continue;

      } else if (naptr_record->naptr_state == OSIP_NAPTR_STATE_SRVINPROGRESS) {
        /* 3: keep waiting (naptr answer received/no srv answer received) */
        osip_usleep(1000);
        continue;

      } else if (naptr_record->naptr_state == OSIP_NAPTR_STATE_SRVDONE) {
        /* 4: check if we have the one we want... */
        if (naptr_lookup != NULL) {
          memcpy(naptr_lookup, naptr_record, sizeof(struct osip_naptr));
        }

        eXosip_dnsutils_release(naptr_record);
        return OSIP_SUCCESS;

      } else if (naptr_record->naptr_state == OSIP_NAPTR_STATE_NOTSUPPORTED) {
        /* 5: fallback to DNS A */
        eXosip_dnsutils_release(naptr_record);
        return OSIP_NOTFOUND;

      } else if (naptr_record->naptr_state == OSIP_NAPTR_STATE_RETRYLATER) {
        /* 5: fallback to DNS A */
        eXosip_dnsutils_release(naptr_record);
        return OSIP_TIMEOUT;
      }
    }
  }

  return -1;
}

static int _resolv_naptr(const char *domain) {
  struct timeval time_start;
  struct timeval time_end;
  struct timeval time_sub;

  int err;
  struct osip_naptr naptr_lookup;

  osip_gettimeofday(&time_start, NULL);

  memset(&naptr_lookup, 0, sizeof(struct osip_naptr));
  err = _naptr_lookup(domain, &naptr_lookup, 1);

  if (err == OSIP_SUCCESS) {
    if (naptr_lookup.sipenum_record.name[0] != '\0') {
      /* enum resolved: */
      syslog_wrapper(LOG_INFO, "ENUM: %s -> %s", domain, naptr_lookup.sipenum_record.name);

    } else {
      struct osip_srv_record *best = NULL;

      if (naptr_lookup.sipudp_record.srventry[0].port > 0) {
        best = &naptr_lookup.sipudp_record;

      } else if (naptr_lookup.siptcp_record.srventry[0].port > 0) {
        best = &naptr_lookup.siptcp_record;

      } else if (naptr_lookup.siptls_record.srventry[0].port > 0) {
        best = &naptr_lookup.siptls_record;
      }

      if (best != NULL) {
        if (naptr_lookup.siptcp_record.srventry[0].port > 0) {
          if (naptr_lookup.siptcp_record.order <= best->order) {
            best = &naptr_lookup.siptcp_record;
          }
        }

        if (naptr_lookup.siptls_record.srventry[0].port > 0) {
          if (naptr_lookup.siptls_record.order <= best->order) {
            best = &naptr_lookup.siptls_record;
          }
        }

        osip_gettimeofday(&time_end, NULL);
        osip_timersub(&time_end, &time_start, &time_sub);
        syslog_wrapper(LOG_INFO, "NAPTR REPORT:[SUCCESS] [duration:%li,%03lis] best service for %s -> [%s] [%s:%i]", time_sub.tv_sec, time_sub.tv_usec / 1000, naptr_lookup.domain, best->protocol, best->srventry[0].srv, best->srventry[0].port);
        return 0;
      }
    }
  }

  osip_gettimeofday(&time_end, NULL);
  osip_timersub(&time_end, &time_start, &time_sub);
  syslog_wrapper(LOG_ERR, "NAPTR REPORT:[FAILURE] [duration:%li,%03lis] no NAPTR/no SRV record for %s", time_sub.tv_sec, time_sub.tv_usec / 1000, domain);
  return 0;
}

#endif

static int _am_option_route_add_lr(const char *orig_route, char *dst_route, int dst_route_size) {
  osip_route_t *route_header = NULL;
  char *new_route = NULL;
  const char *tmp;
  const char *tmp2;
  int i;

  memset(dst_route, '\0', dst_route_size);
  if (orig_route == NULL || orig_route[0] == '\0')
    return 0;

  tmp = strstr(orig_route, "sip:");
  tmp2 = strstr(orig_route, "sips:");
  if (tmp == NULL && tmp2 == NULL) {
    snprintf(dst_route, dst_route_size, "<sip:%s;lr>", orig_route);
    return 0;
  }

  i = osip_route_init(&route_header);
  if (i != 0 || route_header == NULL)
    return OSIP_NOMEM;
  i = osip_route_parse(route_header, orig_route);
  if (i != 0 || route_header->url == NULL || route_header->url->host == NULL) {
    osip_route_free(route_header);
    snprintf(dst_route, dst_route_size, "%s", orig_route);
    return i;
  }

  tmp = strstr(orig_route, ";lr");
  if (tmp == NULL)
    osip_uri_uparam_add(route_header->url, osip_strdup("lr"), NULL);

  i = osip_route_to_str(route_header, &new_route);
  osip_route_free(route_header);
  if (i != 0 || new_route == NULL) {
    return i;
  }
  snprintf(dst_route, dst_route_size, "%s", new_route);
  osip_free(new_route);
  return 0;
}

static int _prepend_route(osip_message_t *sip, const char *hvalue) {
  osip_route_t *route;
  int i;
  char outbound_route[256];

  if (hvalue == NULL || hvalue[0] == '\0')
    return OSIP_SUCCESS;

  memset(outbound_route, '\0', sizeof(outbound_route));
  i = _am_option_route_add_lr(hvalue, outbound_route, sizeof(outbound_route));
  if (i != 0)
    return i;

  i = osip_route_init(&route);

  if (i != 0)
    return i;
  i = osip_route_parse(route, outbound_route);
  if (i != 0) {
    osip_route_free(route);
    return i;
  }
  sip->message_property = 2;
  osip_list_add(&sip->routes, route, 0);
  return OSIP_SUCCESS;
}


static int start_register(struct sip_config_ua *config_ua, const char *contact) {
  osip_message_t *reg = NULL;
  int err;
  
  if (contact != NULL && config_ua->regparam.expiry == -1) {
    config_ua->regparam.expiry = 300;
  }
  
  eXosip_lock(context_eXosip);
  
  if (contact == NULL && config_ua->regparam.expiry == -1) {
    config_ua->regparam.regid = eXosip_register_build_initial_register(context_eXosip, config_ua->fromuser, config_ua->proxy, contact, 0, &reg);
    
  } else {
    config_ua->regparam.regid = eXosip_register_build_initial_register(context_eXosip, config_ua->fromuser, config_ua->proxy, contact, config_ua->regparam.expiry, &reg);
  }
  
  if (config_ua->regparam.regid < 1) {
    eXosip_unlock(context_eXosip);
    syslog_wrapper(LOG_ERR, "REGISTRATION REPORT:[FAILURE] [%s][duration:0,000s] cannot prepare sip REGISTER [%i]", transport, config_ua->regparam.regid);
    return -1;
  }
  
  _prepend_route(reg, config_ua->outbound);
  
  if (contact == NULL && config_ua->regparam.expiry == -1) {
    int pos = 0;
    
    while (!osip_list_eol(&reg->contacts, pos)) {
      osip_contact_t *co;
      
      co = (osip_contact_t *) osip_list_get(&reg->contacts, pos);
      osip_list_remove(&reg->contacts, pos);
      osip_contact_free(co);
    }
  }
  
  err = eXosip_register_send_register(context_eXosip, config_ua->regparam.regid, reg);
  eXosip_unlock(context_eXosip);
  
  if (err != 0) {
    syslog_wrapper(LOG_ERR, "REGISTRATION REPORT:[FAILURE] [%s][duration:0,000s] cannot send sip REGISTER [%i]", transport, err);
    return -1;
  }
  return 0;
}

static int start_message(const char *method, struct sip_config_ua *config_ua, const char *data) {
  osip_message_t *message = NULL;
  int tid;
  
  eXosip_lock(context_eXosip);
  
  tid = eXosip_message_build_request(context_eXosip, &message, method, config_ua->touser, config_ua->fromuser, NULL);
  
  if (tid < 0) {
    eXosip_unlock(context_eXosip);
    syslog_wrapper(LOG_ERR, "MESSAGE REPORT:[FAILURE] [%s][duration:0,000s] cannot prepare sip %s [%i]", transport, method, tid);
    return -1;
  }
  
  _prepend_route(message, config_ua->proxy);
  _prepend_route(message, config_ua->outbound);
  
  tid = eXosip_message_send_request(context_eXosip, message);
  eXosip_unlock(context_eXosip);
  
  if (tid < 0) {
    syslog_wrapper(LOG_ERR, "REGISTRATION REPORT:[FAILURE] [%s][duration:0,000s] cannot send sip REGISTER [%i]", transport, tid);
    return -1;
  }
  return 0;
}

int main(int argc, char *argv[]) {
  int c;
  int port = 0;
  char *contact = NULL;
  struct sip_config_ua config_ua[MAX_SIP_CONFIG];
  int idx;
  int automasquerade = 0;
  int rate = 2000;

  struct servent *service;
  char sslrootcapath[1024];
  int fork = 0;
  int log_perror = 0;
  int err;

  char prog_name[32];
  int optval;
  char *cur;
  char *next;
  
  struct timeval time_interval;
  
  snprintf(prog_name, sizeof(prog_name), "%s (%s)", PROG_NAME, eXosip_get_version());

  memset(&config_ua, 0, sizeof(struct sip_config_ua) * MAX_SIP_CONFIG);
  for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
    config_ua[idx].regparam.expiry = -1;
  }
#ifdef SIGPIPE
  signal(SIGPIPE, SIG_IGN);
#endif
#ifdef __linux
  signal(SIGINT, intHandler);
#endif

  snprintf(transport, sizeof(transport), "%s", "UDP");
  snprintf(sslrootcapath, sizeof(sslrootcapath), "%s", "/etc/ssl/certs/");

  for (;;) {
#define short_options "du:x:t:r:U:P:o:S:t:p:c:e:mv:f:sh"
#ifdef _GNU_SOURCE
    int option_index = 0;

    static struct option long_options[] = {{"deamon", no_argument, NULL, 'd'},
                                           {"from", required_argument, NULL, 'u'},
                                           {"to", required_argument, NULL, 'x'},
                                           {"proxy", required_argument, NULL, 'r'},
                                           {"username", required_argument, NULL, 'U'},
                                           {"password", required_argument, NULL, 'P'},
                                           {"outbound", required_argument, NULL, 'o'},

                                           {"sslrootcapath", required_argument, NULL, 'S'},
                                           {"transport", required_argument, NULL, 't'},
                                           {"port", required_argument, NULL, 'p'},
                                           {"contact", required_argument, NULL, 'c'},
                                           {"expiry", required_argument, NULL, 'e'},
                                           {"automasquerade", no_argument, NULL, 'm'},
                                           {"syslogandconsole", no_argument, NULL, 's'},
                                           {"verbose", required_argument, NULL, 'v'},
                                           {"rate", required_argument, NULL, 'f'},

                                           {"help", no_argument, NULL, 'h'},

                                           {NULL, 0, NULL, 0}};

    c = getopt_long(argc, argv, short_options, long_options, &option_index);
#else
    c = getopt(argc, argv, short_options);
#endif

    if (c == -1) {
      break;
    }

    switch (c) {
    case 'c':
      contact = optarg;
      break;

    case 'd':
      fork = 1;
      break;

    case 'v':
      debug = atoi(optarg);
      break;

    case 'f':
      rate = atoi(optarg);
      break;

    case 's':
#ifdef LOG_PERROR
      log_perror = LOG_PERROR;
#endif
      break;

    case 'e':
      for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
	config_ua[idx].regparam.expiry = atoi(optarg);
      }
      break;

    case 'm':
      automasquerade = 1;
      break;

    case 'h':
      usage();
      exit(0);

    case 'p':
      service = getservbyname(optarg, "udp");

      if (service) {
        port = ntohs(service->s_port);

      } else {
        port = atoi(optarg);
      }

      break;

    case 't':
      snprintf(transport, sizeof(transport), "%s", optarg);
      break;

    case 'r':
      idx=0;
      cur = optarg;
      next = strchr(cur, ',');
      for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
	if (cur == NULL) {
	  break;
	}
	if (next == NULL) {
	  config_ua[idx].proxy = cur;
	  break;
	} else {
	  config_ua[idx].proxy = cur;
	  next[0] = '\0';
	  cur = next + 1;
	  next = strchr(cur, ',');
	}
      }
      break;

    case 'u':
      idx=0;
      cur = optarg;
      next = strchr(cur, ',');
      for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
	if (cur == NULL) {
	  break;
	}
	if (next == NULL) {
	  config_ua[idx].fromuser = cur;
	  break;
	} else {
	  config_ua[idx].fromuser = cur;
	  next[0] = '\0';
	  cur = next + 1;
	  next = strchr(cur, ',');
	}
      }
      break;

    case 'x':
      idx=0;
      cur = optarg;
      next = strchr(cur, ',');
      for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
	if (cur == NULL) {
	  break;
	}
	if (next == NULL) {
	  config_ua[idx].touser = cur;
	  break;
	} else {
	  config_ua[idx].touser = cur;
	  next[0] = '\0';
	  cur = next + 1;
	  next = strchr(cur, ',');
	}
      }
      break;

    case 'U':
      idx=0;
      cur = optarg;
      next = strchr(cur, ',');
      for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
	if (cur == NULL) {
	  break;
	}
	if (next == NULL) {
	  config_ua[idx].username = cur;
	  break;
	} else {
	  config_ua[idx].username = cur;
	  next[0] = '\0';
	  cur = next + 1;
	  next = strchr(cur, ',');
	}
      }
      break;

    case 'P':
      idx=0;
      cur = optarg;
      next = strchr(cur, ',');
      for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
	if (cur == NULL) {
	  break;
	}
	if (next == NULL) {
	  config_ua[idx].password = cur;
	  break;
	} else {
	  config_ua[idx].password = cur;
	  next[0] = '\0';
	  cur = next + 1;
	  next = strchr(cur, ',');
	}
      }
      break;

    case 'o':
      idx=0;
      cur = optarg;
      next = strchr(cur, ',');
      for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
	if (cur == NULL) {
	  break;
	}
	if (next == NULL) {
	  config_ua[idx].outbound = cur;
	  break;
	} else {
	  config_ua[idx].outbound = cur;
	  next[0] = '\0';
	  cur = next + 1;
	  next = strchr(cur, ',');
	}
      }
      break;

    case 'S':
      snprintf(sslrootcapath, sizeof(sslrootcapath), "%s", optarg);
      break;

    default:
      break;
    }
  }

#ifdef LOG_PERROR
  openlog(PROG_NAME, LOG_PID | log_perror, SYSLOG_FACILITY);
#endif

  for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
    if (config_ua[idx].fromuser == NULL)
      break;
    syslog_wrapper(LOG_INFO, "%s up and running [testing on [%s] REGISTER [%s] From: [%s]%s%s%s %s%s%s", prog_name, transport, config_ua[idx].proxy, config_ua[idx].fromuser, (config_ua[idx].username && config_ua[idx].password) ? " Username: [" : "", (config_ua[idx].username && config_ua[idx].password) ? config_ua[idx].username : "",
		   (config_ua[idx].username && config_ua[idx].password) ? ":*****]" : "", config_ua[idx].outbound? "Route: [" : "", config_ua[idx].outbound? config_ua[idx].outbound : "", config_ua[idx].outbound ? "]" : "");
    
    if (!config_ua[idx].proxy || !config_ua[idx].fromuser || strlen(config_ua[idx].proxy) < 7 || strlen(config_ua[idx].fromuser) < 7) {
      syslog_wrapper(LOG_ERR, "REGISTRATION REPORT:[FAILURE] [%s][duration:0,000s] missing or broken mandatory parameter", transport);
      usage();
      exit(1);
    }
  }
  
  if (osip_strcasecmp(transport, "UDP") != 0 && osip_strcasecmp(transport, "TCP") != 0 && osip_strcasecmp(transport, "TLS") != 0 && osip_strcasecmp(transport, "DTLS") != 0) {
    syslog_wrapper(LOG_ERR, "REGISTRATION REPORT:[FAILURE] [%s][duration:0,000s] wrong transport parameter", transport);
    usage();
    exit(1);
  }

  if (fork) {
    err = daemon(1, 0);
    if (err < 0) {
      syslog_wrapper(LOG_ERR, "REGISTRATION REPORT:[FAILURE] [%s][duration:0,000s] daemon mode failed", transport);
      exit(1);
    }
  }

  osip_trace_initialize_func(TRACE_LEVEL7, __osip_trace_func);

  context_eXosip = eXosip_malloc();
  err = eXosip_init(context_eXosip);

  if (err) {
    syslog_wrapper(LOG_ERR, "REGISTRATION REPORT:[FAILURE] [%s][duration:0,000s] eXosip_init failure [%i]", transport, err);
    exit(1);
  }

  eXosip_set_user_agent(context_eXosip, prog_name);

  for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
    if (config_ua[idx].username && config_ua[idx].password) {
      err = eXosip_add_authentication_info(context_eXosip, config_ua[idx].username, config_ua[idx].username, config_ua[idx].password, NULL, NULL);
      
      if (err) {
	syslog_wrapper(LOG_ERR, "REGISTRATION REPORT:[FAILURE] [%s][duration:0,000s] cannot add credential [%i]", transport, err);
	eXosip_quit(context_eXosip);
	osip_free(context_eXosip);
	exit(1);
      }
    }
  }
  
  optval = 1;
  eXosip_set_option(context_eXosip, EXOSIP_OPT_SET_TLS_VERIFY_CERTIFICATE, &optval);

  {
    eXosip_tls_ctx_t tls_description;
    memset(&tls_description, 0, sizeof(eXosip_tls_ctx_t));
    snprintf(tls_description.root_ca_cert, sizeof(tls_description.root_ca_cert), "%s", sslrootcapath);
    eXosip_set_option(context_eXosip, EXOSIP_OPT_SET_TLS_CERTIFICATES_INFO, &tls_description);
  }

  optval = automasquerade;
  eXosip_set_option(context_eXosip, EXOSIP_OPT_AUTO_MASQUERADE_CONTACT, &optval);

  if (automasquerade) {
    syslog_wrapper(LOG_INFO, "automasquerade enabled");
  }

#ifdef TEST_NAPTR
  if (osip_strncasecmp(proxy, "sip:", 4) == 0) {
    _resolv_naptr(proxy + 4);

  } else if (osip_strncasecmp(proxy, "sips:", 4) == 0) {
    _resolv_naptr(proxy + 4);
  }
#endif

  err = -1;

  if (osip_strcasecmp(transport, "UDP") == 0) {
    err = eXosip_listen_addr(context_eXosip, IPPROTO_UDP, NULL, port, AF_INET, 0);

  } else if (osip_strcasecmp(transport, "TCP") == 0) {
    err = eXosip_listen_addr(context_eXosip, IPPROTO_TCP, NULL, port, AF_INET, 0);

  } else if (osip_strcasecmp(transport, "TLS") == 0) {
    err = eXosip_listen_addr(context_eXosip, IPPROTO_TCP, NULL, port, AF_INET, 1);

  } else if (osip_strcasecmp(transport, "DTLS") == 0) {
    err = eXosip_listen_addr(context_eXosip, IPPROTO_UDP, NULL, port, AF_INET, 1);
  }

  if (err) {
    syslog_wrapper(LOG_ERR, "REGISTRATION REPORT:[FAILURE] [%s][duration:0,000s] cannot prepare sip network layer [%i]", transport, err);
    eXosip_quit(context_eXosip);
    osip_free(context_eXosip);
    exit(1);
  }

  osip_gettimeofday(&time_interval, NULL);
  
  for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
    if (config_ua[idx].fromuser == NULL)
      break;
    start_register(&config_ua[idx], contact);
  }
  
  for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
    if (config_ua[idx].touser == NULL)
      break;
    start_message("MESSAGE", &config_ua[idx], "Hello World");
  }
  
  for (; keepRunning;) {
    eXosip_event_t *event;
    struct timeval now;
    struct timeval duration;

    osip_gettimeofday(&now, NULL);
    osip_timersub(&now, &time_interval, &duration);

    if ((duration.tv_sec * 1000 + duration.tv_usec / 1000) > rate) {
      for (idx = 0; idx < MAX_SIP_CONFIG; idx++) {
	if (config_ua[idx].touser == NULL)
	  break;
	start_message("MESSAGE", &config_ua[idx], "Hello World");
      }
      osip_gettimeofday(&time_interval, NULL);
    }
    
    if (!(event = eXosip_event_wait(context_eXosip, 0, 1))) {
#ifdef OSIP_MONOTHREAD
      eXosip_execute(context_eXosip);
#endif
      eXosip_lock(context_eXosip);
      eXosip_automatic_action(context_eXosip);
      eXosip_unlock(context_eXosip);
      osip_usleep(10000);
      continue;
    }

#ifdef OSIP_MONOTHREAD
    eXosip_execute(context_eXosip);
#endif

    eXosip_lock(context_eXosip);
    eXosip_automatic_action(context_eXosip);

    switch (event->type) {
    case EXOSIP_REGISTRATION_SUCCESS:
      syslog_wrapper(LOG_INFO, "REGISTRATION REPORT:[SUCCESS] [%s] REGISTER [%i][%s]", transport, event->response->status_code, event->response->reason_phrase);
      break;

    case EXOSIP_REGISTRATION_FAILURE:

      if (event->response == NULL) {
        syslog_wrapper(LOG_INFO, "REGISTRATION REPORT:[FAILURE] [%s]REGISTER [408][       ]", transport);

      } else {
        if (event->response->status_code == 401 || event->response->status_code == 407) {
          osip_authorization_t *auth = NULL;
          err = osip_message_get_authorization(event->request, 0, &auth);

          if (err < 0) {

	    syslog_wrapper(LOG_INFO, "[%s] REGISTER [%i][%s]", transport, event->response->status_code, event->response->reason_phrase);

          } else {
            syslog_wrapper(LOG_INFO, "REGISTRATION REPORT:[FAILURE] [%s] REGISTER [%i][%s] - err=bad password", transport, event->response->status_code, event->response->reason_phrase);
          }

        } else {
          syslog_wrapper(LOG_INFO, "REGISTRATION REPORT:[FAILURE] [%s] REGISTER [%i][%s] err=%s", transport, event->response->status_code, event->response->reason_phrase, event->response->reason_phrase);
        }
      }

      break;

    case EXOSIP_CALL_INVITE: {
      osip_message_t *answer;
      int i;

      i = eXosip_call_build_answer(context_eXosip, event->tid, 405, &answer);

      if (i != 0) {
        syslog_wrapper(LOG_ERR, "failed to reject INVITE");
        break;
      }

      osip_free(answer->reason_phrase);
      answer->reason_phrase = osip_strdup("No Support for Incoming Calls");
      i = eXosip_call_send_answer(context_eXosip, event->tid, 405, answer);

      if (i != 0) {
        syslog_wrapper(LOG_ERR, "failed to reject INVITE");
        break;
      }

      syslog_wrapper(LOG_INFO, "INVITE rejected with 405");
      break;
    }

    case EXOSIP_MESSAGE_NEW: {
      osip_message_t *answer;
      int i;

      i = eXosip_message_build_answer(context_eXosip, event->tid, 405, &answer);

      if (i != 0) {
        syslog_wrapper(LOG_ERR, "failed to reject %s", event->request->sip_method);
        break;
      }

      i = eXosip_message_send_answer(context_eXosip, event->tid, 405, answer);

      if (i != 0) {
        syslog_wrapper(LOG_ERR, "failed to reject %s", event->request->sip_method);
        break;
      }

      syslog_wrapper(LOG_INFO, "%s rejected with 405", event->request->sip_method);
      break;
    }

    case EXOSIP_IN_SUBSCRIPTION_NEW: {
      osip_message_t *answer;
      int i;

      i = eXosip_insubscription_build_answer(context_eXosip, event->tid, 405, &answer);

      if (i != 0) {
        syslog_wrapper(LOG_ERR, "failed to reject %s", event->request->sip_method);
        break;
      }

      i = eXosip_insubscription_send_answer(context_eXosip, event->tid, 405, answer);

      if (i != 0) {
        syslog_wrapper(LOG_ERR, "failed to reject %s", event->request->sip_method);
        break;
      }

      syslog_wrapper(LOG_INFO, "%s rejected with 405", event->request->sip_method);
      break;
    }

    case EXOSIP_CALL_CLOSED:
    case EXOSIP_CALL_RELEASED:
      break;

    case EXOSIP_CALL_MESSAGE_REQUESTFAILURE:
      if (event->did < 0 && event->response != NULL && (event->response->status_code == 407 || event->response->status_code == 401))
	eXosip_default_action(context_eXosip, event);
      break;
    case EXOSIP_MESSAGE_REQUESTFAILURE:
      if (event->request != NULL && event->response != NULL && !MSG_IS_PUBLISH(event->request) && (event->response->status_code == 407 || event->response->status_code == 401))
	eXosip_default_action(context_eXosip, event);
      break;
    default:
      syslog_wrapper(LOG_DEBUG, "received unknown eXosip event (type, did, cid) = (%d, %d, %d)", event->type, event->did, event->cid);
    }

    eXosip_unlock(context_eXosip);
    eXosip_event_free(event);
  }

  eXosip_quit(context_eXosip);
  osip_free(context_eXosip);
  return 0;
}