kenmirrors
/
freeswitch
mirror of https://github.com/signalwire/freeswitch.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity
freeswitch/libs/sofia-sip/libsofia-sip-ua/nth/test_nth.c

964 lines
23 KiB
C
Raw Blame History

/*
* 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
*
*/
/**@file test_nth.c
* @brief Tests for nth module
*
* @author Pekka Pessi <Pekka.Pessi@nokia.com>
*
* @date Created: Tue Oct 22 20:52:37 2002 ppessi
*/
#include "config.h"
#include <stddef.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <assert.h>
#if HAVE_ALARM
#include <unistd.h>
#include <signal.h>
#endif
typedef struct tester tester_t;
typedef struct site site_t;
typedef struct client client_t;
#define SU_ROOT_MAGIC_T tester_t
#include <sofia-sip/su_tagarg.h>
#include <sofia-sip/su_wait.h>
#define NTH_CLIENT_MAGIC_T client_t
#define NTH_SITE_MAGIC_T site_t
#include "sofia-sip/nth.h"
#include <sofia-sip/http_header.h>
#include <sofia-sip/msg_mclass.h>
#include <sofia-sip/tport_tag.h>
#include <sofia-sip/auth_module.h>
int tstflags = 0;
#define TSTFLAGS tstflags
#include <sofia-sip/tstdef.h>
#if HAVE_FUNC
#elif HAVE_FUNCTION
#define __func__ __FUNCTION__
#else
#define __func__ name
#endif
char const name[] = "test_nth";
static int init_test(tester_t *t);
static int deinit_test(tester_t *t);
static int test_nth_client_api(tester_t *t);
static int test_nth_server_api(tester_t *t);
static int init_server(tester_t *t);
static int test_requests(tester_t *t);
static int init_engine(tester_t *t);
struct site
{
site_t *s_next, *s_parent;
tester_t *s_tester;
url_string_t *s_url;
nth_site_t *s_ns;
int s_called;
int s_status;
char const *s_phrase;
tagi_t *s_tags;
};
struct client
{
unsigned c_status;
};
struct tester
{
su_home_t t_home[1];
su_root_t *t_root;
msg_mclass_t *t_mclass;
url_string_t *t_proxy;
nth_engine_t *t_engine;
char const *t_srcdir;
char const *t_pem;
su_sockaddr_t t_addr[1];
socklen_t t_addrlen;
su_socket_t t_sink;
url_string_t *t_sinkuri;
su_sockaddr_t t_sinkaddr[1];
socklen_t t_sinkaddrlen;
site_t *t_sites;
site_t *t_master;
};
static int test_site(site_t *t,
nth_site_t *server,
nth_request_t *req,
http_t const *http,
char const *path);
static site_t *site_create(tester_t *t, site_t *parent,
char const *url,
int status, char const *phrase,
tag_type_t tag, tag_value_t value, ...)
{
nth_site_t *pns = parent ? parent->s_ns : NULL;
site_t *s;
ta_list ta;
if (url == NULL)
return NULL;
s = su_zalloc(t->t_home, sizeof *s);
if (s == NULL)
return NULL;
s->s_url = URL_STRING_MAKE(url);
s->s_tester = t;
s->s_next = t->t_sites;
s->s_status = status;
s->s_phrase = phrase;
ta_start(ta, tag, value);
s->s_tags = tl_adup(t->t_home, ta_args(ta));
if (s->s_tags)
s->s_ns = nth_site_create(pns, test_site, s,
(url_string_t *)s->s_url,
NTHTAG_ROOT(t->t_root),
ta_tags(ta));
ta_end(ta);
if (s->s_ns == NULL)
return NULL;
t->t_sites = s;
return s;
}
static int init_test(tester_t *t)
{
su_socket_t s;
BEGIN();
t->t_root = su_root_create(t); TEST_1(t->t_root);
t->t_mclass = msg_mclass_clone(http_default_mclass(), 0, 0);
TEST_1(t->t_mclass);
t->t_addr->su_len = (sizeof t->t_addr->su_sin);
s = su_socket(t->t_addr->su_family = AF_INET, SOCK_STREAM, 0);
TEST_1(s != INVALID_SOCKET);
TEST_1(su_inet_pton(AF_INET, "127.0.0.1", &t->t_addr->su_sin.sin_addr) >= 0);
TEST_1(bind(s, &t->t_addr->su_sa,
t->t_addrlen = (sizeof t->t_addr->su_sin)) != -1);
TEST_1(getsockname(s, &t->t_addr->su_sa, &t->t_addrlen) != -1);
TEST_1(t->t_addr->su_port != 0);
TEST_1(su_close(s) != -1);
t->t_pem = su_sprintf(t->t_home, "%s/agent.pem", t->t_srcdir);
END();
}
static int deinit_test(tester_t *t)
{
site_t *s, *s_next;
BEGIN();
nth_engine_destroy(t->t_engine);
for (s = t->t_sites; s; s = s_next) {
s_next = s->s_next;
nth_site_destroy(s->s_ns), s->s_ns = NULL;
su_free(t->t_home, s);
}
su_root_destroy(t->t_root);
su_home_deinit(t->t_home);
memset(t, 0, sizeof t);
END();
}
static int test_nth_client_api(tester_t *t)
{
char const *s;
BEGIN();
s = nth_engine_version();
TEST_1(s); TEST_1(strlen(s)); TEST_S(s, "sofia-http-client/" NTH_CLIENT_VERSION);
TEST_1(nth_engine_create(NULL, TAG_END()) == NULL);
TEST(errno, EINVAL);
TEST_VOID(nth_engine_destroy(NULL));
TEST_1(nth_engine_get_params(NULL, TAG_END()) == -1);
TEST_1(nth_engine_set_params(NULL, TAG_END()) == -1);
TEST_1(!nth_client_tcreate(NULL, NULL, NULL,
HTTP_METHOD_OPTIONS,
URL_STRING_MAKE("*"),
TAG_END()));
TEST(nth_client_status(NULL), 400);
TEST(nth_client_method(NULL), http_method_invalid);
TEST(nth_client_is_streaming(NULL), 0);
TEST_P(nth_client_url(NULL), NULL);
TEST_P(nth_client_request(NULL), NULL);
TEST_P(nth_client_response(NULL), NULL);
TEST_VOID(nth_client_destroy(NULL));
t->t_engine = nth_engine_create(t->t_root,
NTHTAG_ERROR_MSG(2),
NTHTAG_MCLASS(t->t_mclass),
NTHTAG_MFLAGS(MSG_DO_CANONIC|MSG_DO_COMPACT),
NTHTAG_STREAMING(0),
NTHTAG_PROXY("http://localhost:8888"),
TAG_END());
TEST_1(t->t_engine);
{
int error_msg = -1;
msg_mclass_t const *mclass = (void *)-1;
int mflags = -1;
unsigned expires = -1;
int streaming = -1;
url_string_t const *proxy = (void *)-1;
char *proxy_str;
TEST(nth_engine_get_params(t->t_engine,
NTHTAG_ERROR_MSG_REF(error_msg),
NTHTAG_MCLASS_REF(mclass),
NTHTAG_MFLAGS_REF(mflags),
NTHTAG_EXPIRES_REF(expires),
NTHTAG_STREAMING_REF(streaming),
NTHTAG_PROXY_REF(proxy),
TAG_END()),
6);
TEST(error_msg, 1);
TEST_P(mclass, t->t_mclass);
TEST(mflags, MSG_DO_CANONIC|MSG_DO_COMPACT);
TEST(expires, 32000);
TEST(streaming, 0);
TEST_1(proxy != NULL);
TEST_1(proxy_str = url_as_string(t->t_home, proxy->us_url));
TEST_S(proxy_str, "http://localhost:8888");
proxy = URL_STRING_MAKE("http://127.0.0.1:80");
TEST(nth_engine_set_params(t->t_engine,
NTHTAG_ERROR_MSG(0),
NTHTAG_MCLASS(http_default_mclass()),
NTHTAG_MFLAGS(0),
NTHTAG_EXPIRES(10000),
NTHTAG_STREAMING(2),
NTHTAG_PROXY(proxy),
TAG_END()),
6);
error_msg = -1;
mclass = (void *)-1;
mflags = -1;
expires = (unsigned)-1;
streaming = -1;
proxy = (void *)-1;
TEST(nth_engine_get_params(t->t_engine,
NTHTAG_ERROR_MSG_REF(error_msg),
NTHTAG_MCLASS_REF(mclass),
NTHTAG_MFLAGS_REF(mflags),
NTHTAG_EXPIRES_REF(expires),
NTHTAG_STREAMING_REF(streaming),
NTHTAG_PROXY_REF(proxy),
TAG_END()),
6);
TEST(error_msg, 0);
TEST_P(mclass, NULL);
TEST(mflags, 0);
TEST(expires, 10000);
TEST(streaming, 1);
TEST_1(proxy != NULL);
TEST_1(proxy_str = url_as_string(t->t_home, proxy->us_url));
TEST_S(proxy_str, "http://127.0.0.1:80");
}
TEST_1(nth_engine_get_stats(NULL, TAG_END()) == -1);
{
msg_t *msg;
http_t *http;
TEST_1(nth_engine_msg_create(NULL, -1) == NULL);
TEST_1(msg = nth_engine_msg_create(t->t_engine, -1));
TEST_1(http = http_object(msg));
TEST(http->http_flags, MSG_FLG_USERMASK);
msg_destroy(msg);
/* Use mflags set by set_params (+ streaming flag) */
TEST_1(msg = nth_engine_msg_create(t->t_engine, 0));
TEST_1(http = http_object(msg));
TEST(http->http_flags, MSG_FLG_STREAMING | t->t_mclass->mc_flags);
msg_destroy(msg);
}
TEST_VOID(nth_engine_destroy(t->t_engine));
t->t_engine = NULL;
END();
}
static int site_check_all(site_t *t,
nth_site_t *server,
nth_request_t *req,
http_t const *http,
char const *path);
static int test_nth_server_api(tester_t *t)
{
char const *v;
site_t s[1];
BEGIN();
memset(s, 0, sizeof s);
v = nth_site_server_version();
TEST_1(v); TEST_1(strlen(v)); TEST_S(v, "nth/" NTH_SERVER_VERSION);
/* Fails because no parent site, no root */
TEST_1(!nth_site_create(NULL, test_site, s,
URL_STRING_MAKE("http://127.0.0.1:8888"),
TAG_END()));
/* Fails because url specifies both host and path */
TEST_1(!nth_site_create(NULL, site_check_all, s,
URL_STRING_MAKE("http://127.0.0.1:8888/foo/"),
NTHTAG_ROOT(t->t_root), TAG_END()));
TEST_VOID(nth_site_destroy(NULL));
TEST_P(nth_site_magic(NULL), NULL);
TEST_VOID(nth_site_bind(NULL, test_site, s));
TEST_1(nth_site_set_params(NULL, TAG_END()) == -1);
TEST_1(nth_site_get_params(NULL, TAG_END()) == -1);
TEST_1(nth_site_get_stats(NULL, TAG_END()) == -1);
TEST(nth_request_status(NULL), 400);
TEST(nth_request_method(NULL), http_method_invalid);
TEST_P(nth_request_message(NULL), NULL);
TEST_1(nth_request_treply(NULL, HTTP_200_OK, TAG_END()) == -1);
TEST_VOID(nth_request_destroy(NULL));
END();
}
static int test_site(site_t *s,
nth_site_t *ns,
nth_request_t *req,
http_t const *http,
char const *path)
{
if (s == NULL || ns == NULL || req == NULL)
return 500;
TEST_1(nth_request_treply(req, s->s_status, s->s_phrase,
TAG_NEXT(s->s_tags)) != -1);
TEST_VOID(nth_request_destroy(req));
return s->s_status;
}
static int site_check_all(site_t *s,
nth_site_t *ns,
nth_request_t *req,
http_t const *http,
char const *path)
{
msg_t *msg;
auth_status_t *as;
TEST_1(s); TEST_1(ns); TEST_1(req); TEST_1(http); TEST_1(path);
if (s == NULL || ns == NULL || req == NULL)
return 500;
TEST(nth_request_status(req), 0);
TEST(nth_request_method(req), http_method_get);
TEST_1(msg = nth_request_message(req));
msg_destroy(msg);
as = nth_request_auth(req);
TEST_1(nth_request_treply(req, s->s_status, s->s_phrase,
TAG_NEXT(s->s_tags)) != -1);
TEST_VOID(nth_request_destroy(req));
return s->s_status;
}
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";
static int init_server(tester_t *t)
{
BEGIN();
site_t *m = t->t_master, *sub2;
auth_mod_t *am;
int temp;
TEST_1(t->t_master = m =
site_create(t, NULL,
su_sprintf(t->t_home, "HTTP://127.0.0.1:%u",
htons(t->t_addr->su_port)),
HTTP_200_OK,
HTTPTAG_CONTENT_TYPE_STR("text/html"),
HTTPTAG_PAYLOAD_STR("<html><body>Hello</body></html>\n"),
TPTAG_CERTIFICATE(t->t_pem),
TAG_END()));
TEST_1(site_create(t, m, "/sub/sub",
HTTP_200_OK,
HTTPTAG_CONTENT_TYPE_STR("text/html"),
HTTPTAG_PAYLOAD_STR
("<html><body>sub/sub</body></html>\n"),
TAG_END()));
TEST_1(site_create(t, m, "/sub/",
HTTP_200_OK,
HTTPTAG_CONTENT_TYPE_STR("text/html"),
HTTPTAG_PAYLOAD_STR("<html><body>sub/</body></html>\n"),
TAG_END()));
TEST_1(site_create(t, m, "/sub/sub/",
HTTP_200_OK,
HTTPTAG_CONTENT_TYPE_STR("text/html"),
HTTPTAG_PAYLOAD_STR
("<html><body>sub/sub/</body></html>\n"),
TAG_END()));
TEST_1(sub2 =
site_create(t, m, "/sub2/",
HTTP_200_OK,
HTTPTAG_CONTENT_TYPE_STR("text/html"),
HTTPTAG_PAYLOAD_STR("<html><body>sub2/</body></html>\n"),
TAG_END()));
TEST_1(site_create(t, sub2, "sub/",
HTTP_200_OK,
HTTPTAG_CONTENT_TYPE_STR("text/html"),
HTTPTAG_PAYLOAD_STR
("<html><body>sub2/sub/</body></html>\n"),
TAG_END()));
#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_SIZE(write(temp, passwd, strlen(passwd)), strlen(passwd));
TEST_1(close(temp) == 0);
am = auth_mod_create(t->t_root,
AUTHTAG_METHOD("Digest"),
AUTHTAG_REALM("auth"),
AUTHTAG_DB(passwd_name),
TAG_END());
TEST_1(am);
TEST_1(site_create(t, m, "auth/",
HTTP_200_OK,
HTTPTAG_CONTENT_TYPE_STR("text/html"),
HTTPTAG_PAYLOAD_STR
("<html><body>auth/</body></html>\n"),
NTHTAG_AUTH_MODULE(am),
TAG_END()));
auth_mod_unref(am);
am = auth_mod_create(t->t_root,
AUTHTAG_METHOD("Delayed+Basic"),
AUTHTAG_REALM("auth2"),
AUTHTAG_DB(passwd_name),
TAG_END());
TEST_1(am);
TEST_1(site_create(t, m, "auth2/",
HTTP_200_OK,
HTTPTAG_CONTENT_TYPE_STR("text/html"),
HTTPTAG_PAYLOAD_STR
("<html><body>auth/</body></html>\n"),
NTHTAG_AUTH_MODULE(am),
TAG_END()));
auth_mod_unref(am);
END();
}
static int send_request(tester_t *t, char const *req, size_t reqlen,
int close_socket,
char reply[], int rlen,
int *return_len)
{
static su_socket_t c = INVALID_SOCKET;
int m, r;
su_wait_t w[1];
BEGIN();
if (c == INVALID_SOCKET) {
c = su_socket(t->t_addr->su_family, SOCK_STREAM, 0); TEST_1(c != SOCK_STREAM);
TEST_1(su_setblocking(c, 1) != -1);
TEST_1(connect(c, &t->t_addr->su_sa, t->t_addrlen) != -1);
while (su_root_step(t->t_root, 1) == 0);
}
if (reqlen == (size_t)-1)
reqlen = strlen(req);
TEST_SIZE(su_send(c, req, reqlen, 0), reqlen);
if (close_socket == 1)
shutdown(c, 1);
TEST(su_wait_create(w, c, SU_WAIT_IN), 0);
while (su_root_step(t->t_root, 1) == 0 || su_wait(w, 1, 0) < 0);
for (r = 0;;) {
TEST_1((m = recv(c, reply, rlen - r - 1, 0)) != -1);
r += m;
if (m == 0 || r == rlen - 1)
break;
}
reply[r] = '\0';
if (close_socket != -1)
su_close(c), c = -1;
*return_len = r;
END();
}
int sspace(char const *buffer)
{
int m = strcspn(buffer, " ");
if (buffer[m])
m += 1 + strcspn(buffer + m + 1, " ");
return m;
}
#define CRLF "\r\n"
static int test_requests(tester_t *t)
{
char buffer[4096 + 1];
int m;
BEGIN();
{
static char const get[] =
"GET / HTTP/1.1" CRLF
"Host: 127.0.0.1" CRLF
"User-Agent: Test-Tool" CRLF
"Connection: close" CRLF
CRLF;
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = sspace(buffer); buffer[m] = '\0';
TEST_S(buffer, "HTTP/1.1 200");
}
{
static char const get[] =
"GET / HTTP/1.1" CRLF
"Host: 127.0.0.1" CRLF
"User-Agent: Test-Tool" CRLF
"Connection: close" CRLF
CRLF;
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = strcspn(buffer, CRLF); buffer[m] = '\0';
TEST_S(buffer, "HTTP/1.1 200 OK");
}
{
static char const request[] =
"GET %s HTTP/1.1" CRLF
"Host: 127.0.0.1" CRLF
"User-Agent: Test-Tool" CRLF
"Connection: close" CRLF
CRLF;
char *get;
get = su_sprintf(NULL, request, "/sub");
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = sspace(buffer); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 301");
m += strcspn(buffer + m, CRLF) + 1;
free(get);
get = su_sprintf(NULL, request, "/sub/");
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = strcspn(buffer, CRLF); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 200 OK");
TEST_1(strstr(buffer + m, "<body>sub/</body>"));
free(get);
get = su_sprintf(NULL, request, "/sub2/");
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = strcspn(buffer, CRLF); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 200 OK");
TEST_1(strstr(buffer + m, "<body>sub2/</body>"));
free(get);
get = su_sprintf(NULL, request, "/sub2/hub");
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = strcspn(buffer, CRLF); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 200 OK");
TEST_1(strstr(buffer + m, "<body>sub2/</body>"));
free(get);
/* Test that absolute path for subdir site is calculated correctly */
get = su_sprintf(NULL, request, "/sub2/sub");
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = sspace(buffer); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 301");
TEST_1(strstr(buffer + m, "/sub2/sub/" CRLF));
free(get);
get = su_sprintf(NULL, request, "/sub2/sub/");
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = strcspn(buffer, CRLF); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 200 OK");
TEST_1(strstr(buffer + m, "<body>sub2/sub/</body>"));
free(get);
get = su_sprintf(NULL, request, "/sub/sub");
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = strcspn(buffer, CRLF); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 200 OK");
TEST_1(strstr(buffer + m, "<body>sub/sub</body>"));
free(get);
get = su_sprintf(NULL, request, "/auth/");
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = sspace(buffer); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 401");
free(get);
get = su_sprintf(NULL, request, "/auth2/");
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = sspace(buffer); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 401");
free(get);
}
{
static char const get[] =
"GET /auth2/ HTTP/1.1" CRLF
"Host: 127.0.0.1" CRLF
"User-Agent: Test-Tool" CRLF
"Connection: close" CRLF
/* alice:secret in base64 */
"Authorization: Basic YWxpY2U6c2VjcmV0" CRLF
CRLF;
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = sspace(buffer); buffer[m++] = '\0';
TEST_S(buffer, "HTTP/1.1 200");
}
{
static char const kuik[] =
"kuik" CRLF CRLF;
TEST(send_request(t, kuik, -1, 0, buffer, sizeof(buffer), &m), 0);
m = sspace(buffer); buffer[m] = '\0';
TEST_S(buffer, "HTTP/1.1 400");
}
{
static char const kuik[] =
"POST / HTTP/1.1" CRLF
"Host: 127.0.0.1" CRLF
"Content-Length: 4294967296" CRLF
CRLF;
TEST(send_request(t, kuik, -1, 1, buffer, sizeof(buffer), &m), 0);
m = sspace(buffer); buffer[m] = '\0';
TEST_S(buffer, "HTTP/1.1 400");
}
{
static char const get[] =
"GET / HTTP/10.10" CRLF
"Host: 127.0.0.1" CRLF
"User-Agent: Test-Tool" CRLF
"Connection: close" CRLF
CRLF;
TEST(send_request(t, get, -1, 0, buffer, sizeof(buffer), &m), 0);
m = sspace(buffer); buffer[m] = '\0';
TEST_S(buffer, "HTTP/1.1 505");
}
{
static char const get[] =
"GET /" CRLF;
TEST(send_request(t, get, -1, 1, buffer, sizeof(buffer) - 1, &m), 0);
buffer[6] = '\0';
TEST_S(buffer, "<html>");
}
if (0)
{
static char const post[] =
"POST /foo HTTP/1.1" CRLF
"Host: 127.0.0.1" CRLF
"User-Agent: Test-Tool" CRLF
"Connection: close" CRLF
"Content-Length: 7" CRLF
"Expect: 100-continue" CRLF
CRLF;
static char const body[] =
"<html/>";
TEST(send_request(t, post, -1, -1, buffer, sizeof(buffer) - 1, &m), 0);
m = sspace(buffer); buffer[m] = '\0';
TEST_S(buffer, "HTTP/1.1 100");
TEST(send_request(t, body, -1, 0, buffer, sizeof(buffer) - 1, &m), 0);
m = sspace(buffer); buffer[m] = '\0';
TEST_S(buffer, "HTTP/1.1 200");
}
END();
}
static int init_engine(tester_t *t)
{
BEGIN();
su_socket_t s;
t->t_engine = nth_engine_create(t->t_root,
NTHTAG_STREAMING(0),
TAG_END());
TEST_1(t->t_engine);
t->t_sink = s = su_socket(AF_INET, SOCK_STREAM, 0); TEST_1(s != -1);
TEST(bind(s, &t->t_sinkaddr->su_sa,
t->t_sinkaddrlen = (sizeof t->t_sinkaddr->su_sin)),
0);
TEST_1(getsockname(s, &t->t_sinkaddr->su_sa, &t->t_sinkaddrlen) != -1);
TEST(listen(t->t_sink, 5), 0);
TEST_1(t->t_sinkuri = (url_string_t *)
su_sprintf(t->t_home, "HTTP://127.0.0.1:%u",
htons(t->t_sinkaddr->su_port)));
END();
}
static int response_to_client(client_t *c,
nth_client_t *hc,
http_t const *http)
{
if (http) {
c->c_status = http->http_status->st_status;
}
else {
c->c_status = nth_client_status(hc);
}
return 0;
}
static int test_client(tester_t *t)
{
BEGIN();
nth_client_t *hc;
char *uri;
client_t client[1];
memset(client, 0, sizeof client);
TEST_1(uri = su_strcat(NULL, t->t_master->s_url->us_str, "/"));
TEST_1(hc = nth_client_tcreate(t->t_engine,
response_to_client, client,
HTTP_METHOD_GET,
URL_STRING_MAKE(uri),
TAG_END()));
while (client->c_status == 0) su_root_step(t->t_root, 1);
TEST(client->c_status, 200);
nth_client_destroy(hc);
su_free(NULL, uri);
memset(client, 0, sizeof client);
TEST_1(hc = nth_client_tcreate(t->t_engine,
response_to_client, client,
HTTP_METHOD_GET,
URL_STRING_MAKE(t->t_sinkuri),
NTHTAG_EXPIRES(1000),
TAG_END()));
while (client->c_status == 0) su_root_step(t->t_root, 1);
TEST(client->c_status, 408);
nth_client_destroy(hc);
END();
}
#if HAVE_ALARM
static RETSIGTYPE sig_alarm(int s)
{
fprintf(stderr, "%s: FAIL! test timeout!\n", name);
exit(1);
}
#endif
void usage(int exitcode)
{
fprintf(stderr, "usage: %s [-v|-q] [-a] [-p proxy-uri]\n", name);
exit(exitcode);
}
int main(int argc, char **argv)
{
int i;
int retval = 0;
int o_alarm = 1;
tester_t t[1] = {{{ SU_HOME_INIT(t) }}};
char const *srcdir = getenv("srcdir");
if (srcdir == NULL)
srcdir = ".";
for (i = 1; argv[i]; i++) {
if (strcmp(argv[i], "-v") == 0)
tstflags |= tst_verbatim;
else if (strcmp(argv[i], "-a") == 0)
tstflags |= tst_abort;
else if (strcmp(argv[i], "-q") == 0)
tstflags &= ~tst_verbatim;
else if (strcmp(argv[i], "-p") == 0 && argv[i + 1])
t->t_proxy = (url_string_t *)argv[++i];
else if (strcmp(argv[i], "-s") == 0 && argv[i + 1])
srcdir = argv[++i];
else if (strcmp(argv[i], "--no-alarm") == 0) {
o_alarm = 0;
}
else if (strcmp(argv[i], "-") == 0) {
i++; break;
}
else if (argv[i][0] != '-') {
break;
}
else
usage(1);
}
t->t_srcdir = srcdir;
#if HAVE_ALARM
if (o_alarm) {
alarm(60);
signal(SIGALRM, sig_alarm);
}
#endif
su_init();
retval |= init_test(t);
retval |= test_nth_client_api(t);
retval |= test_nth_server_api(t);
retval |= init_server(t);
retval |= test_requests(t);
retval |= init_engine(t);
retval |= test_client(t);
retval |= deinit_test(t);
su_deinit();
return retval;
}
Reference in New Issue View Git Blame Copy Permalink