diff options
Diffstat (limited to 'tests')
-rw-r--r-- | tests/test_uri.c | 154 | ||||
-rw-r--r-- | tests/test_websocket_client.c | 165 |
2 files changed, 319 insertions, 0 deletions
diff --git a/tests/test_uri.c b/tests/test_uri.c new file mode 100644 index 000000000..92bbb70b0 --- /dev/null +++ b/tests/test_uri.c @@ -0,0 +1,154 @@ +/* + * Asterisk -- An open source telephony toolkit. + * + * Copyright (C) 2014, Digium, Inc. + * + * Kevin Harwell <kharwell@digium.com> + * + * See http://www.asterisk.org for more information about + * the Asterisk project. Please do not directly contact + * any of the maintainers of this project for assistance; + * the project provides a web site, mailing lists and IRC + * channels for your use. + * + * This program is free software, distributed under the terms of + * the GNU General Public License Version 2. See the LICENSE file + * at the top of the source tree. + */ + +/*! + * \file + * \brief URI Unit Tests + * + * \author Kevin Harwell <kharwell@digium.com> + * + */ + +/*** MODULEINFO + <depend>TEST_FRAMEWORK</depend> + <support_level>core</support_level> + ***/ + +#include "asterisk.h" + +ASTERISK_FILE_VERSION(__FILE__, "") + +#include "asterisk/test.h" +#include "asterisk/module.h" +#include "asterisk/uri.h" + +#define CATEGORY "/main/uri/" + +static const char *scenarios[][7] = { + {"http://name:pass@localhost", "http", "name:pass", "localhost", NULL, NULL, NULL}, + {"http://localhost", "http", NULL, "localhost", NULL, NULL, NULL}, + {"http://localhost:80", "http", NULL, "localhost", "80", NULL, NULL}, + {"http://localhost/path/", "http", NULL, "localhost", NULL, "path/", NULL}, + {"http://localhost/?query", "http", NULL, "localhost", NULL, "", "query"}, + {"http://localhost:80/path", "http", NULL, "localhost", "80", "path", NULL}, + {"http://localhost:80/?query", "http", NULL, "localhost", "80", "", "query"}, + {"http://localhost:80/path?query", "http", NULL, "localhost", "80", "path", "query"}, +}; + +AST_TEST_DEFINE(uri_parse) +{ +#define VALIDATE(value, expected_value) \ + do { ast_test_validate(test, \ + (value == expected_value) || \ + (value && expected_value && \ + !strcmp(value, expected_value))); \ + } while (0) + + int i; + + switch (cmd) { + case TEST_INIT: + info->name = __func__; + info->category = CATEGORY; + info->summary = "Uri parsing scenarios"; + info->description = "For each scenario validate result(s)"; + return AST_TEST_NOT_RUN; + case TEST_EXECUTE: + break; + } + for (i = 0; i < ARRAY_LEN(scenarios); ++i) { + RAII_VAR(struct ast_uri *, uri, NULL, ao2_cleanup); + const char **scenario = scenarios[i]; + + ast_test_validate(test, (uri = ast_uri_parse(scenario[0]))); + VALIDATE(ast_uri_scheme(uri), scenario[1]); + VALIDATE(ast_uri_user_info(uri), scenario[2]); + VALIDATE(ast_uri_host(uri), scenario[3]); + VALIDATE(ast_uri_port(uri), scenario[4]); + VALIDATE(ast_uri_path(uri), scenario[5]); + VALIDATE(ast_uri_query(uri), scenario[6]); + } + + return AST_TEST_PASS; +} + +AST_TEST_DEFINE(uri_default_http) +{ + RAII_VAR(struct ast_uri *, uri, NULL, ao2_cleanup); + + switch (cmd) { + case TEST_INIT: + info->name = __func__; + info->category = CATEGORY; + info->summary = "parse an http uri with host only"; + info->description = info->summary; + return AST_TEST_NOT_RUN; + case TEST_EXECUTE: + break; + } + + ast_test_validate(test, (uri = ast_uri_parse_http("localhost"))); + ast_test_validate(test, !strcmp(ast_uri_scheme(uri), "http")); + ast_test_validate(test, !strcmp(ast_uri_host(uri), "localhost")); + ast_test_validate(test, !strcmp(ast_uri_port(uri), "80")); + ast_test_validate(test, !ast_uri_is_secure(uri)); + + return AST_TEST_PASS; +} + +AST_TEST_DEFINE(uri_default_http_secure) +{ + RAII_VAR(struct ast_uri *, uri, NULL, ao2_cleanup); + + switch (cmd) { + case TEST_INIT: + info->name = __func__; + info->category = CATEGORY; + info->summary = "parse an https uri with host only"; + info->description = info->summary; + return AST_TEST_NOT_RUN; + case TEST_EXECUTE: + break; + } + + ast_test_validate(test, (uri = ast_uri_parse_http("https://localhost"))); + ast_test_validate(test, !strcmp(ast_uri_scheme(uri), "https")); + ast_test_validate(test, !strcmp(ast_uri_host(uri), "localhost")); + ast_test_validate(test, !strcmp(ast_uri_port(uri), "443")); + ast_test_validate(test, ast_uri_is_secure(uri)); + + return AST_TEST_PASS; +} + +static int load_module(void) +{ + AST_TEST_REGISTER(uri_parse); + AST_TEST_REGISTER(uri_default_http); + AST_TEST_REGISTER(uri_default_http_secure); + return AST_MODULE_LOAD_SUCCESS; +} + +static int unload_module(void) +{ + AST_TEST_UNREGISTER(uri_default_http_secure); + AST_TEST_UNREGISTER(uri_default_http); + AST_TEST_UNREGISTER(uri_parse); + return 0; +} + +AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "URI test module"); diff --git a/tests/test_websocket_client.c b/tests/test_websocket_client.c new file mode 100644 index 000000000..e104ed825 --- /dev/null +++ b/tests/test_websocket_client.c @@ -0,0 +1,165 @@ +/* + * Asterisk -- An open source telephony toolkit. + * + * Copyright (C) 2014, Digium, Inc. + * + * Kevin Harwell <kharwell@digium.com> + * + * See http://www.asterisk.org for more information about + * the Asterisk project. Please do not directly contact + * any of the maintainers of this project for assistance; + * the project provides a web site, mailing lists and IRC + * channels for your use. + * + * This program is free software, distributed under the terms of + * the GNU General Public License Version 2. See the LICENSE file + * at the top of the source tree. + */ + +/*! + * \file + * \brief Websocket Client Unit Tests + * + * \author Kevin Harwell <kharwell@digium.com> + * + */ + +/*** MODULEINFO + <depend>TEST_FRAMEWORK</depend> + <depend>res_http_websocket</depend> + <support_level>core</support_level> + ***/ + +#include "asterisk.h" + +ASTERISK_FILE_VERSION(__FILE__, "") + +#include "asterisk/test.h" +#include "asterisk/module.h" +#include "asterisk/astobj2.h" +#include "asterisk/pbx.h" +#include "asterisk/http_websocket.h" + +#define CATEGORY "/res/websocket/" +#define REMOTE_URL "ws://localhost:8088/ws" + +AST_TEST_DEFINE(websocket_client_create_and_connect) +{ + RAII_VAR(struct ast_websocket *, client, NULL, ao2_cleanup); + + enum ast_websocket_result result; + struct ast_str *write_buf; + struct ast_str *read_buf; + + switch (cmd) { + case TEST_INIT: + info->name = __func__; + info->category = CATEGORY; + info->summary = "test creation and connection of a client websocket"; + info->description = "test creation and connection of a client websocket"; + return AST_TEST_NOT_RUN; + case TEST_EXECUTE: + break; + } + + write_buf = ast_str_alloca(20); + read_buf = ast_str_alloca(20); + + ast_test_validate(test, (client = ast_websocket_client_create( + REMOTE_URL, "echo", NULL, &result))); + + ast_str_set(&write_buf, 0, "this is only a test"); + ast_test_validate(test, !ast_websocket_write_string(client, write_buf)); + ast_test_validate(test, ast_websocket_read_string(client, &read_buf) > 0); + ast_test_validate(test, !strcmp(ast_str_buffer(write_buf), ast_str_buffer(read_buf))); + + return AST_TEST_PASS; +} + +AST_TEST_DEFINE(websocket_client_bad_url) +{ + RAII_VAR(struct ast_websocket *, client, NULL, ao2_cleanup); + enum ast_websocket_result result; + + switch (cmd) { + case TEST_INIT: + info->name = __func__; + info->category = CATEGORY; + info->summary = "websocket client - test bad url"; + info->description = "pass a bad url and make sure it fails"; + return AST_TEST_NOT_RUN; + case TEST_EXECUTE: + break; + } + + ast_test_validate(test, !(client = ast_websocket_client_create( + "invalid", NULL, NULL, &result))); + return AST_TEST_PASS; +} + +AST_TEST_DEFINE(websocket_client_unsupported_protocol) +{ + RAII_VAR(struct ast_websocket *, client, NULL, ao2_cleanup); + enum ast_websocket_result result; + + switch (cmd) { + case TEST_INIT: + info->name = __func__; + info->category = CATEGORY; + info->summary = "websocket client - unsupported protocol"; + info->description = "fails on an unsupported protocol"; + return AST_TEST_NOT_RUN; + case TEST_EXECUTE: + break; + } + + ast_test_validate(test, !(client = ast_websocket_client_create( + REMOTE_URL, "unsupported", NULL, &result))); + return AST_TEST_PASS; +} + +AST_TEST_DEFINE(websocket_client_multiple_protocols) +{ + RAII_VAR(struct ast_websocket *, client, NULL, ao2_cleanup); + const char *accept_protocol; + enum ast_websocket_result result; + + switch (cmd) { + case TEST_INIT: + info->name = __func__; + info->category = CATEGORY; + info->summary = "websocket client - test multiple protocols"; + info->description = "test multi-protocol client"; + return AST_TEST_NOT_RUN; + case TEST_EXECUTE: + break; + } + + ast_test_validate(test, (client = ast_websocket_client_create( + REMOTE_URL, "echo,unsupported", NULL, &result))); + + accept_protocol = ast_websocket_client_accept_protocol(client); + ast_test_validate(test, accept_protocol && !strcmp(accept_protocol, "echo")); + + return AST_TEST_PASS; +} + +static int load_module(void) +{ + AST_TEST_REGISTER(websocket_client_create_and_connect); + AST_TEST_REGISTER(websocket_client_bad_url); + AST_TEST_REGISTER(websocket_client_unsupported_protocol); + AST_TEST_REGISTER(websocket_client_multiple_protocols); + return AST_MODULE_LOAD_SUCCESS; +} + +static int unload_module(void) +{ + AST_TEST_UNREGISTER(websocket_client_multiple_protocols); + AST_TEST_UNREGISTER(websocket_client_unsupported_protocol); + AST_TEST_UNREGISTER(websocket_client_bad_url); + AST_TEST_UNREGISTER(websocket_client_create_and_connect); + return 0; +} + +AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Websocket client test module"); |