diff options
Diffstat (limited to 'tests/unit/plugins/relay/api')
| -rw-r--r-- | tests/unit/plugins/relay/api/test-relay-api-msg.cpp | 20 | ||||
| -rw-r--r-- | tests/unit/plugins/relay/api/test-relay-api-protocol.cpp | 627 |
2 files changed, 620 insertions, 27 deletions
diff --git a/tests/unit/plugins/relay/api/test-relay-api-msg.cpp b/tests/unit/plugins/relay/api/test-relay-api-msg.cpp index 546713ac1..2fee7d763 100644 --- a/tests/unit/plugins/relay/api/test-relay-api-msg.cpp +++ b/tests/unit/plugins/relay/api/test-relay-api-msg.cpp @@ -51,11 +51,11 @@ extern "C" STRNCMP_EQUAL(__expected, cJSON_GetStringValue (json_obj), \ __length); -#define WEE_CHECK_OBJ_INT(__expected, __json, __name) \ +#define WEE_CHECK_OBJ_NUM(__expected, __json, __name) \ json_obj = cJSON_GetObjectItem (__json, __name); \ CHECK(json_obj); \ CHECK(cJSON_IsNumber (json_obj)); \ - LONGS_EQUAL(__expected, cJSON_GetNumberValue (json_obj)); + CHECK(__expected == cJSON_GetNumberValue (json_obj)); #define WEE_CHECK_OBJ_BOOL(__expected, __json, __name) \ json_obj = cJSON_GetObjectItem (__json, __name); \ @@ -134,7 +134,7 @@ TEST(RelayApiMsg, BufferToJson) CHECK(cJSON_IsObject (json)); WEE_CHECK_OBJ_STR("core.weechat", json, "name"); WEE_CHECK_OBJ_STR("weechat", json, "short_name"); - WEE_CHECK_OBJ_INT(1, json, "number"); + WEE_CHECK_OBJ_NUM(1, json, "number"); WEE_CHECK_OBJ_STR("formatted", json, "type"); WEE_CHECK_OBJ_STRN("WeeChat", 7, json, "title"); json_local_vars = cJSON_GetObjectItem (json, "local_variables"); @@ -264,9 +264,9 @@ TEST(RelayApiMsg, LinesToJson) json_line = cJSON_GetArrayItem (json, 0); CHECK(json_line); CHECK(cJSON_IsObject (json_line)); - WEE_CHECK_OBJ_INT(gui_buffers->own_lines->last_line->prev_line->data->id, + WEE_CHECK_OBJ_NUM(gui_buffers->own_lines->last_line->prev_line->data->id, json_line, "id"); - WEE_CHECK_OBJ_INT(-1, json_line, "y"); + WEE_CHECK_OBJ_NUM(-1, json_line, "y"); gmtime_r (&(gui_buffers->own_lines->last_line->prev_line->data->date), &gm_time); tv.tv_sec = mktime (&gm_time); tv.tv_usec = gui_buffers->own_lines->last_line->prev_line->data->date_usec; @@ -300,9 +300,9 @@ TEST(RelayApiMsg, LinesToJson) json_line = cJSON_GetArrayItem (json, 1); CHECK(json_line); CHECK(cJSON_IsObject (json_line)); - WEE_CHECK_OBJ_INT(gui_buffers->own_lines->last_line->data->id, + WEE_CHECK_OBJ_NUM(gui_buffers->own_lines->last_line->data->id, json_line, "id"); - WEE_CHECK_OBJ_INT(-1, json_line, "y"); + WEE_CHECK_OBJ_NUM(-1, json_line, "y"); gmtime_r (&(gui_buffers->own_lines->last_line->data->date), &gm_time); tv.tv_sec = mktime (&gm_time); tv.tv_usec = gui_buffers->own_lines->last_line->data->date_usec; @@ -333,7 +333,7 @@ TEST(RelayApiMsg, LinesToJson) json_line = cJSON_GetArrayItem (json, 0); CHECK(json_line); CHECK(cJSON_IsObject (json_line)); - WEE_CHECK_OBJ_INT(gui_buffers->own_lines->last_line->data->id, + WEE_CHECK_OBJ_NUM(gui_buffers->own_lines->last_line->data->id, json_line, "id"); str_msg_ansi = gui_color_encode_ansi (str_msg2); CHECK(str_msg_ansi); @@ -349,7 +349,7 @@ TEST(RelayApiMsg, LinesToJson) json_line = cJSON_GetArrayItem (json, 0); CHECK(json_line); CHECK(cJSON_IsObject (json_line)); - WEE_CHECK_OBJ_INT(gui_buffers->own_lines->last_line->data->id, + WEE_CHECK_OBJ_NUM(gui_buffers->own_lines->last_line->data->id, json_line, "id"); WEE_CHECK_OBJ_STR(str_msg2, json_line, "message"); cJSON_Delete (json); @@ -362,7 +362,7 @@ TEST(RelayApiMsg, LinesToJson) json_line = cJSON_GetArrayItem (json, 0); CHECK(json_line); CHECK(cJSON_IsObject (json_line)); - WEE_CHECK_OBJ_INT(gui_buffers->own_lines->last_line->data->id, + WEE_CHECK_OBJ_NUM(gui_buffers->own_lines->last_line->data->id, json_line, "id"); WEE_CHECK_OBJ_STR("this is the second line with green", json_line, "message"); cJSON_Delete (json); diff --git a/tests/unit/plugins/relay/api/test-relay-api-protocol.cpp b/tests/unit/plugins/relay/api/test-relay-api-protocol.cpp index 9cd826713..fb2cb823f 100644 --- a/tests/unit/plugins/relay/api/test-relay-api-protocol.cpp +++ b/tests/unit/plugins/relay/api/test-relay-api-protocol.cpp @@ -21,16 +21,210 @@ #include "CppUTest/TestHarness.h" +#include "tests/tests-record.h" + extern "C" { +#include <unistd.h> +#include <cjson/cJSON.h> +#include "src/core/wee-config-file.h" +#include "src/core/wee-string.h" +#include "src/core/wee-util.h" +#include "src/core/wee-version.h" +#include "src/gui/gui-buffer.h" +#include "src/gui/gui-chat.h" +#include "src/gui/gui-line.h" +#include "src/plugins/weechat-plugin.h" #include "src/plugins/relay/relay.h" +#include "src/plugins/relay/relay-client.h" +#include "src/plugins/relay/relay-config.h" +#include "src/plugins/relay/relay-server.h" +#include "src/plugins/relay/api/relay-api.h" #include "src/plugins/relay/api/relay-api-protocol.h" + +extern void relay_client_recv_text (struct t_relay_client *client, + const char *data); +extern int relay_api_protocol_command_delay; } +#define WEE_CHECK_HTTP_CODE(__code, __message) \ + STRNCMP_EQUAL("HTTP/1.1 " #__code " " __message "\r\n", \ + data_sent, \ + strlen ("HTTP/1.1 " #__code " " __message "\r\n")); + +#define WEE_CHECK_TEXT(__code, __message) \ + STRCMP_EQUAL("{\"code\":" #__code "," \ + "\"message\":\"" __message "\"}", \ + data_sent); + +#define WEE_CHECK_OBJ_STR(__expected, __json, __name) \ + json_obj = cJSON_GetObjectItem (__json, __name); \ + CHECK(json_obj); \ + CHECK(cJSON_IsString (json_obj)); \ + STRCMP_EQUAL(__expected, cJSON_GetStringValue (json_obj)); + +#define WEE_CHECK_OBJ_STRN(__expected, __length, __json, __name) \ + json_obj = cJSON_GetObjectItem (__json, __name); \ + CHECK(json_obj); \ + CHECK(cJSON_IsString (json_obj)); \ + STRNCMP_EQUAL(__expected, cJSON_GetStringValue (json_obj), \ + __length); + +#define WEE_CHECK_OBJ_NUM(__expected, __json, __name) \ + json_obj = cJSON_GetObjectItem (__json, __name); \ + CHECK(json_obj); \ + CHECK(cJSON_IsNumber (json_obj)); \ + CHECK(__expected == cJSON_GetNumberValue (json_obj)); + +#define WEE_CHECK_OBJ_BOOL(__expected, __json, __name) \ + json_obj = cJSON_GetObjectItem (__json, __name); \ + CHECK(json_obj); \ + CHECK(cJSON_IsBool (json_obj)); \ + LONGS_EQUAL(__expected, cJSON_IsTrue (json_obj) ? 1 : 0); + +struct t_relay_server *ptr_relay_server = NULL; +struct t_relay_client *ptr_relay_client = NULL; +char *data_sent = NULL; +int data_sent_size = 0; +cJSON *json_body_sent = NULL; + TEST_GROUP(RelayApiProtocol) { }; +TEST_GROUP(RelayApiProtocolWithClient) +{ + void free_data_sent () + { + if (data_sent) + { + free (data_sent); + data_sent = NULL; + } + data_sent_size = 0; + if (json_body_sent) + { + cJSON_Delete (json_body_sent); + json_body_sent = NULL; + } + } + + void test_client_recv_http_raw (const char *http_request) + { + free_data_sent (); + relay_client_recv_buffer (ptr_relay_client, + http_request, strlen (http_request)); + } + + void test_client_recv_http (const char *method_path, const char *body) + { + char http_request[4096]; + + if (body) + { + snprintf (http_request, sizeof (http_request), + "%s HTTP/1.1\r\n" + "Authorization: Basic cGxhaW46c2VjcmV0\r\n" + "Content-Length: %d\r\n" + "Content-Type: application/x-www-form-urlencoded\r\n" + "\r\n" + "%s", + method_path, + (int)strlen (body), + body); + } + else + { + snprintf (http_request, sizeof (http_request), + "%s HTTP/1.1\r\n" + "Authorization: Basic cGxhaW46c2VjcmV0\r\n" + "\r\n", + method_path); + } + test_client_recv_http_raw (http_request); + } + + void test_client_recv_text (const char *data) + { + free_data_sent (); + relay_client_recv_text (ptr_relay_client, data); + } + + static void fake_send_func (void *client, const char *data, int data_size) + { + char *pos_body; + + (void) client; + + if (data_sent) + { + free (data_sent); + data_sent = NULL; + } + data_sent_size = 0; + if (json_body_sent) + { + cJSON_Delete (json_body_sent); + json_body_sent = NULL; + } + + data_sent = (char *)malloc (data_size + 1); + memcpy (data_sent, data, data_size); + data_sent[data_size] = '\0'; + data_sent_size = data_size; + + pos_body = strstr (data_sent, "\r\n\r\n"); + if (pos_body) + json_body_sent = cJSON_Parse(pos_body + 4); + } + + void setup () + { + /* disable auto-open of relay buffer */ + config_file_option_set (relay_config_look_auto_open_buffer, "off", 1); + + /* set relay password */ + config_file_option_set (relay_config_network_password, "secret", 1); + + /* create a relay server */ + ptr_relay_server = relay_server_new ( + "api", + RELAY_PROTOCOL_API, + "test", + 9000, + NULL, /* path */ + 1, /* ipv4 */ + 0, /* ipv6 */ + 0, /* tls */ + 0); /* unix_socket */ + + /* create a relay client */ + ptr_relay_client = relay_client_new (-1, "test", ptr_relay_server); + ptr_relay_client->fake_send_func = &fake_send_func; + + data_sent = NULL; + data_sent_size = 0; + json_body_sent = NULL; + } + + void teardown () + { + relay_client_free (ptr_relay_client); + ptr_relay_client = NULL; + + relay_server_free (ptr_relay_server); + ptr_relay_server = NULL; + + free_data_sent (); + + /* restore auto-open of relay buffer */ + config_file_option_reset (relay_config_look_auto_open_buffer, 1); + + /* restore relay password */ + config_file_option_reset (relay_config_network_password, 1); + } +}; + /* * Tests functions: * relay_api_protocol_signal_buffer_cb @@ -66,9 +260,54 @@ TEST(RelayApiProtocol, SignalUpgradeCb) * relay_api_protocol_cb_handshake */ -TEST(RelayApiProtocol, CbHandshake) +TEST(RelayApiProtocolWithClient, CbHandshake) { - /* TODO: write tests */ + /* no body */ + test_client_recv_http ("POST /api/handshake", NULL); + STRCMP_EQUAL("HTTP/1.1 200 OK\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 74\r\n" + "\r\n" + "{\"password_hash_algo\":null," + "\"password_hash_iterations\":100000," + "\"totp\":false}", + data_sent); + + /* empty body */ + test_client_recv_http ("POST /api/handshake", "{}"); + STRCMP_EQUAL("HTTP/1.1 200 OK\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 74\r\n" + "\r\n" + "{\"password_hash_algo\":null," + "\"password_hash_iterations\":100000," + "\"totp\":false}", + data_sent); + + /* unknown password hash algorithm */ + test_client_recv_http ("POST /api/handshake", + "{\"password_hash_algo\": [\"invalid\"]}"); + STRCMP_EQUAL("HTTP/1.1 200 OK\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 74\r\n" + "\r\n" + "{\"password_hash_algo\":null," + "\"password_hash_iterations\":100000," + "\"totp\":false}", + data_sent); + + /* two supported hash algorithms */ + test_client_recv_http ( + "POST /api/handshake", + "{\"password_hash_algo\": [\"sha256\", \"pbkdf2+sha512\"]}"); + STRCMP_EQUAL("HTTP/1.1 200 OK\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 85\r\n" + "\r\n" + "{\"password_hash_algo\":\"pbkdf2+sha512\"," + "\"password_hash_iterations\":100000," + "\"totp\":false}", + data_sent); } /* @@ -76,9 +315,19 @@ TEST(RelayApiProtocol, CbHandshake) * relay_api_protocol_cb_version */ -TEST(RelayApiProtocol, CbVersion) +TEST(RelayApiProtocolWithClient, CbVersion) { - /* TODO: write tests */ + cJSON *json, *json_obj; + + test_client_recv_http ("GET /api/version", NULL); + WEE_CHECK_HTTP_CODE(200, "OK"); + json = json_body_sent; + WEE_CHECK_OBJ_STR(version_get_version (), json, "weechat_version"); + WEE_CHECK_OBJ_STR(version_get_git (), json, "weechat_version_git"); + WEE_CHECK_OBJ_NUM(util_version_number (version_get_version ()), + json, "weechat_version_number"); + WEE_CHECK_OBJ_STR(RELAY_API_VERSION_STR, json, "relay_api_version"); + WEE_CHECK_OBJ_NUM(RELAY_API_VERSION_NUMBER, json, "relay_api_version_number"); } /* @@ -86,9 +335,114 @@ TEST(RelayApiProtocol, CbVersion) * relay_api_protocol_cb_buffers */ -TEST(RelayApiProtocol, CbBuffers) +TEST(RelayApiProtocolWithClient, CbBuffers) { - /* TODO: write tests */ + cJSON *json, *json_obj, *json_var, *json_groups; + + /* error: invalid buffer name */ + test_client_recv_http ("GET /api/buffers/invalid", NULL); + STRCMP_EQUAL("HTTP/1.1 404 Not Found\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 41\r\n" + "\r\n" + "{\"error\": \"Buffer \\\"invalid\\\" not found\"}", + data_sent); + + /* error: invalid sub-resource */ + test_client_recv_http ("GET /api/buffers/core.weechat/invalid", NULL); + STRCMP_EQUAL("HTTP/1.1 404 Not Found\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 59\r\n" + "\r\n" + "{\"error\": \"Sub-resource of buffers not found: \\\"invalid\\\"\"}", + data_sent); + + /* error: too many parameters in path */ + test_client_recv_http ("GET /api/buffers/core.weechat/too/many/parameters", NULL); + STRCMP_EQUAL("HTTP/1.1 404 Not Found\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 0\r\n" + "\r\n", + data_sent); + + /* get all buffers */ + test_client_recv_http ("GET /api/buffers", NULL); + WEE_CHECK_HTTP_CODE(200, "OK"); + CHECK(json_body_sent); + CHECK(cJSON_IsArray (json_body_sent)); + json = cJSON_GetArrayItem (json_body_sent, 0); + CHECK(json); + CHECK(cJSON_IsObject (json)); + WEE_CHECK_OBJ_NUM(gui_buffers->id, json, "id"); + WEE_CHECK_OBJ_STR("core.weechat", json, "name"); + WEE_CHECK_OBJ_STR("weechat", json, "short_name"); + WEE_CHECK_OBJ_NUM(1, json, "number"); + WEE_CHECK_OBJ_STR("formatted", json, "type"); + WEE_CHECK_OBJ_STRN("WeeChat", 7, json, "title"); + json_var = cJSON_GetObjectItem (json, "local_variables"); + CHECK(json_var); + CHECK(cJSON_IsObject (json_var)); + WEE_CHECK_OBJ_STR("core", json_var, "plugin"); + WEE_CHECK_OBJ_STR("weechat", json_var, "name"); + + /* get one buffer */ + test_client_recv_http ("GET /api/buffers/core.weechat", NULL); + WEE_CHECK_HTTP_CODE(200, "OK"); + CHECK(json_body_sent); + CHECK(cJSON_IsObject (json_body_sent)); + json = json_body_sent; + WEE_CHECK_OBJ_NUM(gui_buffers->id, json, "id"); + WEE_CHECK_OBJ_STR("core.weechat", json, "name"); + WEE_CHECK_OBJ_STR("weechat", json, "short_name"); + WEE_CHECK_OBJ_NUM(1, json, "number"); + WEE_CHECK_OBJ_STR("formatted", json, "type"); + WEE_CHECK_OBJ_STRN("WeeChat", 7, json, "title"); + json_var = cJSON_GetObjectItem (json, "local_variables"); + CHECK(json_var); + CHECK(cJSON_IsObject (json_var)); + WEE_CHECK_OBJ_STR("core", json_var, "plugin"); + WEE_CHECK_OBJ_STR("weechat", json_var, "name"); + + /* get the 2 last lines of core buffer */ + gui_chat_printf (NULL, "test line 1"); + gui_chat_printf (NULL, "test line 2"); + test_client_recv_http ("GET /api/buffers/core.weechat/lines?lines=-2", NULL); + WEE_CHECK_HTTP_CODE(200, "OK"); + CHECK(json_body_sent); + CHECK(cJSON_IsArray (json_body_sent)); + json = cJSON_GetArrayItem (json_body_sent, 0); + CHECK(json); + CHECK(cJSON_IsObject (json)); + WEE_CHECK_OBJ_NUM(gui_buffers->own_lines->last_line->prev_line->data->id, json, "id"); + WEE_CHECK_OBJ_NUM(-1, json, "y"); + CHECK(cJSON_IsString (cJSON_GetObjectItem (json, "date"))); + CHECK(cJSON_IsString (cJSON_GetObjectItem (json, "date_printed"))); + WEE_CHECK_OBJ_BOOL(0, json, "highlight"); + WEE_CHECK_OBJ_STR("", json, "prefix"); + WEE_CHECK_OBJ_STR("test line 1", json, "message"); + json = cJSON_GetArrayItem (json_body_sent, 1); + CHECK(json); + CHECK(cJSON_IsObject (json)); + WEE_CHECK_OBJ_NUM(gui_buffers->own_lines->last_line->data->id, json, "id"); + WEE_CHECK_OBJ_NUM(-1, json, "y"); + CHECK(cJSON_IsString (cJSON_GetObjectItem (json, "date"))); + CHECK(cJSON_IsString (cJSON_GetObjectItem (json, "date_printed"))); + WEE_CHECK_OBJ_BOOL(0, json, "highlight"); + WEE_CHECK_OBJ_STR("", json, "prefix"); + WEE_CHECK_OBJ_STR("test line 2", json, "message"); + + /* get nicks */ + test_client_recv_http ("GET /api/buffers/core.weechat/nicks", NULL); + WEE_CHECK_HTTP_CODE(200, "OK"); + CHECK(json_body_sent); + CHECK(cJSON_IsObject (json_body_sent)); + json = json_body_sent; + WEE_CHECK_OBJ_STR("root", json, "name"); + WEE_CHECK_OBJ_STR("", json, "color"); + json_groups = cJSON_GetObjectItem (json, "groups"); + CHECK(json_groups); + CHECK(cJSON_IsArray (json_groups)); + LONGS_EQUAL(0, cJSON_GetArraySize (json_groups)); } /* @@ -96,9 +450,51 @@ TEST(RelayApiProtocol, CbBuffers) * relay_api_protocol_cb_input */ -TEST(RelayApiProtocol, CbInput) +TEST(RelayApiProtocolWithClient, CbInput) { - /* TODO: write tests */ + int old_delay; + + /* error: no body */ + test_client_recv_http ("POST /api/input", NULL); + STRCMP_EQUAL("HTTP/1.1 400 Bad Request\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 0\r\n" + "\r\n", + data_sent); + + /* error: invalid buffer name */ + test_client_recv_http ("POST /api/input", + "{\"buffer\": \"invalid\", " + "\"command\": \"/print test\"}"); + STRCMP_EQUAL("HTTP/1.1 404 Not Found\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 41\r\n" + "\r\n" + "{\"error\": \"Buffer \\\"invalid\\\" not found\"}", + data_sent); + + /* on core buffer, without buffer name */ + record_start (); + old_delay = relay_api_protocol_command_delay; + relay_api_protocol_command_delay = 0; + test_client_recv_http ("POST /api/input", + "{\"command\": \"/print test from relay 1\"}"); + relay_api_protocol_command_delay = old_delay; + record_stop (); + WEE_CHECK_HTTP_CODE(204, "No Content"); + CHECK(record_search ("core.weechat", "", "test from relay 1", NULL)); + + /* on core buffer, with buffer name */ + record_start (); + old_delay = relay_api_protocol_command_delay; + relay_api_protocol_command_delay = 0; + test_client_recv_http ("POST /api/input", + "{\"buffer\": \"core.weechat\", " + "\"command\": \"/print test from relay 2\"}"); + relay_api_protocol_command_delay = old_delay; + record_stop (); + WEE_CHECK_HTTP_CODE(204, "No Content"); + CHECK(record_search ("core.weechat", "", "test from relay 2", NULL)); } /* @@ -106,9 +502,23 @@ TEST(RelayApiProtocol, CbInput) * relay_api_protocol_cb_ping */ -TEST(RelayApiProtocol, CbPing) +TEST(RelayApiProtocolWithClient, CbPing) { - /* TODO: write tests */ + cJSON *json, *json_obj; + + /* ping without body */ + test_client_recv_http ("POST /api/ping", NULL); + STRCMP_EQUAL("HTTP/1.1 204 No Content\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 0\r\n" + "\r\n", + data_sent); + + /* ping with a body */ + test_client_recv_http ("POST /api/ping", "{\"data\": \"abcdef\"}"); + WEE_CHECK_HTTP_CODE(200, "OK"); + json = json_body_sent; + WEE_CHECK_OBJ_STR("abcdef", json, "data"); } /* @@ -116,9 +526,79 @@ TEST(RelayApiProtocol, CbPing) * relay_api_protocol_cb_sync */ -TEST(RelayApiProtocol, CbSync) +TEST(RelayApiProtocolWithClient, CbSync) { - /* TODO: write tests */ + test_client_recv_http ("POST /api/sync", NULL); + STRCMP_EQUAL("HTTP/1.1 403 Forbidden\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 72\r\n" + "\r\n" + "{\"error\": \"Sync resource is available only with " + "a websocket connection\"}", + data_sent); +} + +/* + * Tests functions: + * relay_api_protocol_cb_sync (websocket) + */ + +TEST(RelayApiProtocolWithClient, CbSyncWebsocket) +{ + test_client_recv_http_raw ( + "GET /api HTTP/1.1\r\n" + "Authorization: Basic cGxhaW46c2VjcmV0\r\n" + "Sec-WebSocket-Version: 13\r\n" + "Sec-WebSocket-Key: dbKbsCX3CxFBmQo09ah1OQ==\r\n" + "Connection: Upgrade\r\n" + "Upgrade: websocket\r\n" + "Host: 127.0.0.1:9000\r\n" + "\r\n"); + STRCMP_EQUAL("HTTP/1.1 101 Switching Protocols\r\n" + "Upgrade: websocket\r\n" + "Connection: Upgrade\r\n" + "Sec-WebSocket-Accept: Z5uTZwvwYNDm9w4HFGk26ijp/p0=\r\n" + "\r\n", + data_sent); + + test_client_recv_text ("{\"request\": \"POST /api/sync\"}"); + WEE_CHECK_TEXT(204, "No Content"); + + LONGS_EQUAL(1, RELAY_API_DATA(ptr_relay_client, sync_enabled)); + LONGS_EQUAL(1, RELAY_API_DATA(ptr_relay_client, sync_nicks)); + LONGS_EQUAL(RELAY_API_COLORS_ANSI, RELAY_API_DATA(ptr_relay_client, sync_colors)); + + test_client_recv_text ("{\"request\": \"POST /api/sync\", " + "\"body\": {\"sync\": false}}"); + WEE_CHECK_TEXT(204, "No Content"); + + LONGS_EQUAL(0, RELAY_API_DATA(ptr_relay_client, sync_enabled)); + LONGS_EQUAL(1, RELAY_API_DATA(ptr_relay_client, sync_nicks)); + LONGS_EQUAL(RELAY_API_COLORS_ANSI, RELAY_API_DATA(ptr_relay_client, sync_colors)); + + test_client_recv_text ("{\"request\": \"POST /api/sync\", " + "\"body\": {\"sync\": true, \"nicks\": false}}"); + WEE_CHECK_TEXT(204, "No Content"); + + LONGS_EQUAL(1, RELAY_API_DATA(ptr_relay_client, sync_enabled)); + LONGS_EQUAL(0, RELAY_API_DATA(ptr_relay_client, sync_nicks)); + LONGS_EQUAL(RELAY_API_COLORS_ANSI, RELAY_API_DATA(ptr_relay_client, sync_colors)); + + test_client_recv_text ("{\"request\": \"POST /api/sync\", " + "\"body\": {\"sync\": true, \"nicks\": true, \"colors\": \"weechat\"}}"); + WEE_CHECK_TEXT(204, "No Content"); + + LONGS_EQUAL(1, RELAY_API_DATA(ptr_relay_client, sync_enabled)); + LONGS_EQUAL(1, RELAY_API_DATA(ptr_relay_client, sync_nicks)); + LONGS_EQUAL(RELAY_API_COLORS_WEECHAT, RELAY_API_DATA(ptr_relay_client, sync_colors)); + + test_client_recv_text ("{\"request\": \"POST /api/sync\", " + "\"body\": {\"sync\": true, \"nicks\": true, \"colors\": \"strip\"}}"); + WEE_CHECK_TEXT(204, "No Content"); + + LONGS_EQUAL(1, RELAY_API_DATA(ptr_relay_client, sync_enabled)); + LONGS_EQUAL(1, RELAY_API_DATA(ptr_relay_client, sync_nicks)); + LONGS_EQUAL(RELAY_API_COLORS_STRIP, RELAY_API_DATA(ptr_relay_client, sync_colors)); } /* @@ -126,17 +606,130 @@ TEST(RelayApiProtocol, CbSync) * relay_api_protocol_recv_json */ -TEST(RelayApiProtocol, RecvJson) +TEST(RelayApiProtocolWithClient, RecvJson) { - /* TODO: write tests */ + test_client_recv_http_raw ( + "GET /api HTTP/1.1\r\n" + "Authorization: Basic cGxhaW46c2VjcmV0\r\n" + "Sec-WebSocket-Version: 13\r\n" + "Sec-WebSocket-Key: dbKbsCX3CxFBmQo09ah1OQ==\r\n" + "Connection: Upgrade\r\n" + "Upgrade: websocket\r\n" + "Host: 127.0.0.1:9000\r\n" + "\r\n"); + STRCMP_EQUAL("HTTP/1.1 101 Switching Protocols\r\n" + "Upgrade: websocket\r\n" + "Connection: Upgrade\r\n" + "Sec-WebSocket-Accept: Z5uTZwvwYNDm9w4HFGk26ijp/p0=\r\n" + "\r\n", + data_sent); + + /* error: empty string */ + test_client_recv_text (""); + WEE_CHECK_TEXT(400, "Bad Request"); + + /* error: empty body */ + test_client_recv_text ("{}"); + WEE_CHECK_TEXT(400, "Bad Request"); + + /* error: empty request */ + test_client_recv_text ("{\"request\": \"\"}"); + WEE_CHECK_TEXT(400, "Bad Request"); + + /* error: invalid request (number) */ + test_client_recv_text ("{\"request\": 123}"); + WEE_CHECK_TEXT(400, "Bad Request"); + + /* error: invalid request (string, not a valid request) */ + test_client_recv_text ("{\"request\": \"abc\"}"); + WEE_CHECK_TEXT(400, "Bad Request"); + + /* error: invalid request (string, resource not found) */ + test_client_recv_text ("{\"request\": \"GET /api/unknown\"}"); + WEE_CHECK_TEXT(404, "Not Found"); } /* * Tests functions: - * relay_api_protocol_recv_http + * relay_api_protocol_recv_http (error 404) */ -TEST(RelayApiProtocol, RecvHttp) +TEST(RelayApiProtocolWithClient, RecvHttp404) { - /* TODO: write tests */ + /* resource not found: error 404 */ + test_client_recv_http ("GET / HTTP/1.1", NULL); + STRCMP_EQUAL("HTTP/1.1 404 Not Found\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 0\r\n" + "\r\n", + data_sent); + + /* resource not found: error 404 */ + test_client_recv_http ("GET /unknown HTTP/1.1", NULL); + STRCMP_EQUAL("HTTP/1.1 404 Not Found\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 0\r\n" + "\r\n", + data_sent); + + /* resource not found: error 404 */ + test_client_recv_http ("GET /unknown/abc HTTP/1.1", NULL); + STRCMP_EQUAL("HTTP/1.1 404 Not Found\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 0\r\n" + "\r\n", + data_sent); + + /* resource not found: error 404 */ + test_client_recv_http ("GET /api HTTP/1.1", NULL); + STRCMP_EQUAL("HTTP/1.1 404 Not Found\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 0\r\n" + "\r\n", + data_sent); + + /* resource not found: error 404 */ + test_client_recv_http ("GET /api/unknown HTTP/1.1", NULL); + STRCMP_EQUAL("HTTP/1.1 404 Not Found\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 0\r\n" + "\r\n", + data_sent); +} + +/* + * Tests functions: + * relay_api_protocol_recv_http (missing password) + */ + +TEST(RelayApiProtocolWithClient, RecvHttpMissingPassword) +{ + /* unauthorized: missing password */ + test_client_recv_http_raw ("GET /api/version HTTP/1.1\r\n" + "\r\n"); + STRCMP_EQUAL("HTTP/1.1 401 Unauthorized\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 29\r\n" + "\r\n" + "{\"error\": \"Missing password\"}", + data_sent); +} + +/* + * Tests functions: + * relay_api_protocol_recv_http (invalid password) + */ + +TEST(RelayApiProtocolWithClient, RecvHttpInvalidPassword) +{ + /* unauthorized: invalid password: "plain:invalid" */ + test_client_recv_http_raw ("GET /api/version HTTP/1.1\r\n" + "Authorization: Basic cGxhaW46aW52YWxpZA==\r\n" + "\r\n"); + STRCMP_EQUAL("HTTP/1.1 401 Unauthorized\r\n" + "Content-Type: application/json; charset=utf-8\r\n" + "Content-Length: 29\r\n" + "\r\n" + "{\"error\": \"Invalid password\"}", + data_sent); } |