#define CHECK_CORE(__prefix, __message) \
if (record_search ("core.weechat", __prefix, __message, NULL) < 0) \
{ \
- char **msg = server_build_error ( \
+ char **msg = build_error ( \
"Core message not displayed", \
__prefix, \
__message, \
if (record_search ("irc.server." IRC_FAKE_SERVER, __prefix, \
__message, __tags) < 0) \
{ \
- char **msg = server_build_error ( \
+ char **msg = build_error ( \
"Server message not displayed", \
__prefix, \
__message, \
if (record_search ("irc." IRC_FAKE_SERVER ".#test", __prefix, \
__message, __tags) < 0) \
{ \
- char **msg = server_build_error ( \
+ char **msg = build_error ( \
"Channel message not displayed", \
__prefix, \
__message, \
if (record_search ("irc." IRC_FAKE_SERVER "." __nick, \
__prefix, __message, __tags) < 0) \
{ \
- char **msg = server_build_error ( \
+ char **msg = build_error ( \
"Private message not displayed", \
__prefix, \
__message, \
#define CHECK_NO_MSG \
if (arraylist_size (recorded_messages) > 0) \
{ \
- char **msg = server_build_error ( \
+ char **msg = build_error ( \
"Unexpected message(s) displayed", \
NULL, \
NULL, \
&& !arraylist_search (sent_messages, (void *)__message, \
NULL, NULL)) \
{ \
- char **msg = server_build_error ( \
- "Message not sent to server", \
+ char **msg = build_error ( \
+ "Message not sent to the IRC server", \
NULL, \
__message, \
NULL, \
else if ((__message == NULL) \
&& (arraylist_size (sent_messages) > 0)) \
{ \
- char **msg = server_build_error ( \
+ char **msg = build_error ( \
"Unexpected response(s) sent to the IRC server", \
NULL, \
NULL, \
{
};
+TEST_GROUP(IrcProtocolWithServer)
+{
+ void server_recv (const char *command)
+ {
+ char str_command[4096];
+
+ record_start ();
+ arraylist_clear (sent_messages);
+
+ snprintf (str_command, sizeof (str_command),
+ "/command -buffer irc.server." IRC_FAKE_SERVER " irc "
+ "/server fakerecv \"%s\"",
+ command);
+ run_cmd_quiet (str_command);
+
+ record_stop ();
+ }
+
+ void server_input_data (const char *buffer, const char *data)
+ {
+ struct t_gui_buffer *ptr_buffer;
+
+ record_start ();
+ arraylist_clear (sent_messages);
+
+ ptr_buffer = gui_buffer_search_by_full_name (buffer);
+ if (ptr_buffer)
+ input_data (ptr_buffer, data, NULL, 0);
+
+ record_stop ();
+ }
+
+ char **build_error (const char *msg1,
+ const char *prefix,
+ const char *message,
+ const char *tags,
+ const char *msg2)
+ {
+ char **msg;
+
+ msg = string_dyn_alloc (1024);
+ string_dyn_concat (msg, msg1, -1);
+ if (message)
+ {
+ string_dyn_concat (msg, ": prefix=\"", -1);
+ string_dyn_concat (msg, prefix, -1);
+ string_dyn_concat (msg, "\", message=\"", -1);
+ string_dyn_concat (msg, message, -1);
+ string_dyn_concat (msg, "\", tags=\"", -1);
+ string_dyn_concat (msg, tags, -1);
+ string_dyn_concat (msg, "\"\n", -1);
+ }
+ else
+ {
+ string_dyn_concat (msg, ":\n", -1);
+ }
+ if (msg2)
+ {
+ string_dyn_concat (msg, msg2, -1);
+ string_dyn_concat (msg, ":\n", -1);
+ }
+ return msg;
+ }
+
+ static int signal_irc_out_cb (const void *pointer, void *data,
+ const char *signal, const char *type_data,
+ void *signal_data)
+ {
+ /* make C++ compiler happy */
+ (void) pointer;
+ (void) data;
+ (void) signal;
+ (void) type_data;
+
+ if (signal_data)
+ arraylist_add (sent_messages, strdup ((const char *)signal_data));
+
+ return WEECHAT_RC_OK;
+ }
+
+ static int sent_msg_cmp_cb (void *data, struct t_arraylist *arraylist,
+ void *pointer1, void *pointer2)
+ {
+ /* make C++ compiler happy */
+ (void) data;
+ (void) arraylist;
+
+ return strcmp ((char *)pointer1, (char *)pointer2);
+ }
+
+ static void sent_msg_free_cb (void *data, struct t_arraylist *arraylist,
+ void *pointer)
+ {
+ /* make C++ compiler happy */
+ (void) data;
+ (void) arraylist;
+
+ free (pointer);
+ }
+
+ void sent_msg_dump (char **msg)
+ {
+ int i;
+
+ for (i = 0; i < arraylist_size (sent_messages); i++)
+ {
+ string_dyn_concat (msg, " \"", -1);
+ string_dyn_concat (msg,
+ (const char *)arraylist_get (sent_messages, i),
+ -1);
+ string_dyn_concat (msg, "\"\n", -1);
+ }
+ }
+
+ void setup ()
+ {
+ /* initialize list of messages sent to the server */
+ if (sent_messages)
+ {
+ arraylist_clear (sent_messages);
+ }
+ else
+ {
+ sent_messages = arraylist_new (16, 0, 1,
+ &sent_msg_cmp_cb, NULL,
+ &sent_msg_free_cb, NULL);
+ }
+
+ if (!hook_signal_irc_out)
+ {
+ hook_signal_irc_out = hook_signal (NULL,
+ IRC_FAKE_SERVER ",irc_out1_*",
+ &signal_irc_out_cb, NULL, NULL);
+ }
+
+ /*
+ * disable backlog feature during tests, so we are not polluted by
+ * these messages when buffers are opened
+ */
+ config_file_option_set (logger_config_look_backlog, "0", 1);
+
+ /* create a fake server (no I/O) */
+ run_cmd_quiet ("/mute /server add " IRC_FAKE_SERVER " fake:127.0.0.1 "
+ "-nicks=nick1,nick2,nick3");
+
+ /* connect to the fake server */
+ run_cmd_quiet ("/connect " IRC_FAKE_SERVER);
+
+ /* get the server pointer */
+ ptr_server = irc_server_search (IRC_FAKE_SERVER);
+ }
+
+ void teardown ()
+ {
+ /* disconnect and delete the fake server */
+ run_cmd_quiet ("/mute /disconnect " IRC_FAKE_SERVER);
+ run_cmd_quiet ("/mute /server del " IRC_FAKE_SERVER);
+ ptr_server = NULL;
+
+ /* restore backlog feature */
+ config_file_option_reset (logger_config_look_backlog, 1);
+ }
+};
+
/*
* Tests functions:
* irc_protocol_is_numeric_command
WEE_TEST_STR("", irc_protocol_string_params (params_3, 3, 3));
}
-TEST_GROUP(IrcProtocolWithServer)
-{
- void server_recv (const char *command)
- {
- char str_command[4096];
-
- record_start ();
- arraylist_clear (sent_messages);
-
- snprintf (str_command, sizeof (str_command),
- "/command -buffer irc.server." IRC_FAKE_SERVER " irc "
- "/server fakerecv \"%s\"",
- command);
- run_cmd_quiet (str_command);
-
- record_stop ();
- }
-
- void server_input_data (const char *buffer, const char *data)
- {
- struct t_gui_buffer *ptr_buffer;
-
- record_start ();
- arraylist_clear (sent_messages);
-
- ptr_buffer = gui_buffer_search_by_full_name (buffer);
- if (ptr_buffer)
- input_data (ptr_buffer, data, NULL, 0);
-
- record_stop ();
- }
-
- char **server_build_error (const char *msg1,
- const char *prefix,
- const char *message,
- const char *tags,
- const char *msg2)
- {
- char **msg;
-
- msg = string_dyn_alloc (1024);
- string_dyn_concat (msg, msg1, -1);
- if (message)
- {
- string_dyn_concat (msg, ": prefix=\"", -1);
- string_dyn_concat (msg, prefix, -1);
- string_dyn_concat (msg, "\", message=\"", -1);
- string_dyn_concat (msg, message, -1);
- string_dyn_concat (msg, "\", tags=\"", -1);
- string_dyn_concat (msg, tags, -1);
- string_dyn_concat (msg, "\"\n", -1);
- }
- else
- {
- string_dyn_concat (msg, ":\n", -1);
- }
- if (msg2)
- {
- string_dyn_concat (msg, msg2, -1);
- string_dyn_concat (msg, ":\n", -1);
- }
- return msg;
- }
-
- static int signal_irc_out_cb (const void *pointer, void *data,
- const char *signal, const char *type_data,
- void *signal_data)
- {
- /* make C++ compiler happy */
- (void) pointer;
- (void) data;
- (void) signal;
- (void) type_data;
-
- if (signal_data)
- arraylist_add (sent_messages, strdup ((const char *)signal_data));
-
- return WEECHAT_RC_OK;
- }
-
- static int sent_msg_cmp_cb (void *data, struct t_arraylist *arraylist,
- void *pointer1, void *pointer2)
- {
- /* make C++ compiler happy */
- (void) data;
- (void) arraylist;
-
- return strcmp ((char *)pointer1, (char *)pointer2);
- }
-
- static void sent_msg_free_cb (void *data, struct t_arraylist *arraylist,
- void *pointer)
- {
- /* make C++ compiler happy */
- (void) data;
- (void) arraylist;
-
- free (pointer);
- }
-
- void sent_msg_dump (char **msg)
- {
- int i;
-
- for (i = 0; i < arraylist_size (sent_messages); i++)
- {
- string_dyn_concat (msg, " \"", -1);
- string_dyn_concat (msg,
- (const char *)arraylist_get (sent_messages, i),
- -1);
- string_dyn_concat (msg, "\"\n", -1);
- }
- }
-
- void setup ()
- {
- /* initialize list of messages sent to the server */
- if (sent_messages)
- {
- arraylist_clear (sent_messages);
- }
- else
- {
- sent_messages = arraylist_new (16, 0, 1,
- &sent_msg_cmp_cb, NULL,
- &sent_msg_free_cb, NULL);
- }
-
- if (!hook_signal_irc_out)
- {
- hook_signal_irc_out = hook_signal (NULL,
- IRC_FAKE_SERVER ",irc_out1_*",
- &signal_irc_out_cb, NULL, NULL);
- }
-
- /*
- * disable backlog feature during tests, so we are not polluted by
- * these messages when buffers are opened
- */
- config_file_option_set (logger_config_look_backlog, "0", 1);
-
- /* create a fake server (no I/O) */
- run_cmd_quiet ("/mute /server add " IRC_FAKE_SERVER " fake:127.0.0.1 "
- "-nicks=nick1,nick2,nick3");
-
- /* connect to the fake server */
- run_cmd_quiet ("/connect " IRC_FAKE_SERVER);
-
- /* get the server pointer */
- ptr_server = irc_server_search (IRC_FAKE_SERVER);
- }
-
- void teardown ()
- {
- /* disconnect and delete the fake server */
- run_cmd_quiet ("/mute /disconnect " IRC_FAKE_SERVER);
- run_cmd_quiet ("/mute /server del " IRC_FAKE_SERVER);
- ptr_server = NULL;
-
- /* restore backlog feature */
- config_file_option_reset (logger_config_look_backlog, 1);
- }
-};
-
/*
* Tests send of messages to channel (STATUSMSG and normal) and nick,
* without capability "echo-message" enabled:
--- /dev/null
+/*
+ * test-relay-irc.cpp - test IRC protocol for relay to client
+ *
+ * Copyright (C) 2023 Sébastien Helleu <flashcode@flashtux.org>
+ *
+ * This file is part of WeeChat, the extensible chat client.
+ *
+ * WeeChat is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * WeeChat 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with WeeChat. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include "CppUTest/TestHarness.h"
+
+#include "tests/tests.h"
+#include "tests/tests-record.h"
+
+extern "C"
+{
+#include <stdio.h>
+#include <string.h>
+#include "src/core/wee-arraylist.h"
+#include "src/core/wee-config-file.h"
+#include "src/core/wee-hashtable.h"
+#include "src/core/wee-hook.h"
+#include "src/core/wee-string.h"
+#include "src/plugins/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/irc/relay-irc.h"
+
+extern int relay_irc_command_relayed (const char *irc_command);
+extern int relay_irc_command_ignored (const char *irc_command);
+extern int relay_irc_search_server_capability (const char *capability);
+extern struct t_hashtable *relay_irc_message_parse (const char *message);
+extern void relay_irc_sendf (struct t_relay_client *client,
+ const char *format, ...);
+extern int relay_irc_tag_relay_client_id (const char *tags);
+extern void relay_irc_input_send (struct t_relay_client *client,
+ const char *irc_channel,
+ const char *options,
+ const char *format, ...);
+}
+
+#define CLIENT_RECV(__irc_msg) \
+ test_client_recv (__irc_msg);
+
+#define CLIENT_SEND(__irc_msg) \
+ test_client_send (__irc_msg);
+
+#define CHECK_SENT_CLIENT(__message) \
+ if ((__message != NULL) \
+ && !arraylist_search (sent_messages_client, (void *)__message, \
+ NULL, NULL)) \
+ { \
+ char **msg = test_build_error ( \
+ "Message not sent to the relay client", \
+ NULL, \
+ __message, \
+ NULL, \
+ "All messages sent"); \
+ sent_msg_dump (sent_messages_client, msg); \
+ FAIL(string_dyn_free (msg, 0)); \
+ } \
+ else if ((__message == NULL) \
+ && (arraylist_size (sent_messages_client) > 0)) \
+ { \
+ char **msg = test_build_error ( \
+ "Unexpected message(s) sent to the relay cleint", \
+ NULL, \
+ NULL, \
+ NULL, \
+ NULL); \
+ sent_msg_dump (sent_messages_client, msg); \
+ FAIL(string_dyn_free (msg, 0)); \
+ }
+
+#define CHECK_SENT_IRC(__message) \
+ if ((__message != NULL) \
+ && !arraylist_search (sent_messages_irc, (void *)__message, \
+ NULL, NULL)) \
+ { \
+ char **msg = test_build_error ( \
+ "Message not sent to the IRC server", \
+ NULL, \
+ __message, \
+ NULL, \
+ "All messages sent"); \
+ sent_msg_dump (sent_messages_irc, msg); \
+ FAIL(string_dyn_free (msg, 0)); \
+ } \
+ else if ((__message == NULL) \
+ && (arraylist_size (sent_messages_irc) > 0)) \
+ { \
+ char **msg = test_build_error ( \
+ "Unexpected message(s) sent to the IRC server", \
+ NULL, \
+ NULL, \
+ NULL, \
+ NULL); \
+ sent_msg_dump (sent_messages_irc, msg); \
+ FAIL(string_dyn_free (msg, 0)); \
+ }
+
+struct t_relay_server *ptr_relay_server = NULL;
+struct t_relay_client *ptr_relay_client = NULL;
+struct t_arraylist *sent_messages_client = NULL;
+struct t_arraylist *sent_messages_irc = NULL;
+struct t_hook *hook_modifier_relay_irc_out = NULL;
+struct t_hook *hook_signal_irc_input_send = NULL;
+
+TEST_GROUP(RelayIrc)
+{
+};
+
+TEST_GROUP(RelayIrcWithClient)
+{
+ void test_client_recv (const char *data)
+ {
+ record_start ();
+
+ arraylist_clear (sent_messages_client);
+ arraylist_clear (sent_messages_irc);
+
+ relay_irc_recv (ptr_relay_client, data);
+
+ record_stop ();
+ }
+
+ void test_client_send (const char *data)
+ {
+ record_start ();
+
+ arraylist_clear (sent_messages_client);
+ arraylist_clear (sent_messages_irc);
+
+ relay_irc_sendf (ptr_relay_client, "%s", data);
+
+ record_stop ();
+ }
+
+ char **test_build_error (const char *msg1,
+ const char *prefix,
+ const char *message,
+ const char *tags,
+ const char *msg2)
+ {
+ char **msg;
+
+ msg = string_dyn_alloc (1024);
+ string_dyn_concat (msg, msg1, -1);
+ if (message)
+ {
+ string_dyn_concat (msg, ": prefix=\"", -1);
+ string_dyn_concat (msg, prefix, -1);
+ string_dyn_concat (msg, "\", message=\"", -1);
+ string_dyn_concat (msg, message, -1);
+ string_dyn_concat (msg, "\", tags=\"", -1);
+ string_dyn_concat (msg, tags, -1);
+ string_dyn_concat (msg, "\"\n", -1);
+ }
+ else
+ {
+ string_dyn_concat (msg, ":\n", -1);
+ }
+ if (msg2)
+ {
+ string_dyn_concat (msg, msg2, -1);
+ string_dyn_concat (msg, ":\n", -1);
+ }
+ return msg;
+ }
+
+ static char *modifier_relay_irc_out_cb (const void *pointer,
+ void *data,
+ const char *modifier,
+ const char *modifier_data,
+ const char *string)
+ {
+ /* make C++ compiler happy */
+ (void) pointer;
+ (void) data;
+ (void) modifier;
+ (void) modifier_data;
+
+ if (string)
+ arraylist_add (sent_messages_client, strdup (string));
+
+ return NULL;
+ }
+
+ static int signal_irc_input_send_cb (const void *pointer, void *data,
+ const char *signal,
+ const char *type_data,
+ void *signal_data)
+ {
+ /* make C++ compiler happy */
+ (void) pointer;
+ (void) data;
+ (void) signal;
+ (void) type_data;
+
+ if (signal_data)
+ {
+ arraylist_add (sent_messages_irc,
+ strdup ((const char *)signal_data));
+ }
+
+ return WEECHAT_RC_OK;
+ }
+
+ static int sent_msg_cmp_cb (void *data, struct t_arraylist *arraylist,
+ void *pointer1, void *pointer2)
+ {
+ /* make C++ compiler happy */
+ (void) data;
+ (void) arraylist;
+
+ return strcmp ((char *)pointer1, (char *)pointer2);
+ }
+
+ static void sent_msg_free_cb (void *data, struct t_arraylist *arraylist,
+ void *pointer)
+ {
+ /* make C++ compiler happy */
+ (void) data;
+ (void) arraylist;
+
+ free (pointer);
+ }
+
+ void sent_msg_dump (struct t_arraylist *sent_messages, char **msg)
+ {
+ int i;
+
+ for (i = 0; i < arraylist_size (sent_messages); i++)
+ {
+ string_dyn_concat (msg, " \"", -1);
+ string_dyn_concat (msg,
+ (const char *)arraylist_get (sent_messages, i),
+ -1);
+ string_dyn_concat (msg, "\"\n", -1);
+ }
+ }
+
+ void setup ()
+ {
+ /* initialize list of messages sent to the relay client */
+ if (sent_messages_client)
+ {
+ arraylist_clear (sent_messages_client);
+ }
+ else
+ {
+ sent_messages_client = arraylist_new (16, 0, 1,
+ &sent_msg_cmp_cb, NULL,
+ &sent_msg_free_cb, NULL);
+ }
+
+ /* initialize list of messages sent to the IRC server */
+ if (sent_messages_irc)
+ {
+ arraylist_clear (sent_messages_irc);
+ }
+ else
+ {
+ sent_messages_irc = arraylist_new (16, 0, 1,
+ &sent_msg_cmp_cb, NULL,
+ &sent_msg_free_cb, NULL);
+ }
+
+ /* 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);
+
+ if (!hook_modifier_relay_irc_out)
+ {
+ hook_modifier_relay_irc_out = hook_modifier (
+ NULL,
+ "relay_client_irc_out1",
+ &modifier_relay_irc_out_cb, NULL, NULL);
+ }
+
+ if (!hook_signal_irc_input_send)
+ {
+ hook_signal_irc_input_send = hook_signal (
+ NULL,
+ "irc_input_send",
+ &signal_irc_input_send_cb, NULL, NULL);
+ }
+
+ /* create a fake server (no I/O) */
+ run_cmd_quiet ("/mute /server add test fake:127.0.0.1 "
+ "-nicks=nick1,nick2,nick3");
+
+ /* connect to the fake server */
+ run_cmd_quiet ("/connect test");
+
+ /* simulate connection OK to server */
+ run_cmd_quiet ("/command -buffer irc.server.test irc "
+ "/server fakerecv "
+ "\":server 001 alice :Welcome on this server, nick1!\"");
+
+ /* create a fake server (no I/O) */
+ ptr_relay_server = relay_server_new (
+ "irc.test",
+ RELAY_PROTOCOL_IRC,
+ "test",
+ 9000,
+ NULL, /* path */
+ 1, /* ipv4 */
+ 0, /* ipv6 */
+ 0, /* tls */
+ 0); /* unix_socket */
+
+ /* create a fake client (no I/O) */
+ ptr_relay_client = relay_client_new (-1, "test", ptr_relay_server);
+ }
+
+ void teardown ()
+ {
+ relay_client_free (ptr_relay_client);
+ relay_server_free (ptr_relay_server);
+
+ ptr_relay_server = NULL;
+ ptr_relay_client = NULL;
+
+ /* disconnect and delete the fake server */
+ run_cmd_quiet ("/mute /disconnect test");
+ run_cmd_quiet ("/mute /server del test");
+
+ /* 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_irc_command_relayed
+ */
+
+TEST(RelayIrc, RelayIrcCommandRelayed)
+{
+ LONGS_EQUAL(0, relay_irc_command_relayed (NULL));
+ LONGS_EQUAL(0, relay_irc_command_relayed (""));
+ LONGS_EQUAL(0, relay_irc_command_relayed ("unknown"));
+
+ LONGS_EQUAL(1, relay_irc_command_relayed ("privmsg"));
+ LONGS_EQUAL(1, relay_irc_command_relayed ("PRIVMSG"));
+ LONGS_EQUAL(1, relay_irc_command_relayed ("notice"));
+ LONGS_EQUAL(1, relay_irc_command_relayed ("Notice"));
+}
+
+/*
+ * Tests functions:
+ * relay_irc_command_ignored
+ */
+
+TEST(RelayIrc, RelayIrcCommandIgnored)
+{
+ LONGS_EQUAL(0, relay_irc_command_ignored (NULL));
+ LONGS_EQUAL(0, relay_irc_command_ignored (""));
+ LONGS_EQUAL(0, relay_irc_command_ignored ("unknown"));
+
+ LONGS_EQUAL(1, relay_irc_command_ignored ("cap"));
+ LONGS_EQUAL(1, relay_irc_command_ignored ("CAP"));
+ LONGS_EQUAL(1, relay_irc_command_ignored ("pong"));
+ LONGS_EQUAL(1, relay_irc_command_ignored ("Pong"));
+ LONGS_EQUAL(1, relay_irc_command_ignored ("quit"));
+}
+
+/*
+ * Tests functions:
+ * relay_irc_search_backlog_commands_tags
+ */
+
+TEST(RelayIrc, RelayIrcSearchBacklogCommandsTags)
+{
+ LONGS_EQUAL(-1, relay_irc_search_backlog_commands_tags (NULL));
+ LONGS_EQUAL(-1, relay_irc_search_backlog_commands_tags (""));
+ LONGS_EQUAL(-1, relay_irc_search_backlog_commands_tags ("unknown"));
+ LONGS_EQUAL(-1, relay_irc_search_backlog_commands_tags ("IRC_JOIN"));
+
+ CHECK(relay_irc_search_backlog_commands_tags ("irc_join") >= 0);
+ CHECK(relay_irc_search_backlog_commands_tags ("irc_privmsg") >= 0);
+}
+
+/*
+ * Tests functions:
+ * relay_irc_search_server_capability
+ */
+
+TEST(RelayIrc, RelayIrcSearchServerCapability)
+{
+ LONGS_EQUAL(-1, relay_irc_search_server_capability (NULL));
+ LONGS_EQUAL(-1, relay_irc_search_server_capability (""));
+ LONGS_EQUAL(-1, relay_irc_search_server_capability ("unknown"));
+
+ CHECK(relay_irc_search_server_capability ("server-time") >= 0);
+}
+
+/*
+ * Tests functions:
+ * relay_irc_message_parse
+ */
+
+TEST(RelayIrc, RelayIrcMessageParse)
+{
+ struct t_hashtable *hashtable;
+
+ POINTERS_EQUAL(NULL, relay_irc_message_parse (NULL));
+
+ hashtable = relay_irc_message_parse ("");
+ CHECK(hashtable);
+ LONGS_EQUAL(14, hashtable->items_count);
+ STRCMP_EQUAL("", (const char *)hashtable_get (hashtable, "tags"));
+ STRCMP_EQUAL("", (const char *)hashtable_get (hashtable, "message_without_tags"));
+ STRCMP_EQUAL("", (const char *)hashtable_get (hashtable, "nick"));
+ STRCMP_EQUAL("", (const char *)hashtable_get (hashtable, "user"));
+ STRCMP_EQUAL("", (const char *)hashtable_get (hashtable, "host"));
+ STRCMP_EQUAL("", (const char *)hashtable_get (hashtable, "command"));
+ STRCMP_EQUAL("", (const char *)hashtable_get (hashtable, "channel"));
+ STRCMP_EQUAL("", (const char *)hashtable_get (hashtable, "arguments"));
+ STRCMP_EQUAL("", (const char *)hashtable_get (hashtable, "text"));
+ STRCMP_EQUAL("0", (const char *)hashtable_get (hashtable, "num_params"));
+ STRCMP_EQUAL("-1", (const char *)hashtable_get (hashtable, "pos_command"));
+ STRCMP_EQUAL("-1", (const char *)hashtable_get (hashtable, "pos_arguments"));
+ STRCMP_EQUAL("-1", (const char *)hashtable_get (hashtable, "pos_channel"));
+ STRCMP_EQUAL("-1", (const char *)hashtable_get (hashtable, "pos_text"));
+ hashtable_free (hashtable);
+
+ hashtable = relay_irc_message_parse (
+ "@time=2015-06-27T16:40:35.000Z :nick!user@host PRIVMSG #weechat :Hello world!");
+ CHECK(hashtable);
+ LONGS_EQUAL(17, hashtable->items_count);
+ STRCMP_EQUAL("time=2015-06-27T16:40:35.000Z", (const char *)hashtable_get (hashtable, "tags"));
+ STRCMP_EQUAL("2015-06-27T16:40:35.000Z", (const char *)hashtable_get (hashtable, "tag_time"));
+ STRCMP_EQUAL(":nick!user@host PRIVMSG #weechat :Hello world!", (const char *)hashtable_get (hashtable, "message_without_tags"));
+ STRCMP_EQUAL("nick", (const char *)hashtable_get (hashtable, "nick"));
+ STRCMP_EQUAL("user", (const char *)hashtable_get (hashtable, "user"));
+ STRCMP_EQUAL("nick!user@host", (const char *)hashtable_get (hashtable, "host"));
+ STRCMP_EQUAL("PRIVMSG", (const char *)hashtable_get (hashtable, "command"));
+ STRCMP_EQUAL("#weechat", (const char *)hashtable_get (hashtable, "channel"));
+ STRCMP_EQUAL("#weechat :Hello world!", (const char *)hashtable_get (hashtable, "arguments"));
+ STRCMP_EQUAL("Hello world!", (const char *)hashtable_get (hashtable, "text"));
+ STRCMP_EQUAL("2", (const char *)hashtable_get (hashtable, "num_params"));
+ STRCMP_EQUAL("#weechat", (const char *)hashtable_get (hashtable, "param1"));
+ STRCMP_EQUAL("Hello world!", (const char *)hashtable_get (hashtable, "param2"));
+ STRCMP_EQUAL("47", (const char *)hashtable_get (hashtable, "pos_command"));
+ STRCMP_EQUAL("55", (const char *)hashtable_get (hashtable, "pos_arguments"));
+ STRCMP_EQUAL("55", (const char *)hashtable_get (hashtable, "pos_channel"));
+ STRCMP_EQUAL("65", (const char *)hashtable_get (hashtable, "pos_text"));
+ hashtable_free (hashtable);
+}
+
+/*
+ * Tests functions:
+ * relay_irc_sendf
+ */
+
+TEST(RelayIrcWithClient, RelayIrcSendf)
+{
+
+ relay_irc_sendf (NULL, NULL);
+ relay_irc_sendf (NULL, "test");
+ relay_irc_sendf (ptr_relay_client, NULL);
+
+ CLIENT_SEND("PING");
+ CHECK_SENT_CLIENT("PING");
+
+ CLIENT_SEND("PRIVMSG #test :test message");
+ CHECK_SENT_CLIENT("PRIVMSG #test :test message");
+}
+
+/*
+ * Tests functions:
+ * relay_irc_signal_irc_in2_cb
+ */
+
+TEST(RelayIrc, RelayIrcSignalIrcIn2Cb)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_tag_relay_client_id
+ */
+
+TEST(RelayIrc, RelayIrcTagRelayClientId)
+{
+ LONGS_EQUAL(-1, relay_irc_tag_relay_client_id (NULL));
+ LONGS_EQUAL(-1, relay_irc_tag_relay_client_id (""));
+ LONGS_EQUAL(-1, relay_irc_tag_relay_client_id ("zzz"));
+ LONGS_EQUAL(-1, relay_irc_tag_relay_client_id ("relay_client_abc"));
+
+ LONGS_EQUAL(0, relay_irc_tag_relay_client_id ("relay_client_0"));
+ LONGS_EQUAL(123, relay_irc_tag_relay_client_id ("relay_client_123"));
+}
+
+/*
+ * Tests functions:
+ * relay_irc_signal_irc_outtags_cb
+ */
+
+TEST(RelayIrc, RelayIrcSignalIrcOuttagsCb)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_signal_irc_disc_cb
+ */
+
+TEST(RelayIrc, RelayIrcSignalIrcDiscCb)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_hsignal_irc_redir_cb
+ */
+
+TEST(RelayIrc, RelayIrcHsignalIrcRedirCb)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_get_line_info
+ */
+
+TEST(RelayIrc, RelayIrcGetLineInfo)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_send_channel_backlog
+ */
+
+TEST(RelayIrc, RelayIrcSendChannelBacklog)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_send_join
+ */
+
+TEST(RelayIrc, RelayIrcSendJoin)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_send_join_channels
+ */
+
+TEST(RelayIrc, RelayIrcSendJoinChannels)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_input_send
+ */
+
+TEST(RelayIrcWithClient, RelayIrcInputSend)
+{
+ arraylist_clear (sent_messages_irc);
+ relay_irc_input_send (ptr_relay_client, "#test", "priority_high",
+ "this is a test");
+ CHECK_SENT_IRC("test;#test;priority_high;relay_client_1;this is a test");
+}
+
+/*
+ * Tests functions:
+ * relay_irc_hook_signals
+ */
+
+TEST(RelayIrc, RelayIrcHookSignals)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_recv_command_capab
+ */
+
+TEST(RelayIrcWithClient, RelayIrcRecvCommandCapab)
+{
+ relay_client_set_status (ptr_relay_client, RELAY_STATUS_CONNECTING);
+
+ POINTERS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, server_capabilities));
+ POINTERS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, cap_ls_received));
+ POINTERS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, cap_end_received));
+
+ /* not enough parameters */
+ CLIENT_RECV(":alice!user@host CAP");
+
+ /* list supported capabilities */
+ CLIENT_RECV(":alice!user@host CAP LS");
+ CHECK_SENT_CLIENT(":weechat.relay.irc CAP nick LS :server-time");
+ POINTERS_EQUAL(1, RELAY_IRC_DATA(ptr_relay_client, cap_ls_received));
+ POINTERS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, cap_end_received));
+
+ /* request unknown capability: reject */
+ CLIENT_RECV(":alice!user@host CAP REQ unknown");
+ CHECK_SENT_CLIENT(":weechat.relay.irc CAP nick NAK :unknown");
+ POINTERS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, server_capabilities));
+ POINTERS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, cap_end_received));
+
+ /* request supported capability: accept */
+ CLIENT_RECV(":alice!user@host CAP REQ server-time");
+ CHECK_SENT_CLIENT(":weechat.relay.irc CAP nick ACK :server-time");
+ CHECK(RELAY_IRC_DATA(ptr_relay_client, server_capabilities)
+ & (1 << RELAY_IRC_CAPAB_SERVER_TIME));
+ POINTERS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, cap_end_received));
+ RELAY_IRC_DATA(ptr_relay_client, server_capabilities) = 0;
+
+ /* request unknown + supported capabilities: reject */
+ CLIENT_RECV(":alice!user@host CAP REQ :server-time unknown");
+ CHECK_SENT_CLIENT(":weechat.relay.irc CAP nick NAK :server-time unknown");
+ POINTERS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, server_capabilities));
+ POINTERS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, cap_end_received));
+
+ /* request with empty list: end of capability negociation */
+ CLIENT_RECV(":alice!user@host CAP REQ :");
+ CHECK_SENT_CLIENT(":weechat.relay.irc CAP nick NAK :");
+ POINTERS_EQUAL(1, RELAY_IRC_DATA(ptr_relay_client, cap_end_received));
+
+ RELAY_IRC_DATA(ptr_relay_client, cap_end_received) = 0;
+
+ /* end capability negociation */
+ CLIENT_RECV(":alice!user@host CAP END");
+ POINTERS_EQUAL(1, RELAY_IRC_DATA(ptr_relay_client, cap_end_received));
+}
+
+/*
+ * Tests functions:
+ * relay_irc_recv
+ */
+
+TEST(RelayIrcWithClient, RelayIrcRecv)
+{
+ relay_client_set_status (ptr_relay_client, RELAY_STATUS_CONNECTING);
+
+ /* NICK */
+ CLIENT_RECV("NICK alice");
+ STRCMP_EQUAL("alice", RELAY_IRC_DATA(ptr_relay_client, nick));
+
+ CLIENT_RECV("NICK bob");
+ STRCMP_EQUAL("bob", RELAY_IRC_DATA(ptr_relay_client, nick));
+
+ /* PASS */
+ LONGS_EQUAL(0, RELAY_IRC_DATA(ptr_relay_client, password_ok));
+
+ CLIENT_RECV("PASS invalid");
+ LONGS_EQUAL(RELAY_STATUS_CONNECTING, ptr_relay_client->status);
+
+ CLIENT_RECV("PASS secret");
+ LONGS_EQUAL(1, RELAY_IRC_DATA(ptr_relay_client, password_ok));
+ LONGS_EQUAL(RELAY_STATUS_CONNECTED, ptr_relay_client->status);
+
+ free (ptr_relay_client->protocol_args);
+ ptr_relay_client->protocol_args = NULL;
+ relay_client_set_status (ptr_relay_client, RELAY_STATUS_CONNECTING);
+ RELAY_IRC_DATA(ptr_relay_client, password_ok) = 0;
+
+ CLIENT_RECV("PASS test2:secret");
+ STRCMP_EQUAL("test2", ptr_relay_client->protocol_args);
+ LONGS_EQUAL(1, RELAY_IRC_DATA(ptr_relay_client, password_ok));
+ LONGS_EQUAL(RELAY_STATUS_CONNECTED, ptr_relay_client->status);
+ free (ptr_relay_client->protocol_args);
+ ptr_relay_client->protocol_args = strdup ("test");
+
+ /* USER */
+ relay_client_set_status (ptr_relay_client, RELAY_STATUS_CONNECTING);
+ CLIENT_RECV("USER alice 0 * :alice");
+ LONGS_EQUAL(1, RELAY_IRC_DATA(ptr_relay_client, user_received));
+ LONGS_EQUAL(1, RELAY_IRC_DATA(ptr_relay_client, connected));
+ STRCMP_EQUAL("alice", RELAY_IRC_DATA(ptr_relay_client, nick));
+ CHECK_SENT_CLIENT(":bob!proxy NICK :alice");
+ CHECK_SENT_CLIENT(":weechat.relay.irc 001 alice :Welcome to the "
+ "Internet Relay Chat Network alice!weechat@proxy");
+
+ /* JOIN */
+ CLIENT_RECV("JOIN #test");
+ CHECK_SENT_IRC("test;;priority_high;relay_client_1;/join #test");
+
+ /* PART */
+ CLIENT_RECV("PART #test");
+ CHECK_SENT_IRC("test;;priority_high;relay_client_1;/part #test");
+
+ /* PING */
+ CLIENT_RECV("PING :12345");
+ CHECK_SENT_CLIENT(":weechat.relay.irc PONG weechat.relay.irc :12345");
+
+ /* NOTICE */
+ CLIENT_RECV("NOTICE bob :a notice");
+ CHECK_SENT_IRC("test;;priority_high;relay_client_1;/notice bob a notice");
+
+ /* PRIVMSG to channel */
+ CLIENT_RECV("PRIVMSG #test :message to channel");
+ CHECK_SENT_IRC("test;#test;priority_high,user_message;relay_client_1;"
+ "message to channel");
+
+ /* PRIVMSG to user */
+ CLIENT_RECV("PRIVMSG bob :private message");
+ CHECK_SENT_IRC("test;;priority_high;relay_client_1;"
+ "/query bob private message");
+
+ /* WHOIS */
+ CLIENT_RECV("WHOIS bob");
+ CHECK_SENT_IRC("test;;priority_high;relay_client_1;/quote WHOIS bob");
+}
+
+/*
+ * Tests functions:
+ * relay_irc_close_connection
+ */
+
+TEST(RelayIrc, RelayIrcCloseConnection)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_alloc
+ */
+
+TEST(RelayIrc, RelayIrcAlloc)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_alloc_with_infolist
+ */
+
+TEST(RelayIrc, RelayIrcAllocWithInfolist)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_get_initial_status
+ */
+
+TEST(RelayIrc, RelayIrcGetInitialStatus)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_free
+ */
+
+TEST(RelayIrc, RelayIrcFree)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_add_to_infolist
+ */
+
+TEST(RelayIrc, RelayIrcAddToInfolist)
+{
+ /* TODO: write tests */
+}
+
+/*
+ * Tests functions:
+ * relay_irc_print_log
+ */
+
+TEST(RelayIrc, RelayIrcPrintLog)
+{
+ /* TODO: write tests */
+}
projects / irc / weechat / weechat.git / commitdiff
