Add reply cache, composer bar, and nick-menu replies

src/common/fe.h

@@ -78,6 +78,7 @@ int fe_input_add (int sok, int flags, void *func, void *data);
 void fe_input_remove (int tag);
 void fe_idle_add (void *func, void *data);
 void fe_set_topic (struct session *sess, char *topic, char *stripped_topic);
+void fe_set_typing (struct session *sess, const char *nick, const char *state);
 typedef enum
 {
 	FE_COLOR_NONE = 0,

src/common/inbound.c

@@ -46,6 +46,155 @@
 #include "servlist.h"
 #include "sts.h"
 #include "text.h"
+
+void reply_state_clear (session *sess);
+
+gboolean
+reply_msgid_valid (const char *msgid)
+{
+	const char *p;
+
+	if (!msgid || !*msgid || *msgid == ':')
+		return FALSE;
+
+	for (p = msgid; *p; p++)
+	{
+		if (*p == ' ' || *p == '\r' || *p == '\n')
+			return FALSE;
+	}
+
+	return TRUE;
+}
+
+static void
+reply_item_free (reply_item *item)
+{
+	if (!item)
+		return;
+	g_free (item->msgid);
+	g_free (item->nick);
+	g_free (item->text);
+	g_free (item);
+}
+
+void
+reply_cache_free (session *sess)
+{
+	if (!sess)
+		return;
+	g_slist_free_full (sess->reply_items, (GDestroyNotify) reply_item_free);
+	sess->reply_items = NULL;
+	reply_state_clear (sess);
+}
+
+reply_item *
+reply_cache_find (session *sess, const char *msgid)
+{
+	GSList *list;
+
+	if (!sess || !reply_msgid_valid (msgid))
+		return NULL;
+
+	for (list = sess->reply_items; list; list = list->next)
+	{
+		reply_item *item = list->data;
+		if (!strcmp (item->msgid, msgid))
+			return item;
+	}
+
+	return NULL;
+}
+
+reply_item *
+reply_cache_latest_from (session *sess, const char *nick)
+{
+	GSList *list;
+
+	if (!sess || !nick || !*nick)
+		return NULL;
+
+	for (list = sess->reply_items; list; list = list->next)
+	{
+		reply_item *item = list->data;
+		if (!sess->server->p_cmp (item->nick, nick))
+			return item;
+	}
+
+	return NULL;
+}
+
+void
+reply_state_clear (session *sess)
+{
+	if (!sess)
+		return;
+	g_clear_pointer (&sess->reply_msgid, g_free);
+	g_clear_pointer (&sess->reply_target, g_free);
+	g_clear_pointer (&sess->reply_nick, g_free);
+	g_clear_pointer (&sess->reply_text, g_free);
+}
+
+void
+reply_state_set (session *sess, const char *msgid, const char *target, const char *nick, const char *text)
+{
+	if (!sess || !reply_msgid_valid (msgid))
+		return;
+	reply_state_clear (sess);
+	sess->reply_msgid = g_strdup (msgid);
+	sess->reply_target = g_strdup (target && *target ? target : sess->channel);
+	sess->reply_nick = g_strdup (nick && *nick ? nick : _("message"));
+	sess->reply_text = g_strdup (text && *text ? text : _("Original message unavailable"));
+}
+
+static void
+reply_cache_add (session *sess, const char *msgid, const char *nick, const char *text, time_t timestamp)
+{
+	reply_item *item;
+
+	if (!sess || !reply_msgid_valid (msgid) || !nick || !text)
+		return;
+
+	item = reply_cache_find (sess, msgid);
+	if (item)
+	{
+		g_free (item->nick);
+		g_free (item->text);
+		item->nick = g_strdup (nick);
+		item->text = g_strdup (text);
+		item->timestamp = timestamp;
+		return;
+	}
+
+	item = g_new0 (reply_item, 1);
+	item->msgid = g_strdup (msgid);
+	item->nick = g_strdup (nick);
+	item->text = g_strdup (text);
+	item->timestamp = timestamp;
+	sess->reply_items = g_slist_prepend (sess->reply_items, item);
+
+	if (g_slist_length (sess->reply_items) > 200)
+	{
+		GSList *last = g_slist_last (sess->reply_items);
+		item = last->data;
+		sess->reply_items = g_slist_delete_link (sess->reply_items, last);
+		reply_item_free (item);
+	}
+}
+
+static void
+reply_context_print (session *sess, const message_tags_data *tags_data)
+{
+	reply_item *item;
+
+	if (!sess || !tags_data || !tags_data->reply)
+		return;
+
+	item = reply_cache_find (sess, tags_data->reply);
+	if (item)
+		PrintTextTimeStampf (sess, tags_data->timestamp, "\00314│ ↪ %s: %.180s\017\n", item->nick, item->text);
+	else
+		PrintTextTimeStamp (sess, "\00314│ ↪ Original message unavailable\017\n", tags_data->timestamp);
+}
 #include "ctcp.h"
 #include "zoitechatc.h"
 #include "chanopt.h"
@@ -450,6 +599,9 @@ inbound_action (session *sess, char *chan, char *from, char *ip, char *text,
 			fromme = TRUE;
 	}
 
+	if (!fromme)
+		fe_set_typing (sess, from, "done");
+
 	inbound_make_idtext (serv, idtext, sizeof (idtext), id);
 
 	if (!fromme && !privaction)
@@ -518,12 +670,17 @@ inbound_chanmsg (server *serv, session *sess, char *chan, char *from,
 			fromme = TRUE;
 	}
 
+	if (!fromme)
+		fe_set_typing (sess, from, "done");
+
 	if (fromme)
 	{
 		if (prefs.hex_away_auto_unmark && serv->is_away && !tags_data->timestamp)
 			sess->server->p_set_back (sess->server);
+		reply_context_print (sess, tags_data);
 		EMIT_SIGNAL_TIMESTAMP (XP_TE_UCHANMSG, sess, from, text, nickchar, NULL,
 									  0, tags_data->timestamp);
+		reply_cache_add (sess, tags_data->msgid, from, text, tags_data->timestamp);
 		return;
 	}
 
@@ -532,6 +689,8 @@ inbound_chanmsg (server *serv, session *sess, char *chan, char *from,
 	if (is_hilight (from, text, sess, serv))
 		hilight = TRUE;
 
+	reply_context_print (sess, tags_data);
+
 	if (sess->type == SESS_DIALOG)
 		EMIT_SIGNAL_TIMESTAMP (XP_TE_DPRIVMSG, sess, from, text, idtext, NULL, 0,
 									  tags_data->timestamp);
@@ -541,6 +700,8 @@ inbound_chanmsg (server *serv, session *sess, char *chan, char *from,
 	else
 		EMIT_SIGNAL_TIMESTAMP (XP_TE_CHANMSG, sess, from, text, nickchar, idtext,
 									  0, tags_data->timestamp);
+
+	reply_cache_add (sess, tags_data->msgid, from, text, tags_data->timestamp);
 }
 
 void
@@ -1742,6 +1903,10 @@ inbound_toggle_caps (server *serv, const char *extensions_str, gboolean enable)
 			serv->have_awaynotify = enable;
 		else if (!strcmp (extension, "account-tag"))
 			serv->have_account_tag = enable;
+		else if (!strcmp (extension, "message-tags"))
+			serv->have_message_tags = enable;
+		else if (!strcmp (extension, "echo-message"))
+			serv->have_echo_message = enable;
 		else if (!strcmp (extension, "sasl"))
 		{
 			serv->have_sasl = enable;
@@ -1873,6 +2038,8 @@ static const char * const supported_caps[] = {
 	"account-tag",
 	"extended-monitor",
 	"standard-replies",
+	"message-tags",
+	"echo-message",
 
 	/* ZNC */
 	"znc.in/server-time-iso",

src/common/inbound.h

@@ -78,6 +78,13 @@ void inbound_login_end (session *sess, char *text,
 void inbound_chanmsg (server *serv, session *sess, char *chan, char *from,
 							 char *text, char fromme, int id, 
 							 const message_tags_data *tags_data);
+gboolean reply_msgid_valid (const char *msgid);
+void reply_cache_free (session *sess);
+reply_item *reply_cache_find (session *sess, const char *msgid);
+reply_item *reply_cache_latest_from (session *sess, const char *nick);
+void reply_state_set (session *sess, const char *msgid, const char *target,
+							 const char *nick, const char *text);
+void reply_state_clear (session *sess);
 void clear_channel (session *sess);
 void set_topic (session *sess, char *topic, char *stripped_topic);
 void inbound_privmsg (server *serv, char *from, char *ip, char *text, int id, 

src/common/modes.c

@@ -907,6 +907,10 @@ inbound_005 (server * serv, char *word[], const message_tags_data *tags_data)
 		{
 			if (g_strcmp0 (tokvalue, "ascii") == 0)
 				serv->p_cmp = (void *)g_ascii_strcasecmp;
+		} else if (g_strcmp0 (tokname, "CLIENTTAGDENY") == 0)
+		{
+			g_free (serv->clienttagdeny);
+			serv->clienttagdeny = tokadding ? g_strdup (tokvalue) : NULL;
 		} else if (g_strcmp0 (tokname, "CHARSET") == 0)
 		{
 			if (g_ascii_strcasecmp (tokvalue, "UTF-8") == 0)

src/common/outbound.c

@@ -2744,8 +2744,8 @@ cmd_me (struct session *sess, char *tbuf, char *word[], char *word_eol[])
 			while ((split_text = split_up_text (sess, act + offset, cmd_length, split_text)))
 			{
 				sess->server->p_action (sess->server, sess->channel, split_text);
-				/* print it to screen */
+				if (!sess->server->have_echo_message)
-				inbound_action (sess, sess->channel, sess->server->nick, "",
+					inbound_action (sess, sess->channel, sess->server->nick, "",
 									 split_text, TRUE, FALSE,
 									 &no_tags);
 
@@ -2756,8 +2756,8 @@ cmd_me (struct session *sess, char *tbuf, char *word[], char *word_eol[])
 			}
 
 			sess->server->p_action (sess->server, sess->channel, act + offset);
-			/* print it to screen */
+			if (!sess->server->have_echo_message)
-			inbound_action (sess, sess->channel, sess->server->nick, "",
+				inbound_action (sess, sess->channel, sess->server->nick, "",
 								 act + offset, TRUE, FALSE, &no_tags);
 		} else
 		{
@@ -2821,6 +2821,137 @@ cmd_mop (struct session *sess, char *tbuf, char *word[], char *word_eol[])
 	return TRUE;
 }
 
+
+static gboolean
+client_tag_allowed (server *serv, const char *tag)
+{
+	char **deny;
+	int i;
+
+	if (!serv->have_message_tags)
+		return FALSE;
+
+	if (!serv->clienttagdeny || !*serv->clienttagdeny)
+		return TRUE;
+
+	deny = g_strsplit (serv->clienttagdeny, ",", 0);
+	for (i = 0; deny[i]; i++)
+	{
+		if (!strcmp (deny[i], "*") || !strcmp (deny[i], tag) || (deny[i][0] == '+' && !strcmp (deny[i] + 1, tag)))
+		{
+			g_strfreev (deny);
+			return FALSE;
+		}
+	}
+
+	g_strfreev (deny);
+	return TRUE;
+}
+
+static char *
+client_tag_escape (const char *text)
+{
+	GString *out;
+	const char *p;
+
+	out = g_string_sized_new (strlen (text));
+	for (p = text; *p; p++)
+	{
+		switch (*p)
+		{
+		case ';':
+			g_string_append (out, "\\:");
+			break;
+		case ' ':
+			g_string_append (out, "\\s");
+			break;
+		case '\\':
+			g_string_append (out, "\\\\");
+			break;
+		case '\r':
+			g_string_append (out, "\\r");
+			break;
+		case '\n':
+			g_string_append (out, "\\n");
+			break;
+		default:
+			g_string_append_c (out, *p);
+			break;
+		}
+	}
+
+	return g_string_free (out, FALSE);
+}
+
+static int
+cmd_reply (struct session *sess, char *tbuf, char *word[], char *word_eol[])
+{
+	char *msgid = word[2];
+	char *target = sess->channel;
+	char *text = word_eol[3];
+	char *escaped;
+	char *tags;
+
+	if (!reply_msgid_valid (msgid) || !*target || !*text)
+		return FALSE;
+
+	if (*text == ':')
+		text++;
+
+	if (!sess->server->connected || !client_tag_allowed (sess->server, "reply"))
+	{
+		notc_msg (sess);
+		return TRUE;
+	}
+
+	escaped = client_tag_escape (msgid);
+	tags = g_strdup_printf ("+reply=%s", escaped);
+	sess->server->p_message_tagged (sess->server, tags, target, text);
+	if (!sess->server->have_echo_message)
+	{
+		session *target_sess = find_dialog (sess->server, target);
+		message_tags_data no_tags = MESSAGE_TAGS_DATA_INIT;
+		no_tags.reply = msgid;
+
+		if (!target_sess)
+			target_sess = find_channel (sess->server, target);
+		if (target_sess)
+			inbound_chanmsg (target_sess->server, target_sess, target_sess->channel, target_sess->server->nick, text, TRUE, FALSE, &no_tags);
+	}
+	g_free (tags);
+	g_free (escaped);
+
+	return TRUE;
+}
+
+static int
+cmd_typing (struct session *sess, char *tbuf, char *word[], char *word_eol[])
+{
+	char *state = word[2];
+	char *target = word[3];
+	char tags[32];
+
+	if (!*state)
+		state = "active";
+
+	if (!*target)
+		target = sess->channel;
+
+	if (!*target || (strcmp (state, "active") && strcmp (state, "paused") && strcmp (state, "done")))
+		return FALSE;
+
+	if (!sess->server->connected || !client_tag_allowed (sess->server, "typing"))
+	{
+		notc_msg (sess);
+		return TRUE;
+	}
+
+	g_snprintf (tags, sizeof (tags), "+typing=%s", state);
+	sess->server->p_tagmsg (sess->server, tags, target);
+
+	return TRUE;
+}
+
 static int
 cmd_msg (struct session *sess, char *tbuf, char *word[], char *word_eol[])
 {
@@ -2875,7 +3006,7 @@ cmd_msg (struct session *sess, char *tbuf, char *word[], char *word_eol[])
 			newsess = find_dialog (sess->server, nick);
 			if (!newsess)
 				newsess = find_channel (sess->server, nick);
-			if (newsess)
+			if (newsess && !sess->server->have_echo_message)
 			{
 				message_tags_data no_tags = MESSAGE_TAGS_DATA_INIT;
 
@@ -4139,9 +4270,11 @@ const struct commands xc_cmds[] = {
 #endif
 	{"RECV", cmd_recv, 1, 0, 1, N_("RECV <text>, send raw data to ZoiteChat, as if it was received from the IRC server")},
 	{"RELOAD", cmd_reload, 0, 0, 1, N_("RELOAD <name>, reloads a plugin or script")},
+	{"REPLY", cmd_reply, 0, 0, 1, N_("REPLY <msgid> <message>, sends a reply-tagged message to the current channel or dialog")},
 	{"SAY", cmd_say, 0, 0, 1,
 	 N_("SAY <text>, sends the text to the object in the current window")},
 	{"SEND", cmd_send, 0, 0, 1, N_("SEND <nick> [<file>]")},
+	{"TYPING", cmd_typing, 0, 0, 1, N_("TYPING [active|paused|done] [target], sends a typing notification")},
 #ifdef USE_OPENSSL
 	{"SERVCHAN", cmd_servchan, 0, 0, 1,
 	 N_("SERVCHAN [-noproxy] [-insecure|-ssl|-ssl-noverify] <host> <port> <channel>, connects and joins a channel using ssl unless otherwise specified")},
@@ -4674,8 +4807,9 @@ handle_say (session *sess, char *text, int check_spch)
 
 		while ((split_text = split_up_text (sess, text + offset, cmd_length, split_text)))
 		{
-			inbound_chanmsg (sess->server, sess, sess->channel, sess->server->nick,
+			if (!sess->server->have_echo_message)
-								  split_text, TRUE, FALSE, &no_tags);
+				inbound_chanmsg (sess->server, sess, sess->channel, sess->server->nick,
+									  split_text, TRUE, FALSE, &no_tags);
 			sess->server->p_message (sess->server, sess->channel, split_text);
 			
 			if (*split_text)
@@ -4684,7 +4818,8 @@ handle_say (session *sess, char *text, int check_spch)
 			g_free (split_text);
 		}
 
-		inbound_chanmsg (sess->server, sess, sess->channel, sess->server->nick,
+		if (!sess->server->have_echo_message)
+			inbound_chanmsg (sess->server, sess, sess->channel, sess->server->nick,
 							  text + offset, TRUE, FALSE, &no_tags);
 		sess->server->p_message (sess->server, sess->channel, text + offset);
 	} else

src/common/proto-irc.c

@@ -362,6 +362,18 @@ irc_message (server *serv, char *channel, char *text)
 	tcp_sendf (serv, "PRIVMSG %s :%s\r\n", channel, text);
 }
 
+static void
+irc_message_tagged (server *serv, char *tags, char *channel, char *text)
+{
+	tcp_sendf (serv, "@%s PRIVMSG %s :%s\r\n", tags, channel, text);
+}
+
+static void
+irc_tagmsg (server *serv, char *tags, char *target)
+{
+	tcp_sendf (serv, "@%s TAGMSG %s\r\n", tags, target);
+}
+
 static void
 irc_action (server *serv, char *channel, char *act)
 {
@@ -425,7 +437,7 @@ static int
 irc_raw (server *serv, char *raw)
 {
 	int len;
-	char tbuf[4096];
+	char tbuf[8704];
 	if (*raw)
 	{
 		len = strlen (raw);
@@ -1009,6 +1021,40 @@ process_numeric (session * sess, int n,
 
 /* handle named messages that starts with a ':' */
 
+
+static void
+emit_standard_reply (session *sess, const char *type, char *command, char *code, char *text, const message_tags_data *tags_data)
+{
+	int is_global = g_strcmp0 (command, "*") == 0;
+
+	if (!text)
+		text = "";
+	if (*text == ':')
+		text++;
+
+	if (!strcmp (type, "FAIL"))
+	{
+		if (is_global)
+			EMIT_SIGNAL_TIMESTAMP (XP_TE_FAIL, sess, code, text, NULL, NULL, NULL, tags_data->timestamp);
+		else
+			EMIT_SIGNAL_TIMESTAMP (XP_TE_FAILCMD, sess, command, code, text, NULL, NULL, tags_data->timestamp);
+	}
+	else if (!strcmp (type, "WARN"))
+	{
+		if (is_global)
+			EMIT_SIGNAL_TIMESTAMP (XP_TE_WARN, sess, code, text, NULL, NULL, NULL, tags_data->timestamp);
+		else
+			EMIT_SIGNAL_TIMESTAMP (XP_TE_WARNCMD, sess, command, code, text, NULL, NULL, tags_data->timestamp);
+	}
+	else if (!strcmp (type, "NOTE"))
+	{
+		if (is_global)
+			EMIT_SIGNAL_TIMESTAMP (XP_TE_NOTE, sess, code, text, NULL, NULL, NULL, tags_data->timestamp);
+		else
+			EMIT_SIGNAL_TIMESTAMP (XP_TE_NOTECMD, sess, command, code, text, NULL, NULL, tags_data->timestamp);
+	}
+}
+
 static void
 process_named_msg (session *sess, char *type, char *word[], char *word_eol[],
 						 const message_tags_data *tags_data)
@@ -1335,6 +1381,29 @@ process_named_msg (session *sess, char *type, char *word[], char *word_eol[],
 									tags_data);
 			return;
 
+		case WORDL('T','A','G','M'):
+			if (tags_data->typing)
+			{
+				session *typing_sess = NULL;
+				char *to = word[3];
+
+				if (is_channel (serv, to))
+					typing_sess = find_channel (serv, to);
+				else if (!serv->p_cmp (to, serv->nick))
+					typing_sess = find_dialog (serv, nick);
+				if (!typing_sess)
+					typing_sess = sess;
+				if (!serv->p_cmp (nick, serv->nick))
+					return;
+				if (!strcmp (tags_data->typing, "done"))
+					fe_set_typing (typing_sess, nick, "done");
+				else if (!strcmp (tags_data->typing, "paused"))
+					fe_set_typing (typing_sess, nick, "paused");
+				else if (!strcmp (tags_data->typing, "active"))
+					fe_set_typing (typing_sess, nick, "active");
+			}
+			return;
+
 		case WORDL('W','A','L','L'):
 			text = word_eol[3];
 			if (*text == ':')
@@ -1431,6 +1500,11 @@ process_named_servermsg (session *sess, char *buf, char *rawname, char *word_eol
 		inbound_sasl_authenticate (sess->server, word_eol[2]);
 		return;
 	}
+	if (!strncmp (buf, "FAIL ", 5) || !strncmp (buf, "WARN ", 5) || !strncmp (buf, "NOTE ", 5))
+	{
+		emit_standard_reply (sess, word_eol[1], word_eol[2], word_eol[3], word_eol[4], tags_data);
+		return;
+	}
 
 	EMIT_SIGNAL_TIMESTAMP (XP_TE_SERVTEXT, sess, buf, sess->server->servername,
 								  rawname, NULL, 0, tags_data->timestamp);
@@ -1533,39 +1607,130 @@ handle_message_tag_time (const char *time, message_tags_data *tags_data)
  *
  * See http://ircv3.atheme.org/specification/message-tags-3.2 
  */
+static char *
+message_tag_unescape (const char *value)
+{
+	GString *out;
+	const char *p;
+
+	if (!*value)
+		return NULL;
+
+	out = g_string_sized_new (strlen (value));
+
+	for (p = value; *p; p++)
+	{
+		if (*p != '\\')
+		{
+			g_string_append_c (out, *p);
+			continue;
+		}
+
+		p++;
+		if (!*p)
+			break;
+
+		switch (*p)
+		{
+		case ':':
+			g_string_append_c (out, ';');
+			break;
+		case 's':
+			g_string_append_c (out, ' ');
+			break;
+		case '\\':
+			g_string_append_c (out, '\\');
+			break;
+		case 'r':
+			g_string_append_c (out, '\r');
+			break;
+		case 'n':
+			g_string_append_c (out, '\n');
+			break;
+		default:
+			g_string_append_c (out, *p);
+			break;
+		}
+	}
+
+	value = out->str;
+	if (!g_utf8_validate (value, -1, NULL))
+	{
+		g_string_free (out, TRUE);
+		return NULL;
+	}
+
+	return g_string_free (out, FALSE);
+}
+
 static void
 handle_message_tags (server *serv, const char *tags_str,
 							message_tags_data *tags_data)
 {
 	char **tags;
+	char *time = NULL;
 	int i;
 
-	/* FIXME We might want to avoid the allocation overhead here since 
-	 * this might be called for every message from the server.
-	 */
 	tags = g_strsplit (tags_str, ";", 0);
 
-	for (i=0; tags[i]; i++)
+	for (i = 0; tags[i]; i++)
 	{
 		char *key = tags[i];
-		char *value = strchr (tags[i], '=');
+		char *raw_value = strchr (tags[i], '=');
+		char *value = NULL;
 
-		if (!value)
+		if (!*key)
 			continue;
 
-		*value = '\0';
+		if (raw_value)
-		value++;
+		{
+			*raw_value = '\0';
+			raw_value++;
+			value = message_tag_unescape (raw_value);
+		}
 
 		if (serv->have_account_tag && !strcmp (key, "account"))
-			tags_data->account = g_strdup (value);
+		{
-
+			g_free (tags_data->account);
-		if (serv->have_idmsg && strcmp (key, "solanum.chat/identified"))
+			tags_data->account = value;
+			value = NULL;
+		}
+		else if (serv->have_idmsg && !strcmp (key, "solanum.chat/identified"))
+		{
 			tags_data->identified = TRUE;
+		}
+		else if (serv->have_server_time && !strcmp (key, "time"))
+		{
+			g_free (time);
+			time = value;
+			value = NULL;
+		}
+		else if (!strcmp (key, "msgid"))
+		{
+			g_free (tags_data->msgid);
+			tags_data->msgid = value;
+			value = NULL;
+		}
+		else if (!strcmp (key, "+reply"))
+		{
+			g_free (tags_data->reply);
+			tags_data->reply = value;
+			value = NULL;
+		}
+		else if (!strcmp (key, "+typing"))
+		{
+			g_free (tags_data->typing);
+			tags_data->typing = value;
+			value = NULL;
+		}
 
-		if (serv->have_server_time && !strcmp (key, "time"))
+		g_free (value);
-			handle_message_tag_time (value, tags_data);
 	}
 
+	if (time)
+		handle_message_tag_time (time, tags_data);
+
+	g_free (time);
 	g_strfreev (tags);
 }
 
@@ -1667,6 +1832,9 @@ void
 message_tags_data_free (message_tags_data *tags_data)
 {
 	g_clear_pointer (&tags_data->account, g_free);
+	g_clear_pointer (&tags_data->msgid, g_free);
+	g_clear_pointer (&tags_data->reply, g_free);
+	g_clear_pointer (&tags_data->typing, g_free);
 }
 
 void
@@ -1696,6 +1864,8 @@ proto_fill_her_up (server *serv)
 	serv->p_set_back = irc_set_back;
 	serv->p_set_away = irc_set_away;
 	serv->p_message = irc_message;
+	serv->p_message_tagged = irc_message_tagged;
+	serv->p_tagmsg = irc_tagmsg;
 	serv->p_action = irc_action;
 	serv->p_notice = irc_notice;
 	serv->p_topic = irc_topic;

src/common/proto-irc.h

@@ -28,6 +28,9 @@
 		NULL, /* account name */		\
 		FALSE, /* identified to nick */ \
 		(time_t)0, /* timestamp */		\
+		NULL,						\
+		NULL,						\
+		NULL,						\
 	}
 
 #define STRIP_COLON(word, word_eol, idx) (word)[(idx)][0] == ':' ? (word_eol)[(idx)]+1 : (word)[(idx)]
@@ -41,6 +44,9 @@ typedef struct
 	char *account;
 	gboolean identified;
 	time_t timestamp;
+	char *msgid;
+	char *reply;
+	char *typing;
 } message_tags_data;
 
 void message_tags_data_free (message_tags_data *tags_data);

src/common/server.c

@@ -1821,6 +1821,7 @@ void
 server_set_defaults (server *serv)
 {
 	g_free (serv->chantypes);
+	g_clear_pointer (&serv->clienttagdeny, g_free);
 	g_free (serv->chanmodes);
 	g_free (serv->nick_prefixes);
 	g_free (serv->nick_modes);
@@ -1855,6 +1856,8 @@ server_set_defaults (server *serv)
 	serv->have_extjoin = FALSE;
 	serv->have_account_tag = FALSE;
 	serv->have_server_time = FALSE;
+	serv->have_message_tags = FALSE;
+	serv->have_echo_message = FALSE;
 	serv->have_sasl = FALSE;
 	serv->have_except = FALSE;
 	serv->have_invite = FALSE;
@@ -1985,6 +1988,7 @@ server_free (server *serv)
 	g_free (serv->nick_prefixes);
 	g_free (serv->chanmodes);
 	g_free (serv->chantypes);
+	g_free (serv->clienttagdeny);
 	g_free (serv->bad_nick_prefixes);
 	g_free (serv->last_away_reason);
 	g_free (serv->encoding);

src/common/userlist.h

@@ -31,6 +31,7 @@ struct User
 	char *servername;
 	char *account;
 	time_t lasttalk;
+	time_t typing_time;
 	unsigned int access;	/* axs bit field */
 	char prefix[2]; /* @ + % */
 	unsigned int op:1;
@@ -39,6 +40,7 @@ struct User
 	unsigned int me:1;
 	unsigned int away:1;
 	unsigned int selected:1;
+	unsigned int typing:2;
 };
 
 #define USERACCESS_SIZE 12

src/common/zoitechat.c

@@ -793,7 +793,13 @@ session_free (session *killsess)
 
 	send_quit_or_part (killsess);
 
+	if (killsess->typing_timeout_tag)
+		fe_timeout_remove (killsess->typing_timeout_tag);
+	if (killsess->typing_animation_tag)
+		fe_timeout_remove (killsess->typing_animation_tag);
+
 	history_free (&killsess->history);
+	reply_cache_free (killsess);
 	g_free (killsess->topic);
 	g_free (killsess->current_modes);
 

src/common/zoitechat.h

@@ -388,6 +388,14 @@ typedef enum {
 	TAB_STATE_NEW_HILIGHT = (1 << 2),
 } tab_state_flags;
 
+typedef struct reply_item
+{
+	char *msgid;
+	char *nick;
+	char *text;
+	time_t timestamp;
+} reply_item;
+
 typedef struct session
 {
 	/* Per-Channel Alerts */
@@ -429,8 +437,17 @@ typedef struct session
 	char *quitreason;
 	char *topic;
 	char *current_modes;					/* free() me */
+	GSList *reply_items;
+	char *reply_msgid;
+	char *reply_target;
+	char *reply_nick;
+	char *reply_text;
 
 	int mode_timeout_tag;
+	int typing_timeout_tag;
+	int typing_status;
+	int typing_animation_tag;
+	int typing_animation_frame;
 
 	struct session *lastlog_sess;
 	struct nbexec *running_exec;
@@ -494,6 +511,8 @@ typedef struct server
 	void (*p_set_back)(struct server *);
 	void (*p_set_away)(struct server *, char *reason);
 	void (*p_message)(struct server *, char *channel, char *text);
+	void (*p_message_tagged)(struct server *, char *tags, char *channel, char *text);
+	void (*p_tagmsg)(struct server *, char *tags, char *target);
 	void (*p_action)(struct server *, char *channel, char *act);
 	void (*p_notice)(struct server *, char *channel, char *text);
 	void (*p_topic)(struct server *, char *channel, char *topic);
@@ -543,6 +562,7 @@ typedef struct server
 	int loginmethod;					/* see login_types[] */
 
 	char *chantypes;					/* for 005 numeric - free me */
+	char *clienttagdeny;
 	char *chanmodes;					/* for 005 numeric - free me */
 	char *nick_prefixes;				/* e.g. "*@%+" */
 	char *nick_modes;					/* e.g. "aohv" */
@@ -605,6 +625,8 @@ typedef struct server
 	unsigned int have_extjoin:1;	/* cap extended-join */
 	unsigned int have_account_tag:1;	/* cap account-tag */
 	unsigned int have_server_time:1;	/* cap server-time */
+	unsigned int have_message_tags:1;
+	unsigned int have_echo_message:1;
 	unsigned int have_sasl:1;		/* SASL capability */
 	unsigned int have_except:1;	/* ban exemptions +e */
 	unsigned int have_invite:1;	/* invite exemptions +I */

src/fe-gtk/fe-gtk.h

@@ -163,6 +163,8 @@ typedef struct session_gui
 		*op_xpm,			/* icon to the left of nickname */
 		*namelistinfo,	/* label above userlist */
 		*input_box,
+		*reply_box,
+		*reply_label,
 		*flag_wid[NUM_FLAG_WIDS],		/* channelmode buttons */
 		*limit_entry,		  /* +l */
 		*key_entry;		  /* +k */

src/fe-gtk/maingui.c

@@ -173,6 +173,7 @@ enum
 #define TAG_UTIL 1      /* dcc, notify, chanlist */
 
 static void mg_apply_emoji_fallback_widget (GtkWidget *widget);
+static void mg_reply_show_child (GtkWidget *widget, gpointer data);
 
 #define MG_CONFIG_SAVE_DEBOUNCE_MS 250
 
@@ -731,6 +732,164 @@ mg_inputbox_focus (GtkWidget *widget, GdkEventFocus *event, session_gui *gui)
         return FALSE;
 }
 
+
+static gboolean
+mg_client_tag_allowed (server *serv, const char *tag)
+{
+        char **deny;
+        int i;
+
+        if (!serv->have_message_tags)
+                return FALSE;
+
+        if (!serv->clienttagdeny || !*serv->clienttagdeny)
+                return TRUE;
+
+        deny = g_strsplit (serv->clienttagdeny, ",", 0);
+        for (i = 0; deny[i]; i++)
+        {
+                if (!strcmp (deny[i], "*") || !strcmp (deny[i], tag) || (deny[i][0] == '+' && !strcmp (deny[i] + 1, tag)))
+                {
+                        g_strfreev (deny);
+                        return FALSE;
+                }
+        }
+
+        g_strfreev (deny);
+        return TRUE;
+}
+
+static void
+mg_send_typing (session *sess, const char *state)
+{
+        char tags[32];
+
+        if (!sess || !sess->server->connected || !mg_client_tag_allowed (sess->server, "typing") || !sess->channel[0])
+                return;
+
+        if (sess->type != SESS_CHANNEL && sess->type != SESS_DIALOG)
+                return;
+
+        g_snprintf (tags, sizeof (tags), "+typing=%s", state);
+        sess->server->p_tagmsg (sess->server, tags, sess->channel);
+}
+
+static int
+mg_typing_pause_cb (session *sess)
+{
+        sess->typing_timeout_tag = 0;
+        if (sess->typing_status == 1)
+        {
+                mg_send_typing (sess, "paused");
+                sess->typing_status = 2;
+        }
+        return 0;
+}
+
+static void
+mg_typing_update (session *sess, const char *text)
+{
+        if (!sess)
+                return;
+
+        if (sess->typing_timeout_tag)
+        {
+                fe_timeout_remove (sess->typing_timeout_tag);
+                sess->typing_timeout_tag = 0;
+        }
+
+        if (!text || !*text || text[0] == prefs.hex_input_command_char[0])
+        {
+                if (sess->typing_status)
+                        mg_send_typing (sess, "done");
+                sess->typing_status = 0;
+                return;
+        }
+
+        if (sess->typing_status != 1)
+        {
+                mg_send_typing (sess, "active");
+                sess->typing_status = 1;
+        }
+        sess->typing_timeout_tag = fe_timeout_add_seconds (6, mg_typing_pause_cb, sess);
+}
+
+
+static void
+mg_reply_show_child (GtkWidget *widget, gpointer data)
+{
+	gtk_widget_show (widget);
+}
+
+void
+mg_reply_update (session *sess)
+{
+	char *nick;
+	char *text;
+	char *markup;
+
+	if (!sess || !sess->gui || !sess->gui->reply_box || !sess->gui->reply_label)
+		return;
+
+	if (!sess->reply_msgid)
+	{
+		gtk_widget_hide (sess->gui->reply_box);
+		return;
+	}
+
+	nick = g_markup_escape_text (sess->reply_nick ? sess->reply_nick : _("message"), -1);
+	text = g_markup_escape_text (sess->reply_text ? sess->reply_text : _("Original message unavailable"), -1);
+	markup = g_strdup_printf ("<span foreground='#7d8790'>↪ Replying to <b>%s</b> · %.160s</span>", nick, text);
+	gtk_label_set_markup (GTK_LABEL (sess->gui->reply_label), markup);
+	gtk_container_foreach (GTK_CONTAINER (sess->gui->reply_box), mg_reply_show_child, NULL);
+	gtk_widget_show (sess->gui->reply_box);
+	g_free (markup);
+	g_free (text);
+	g_free (nick);
+}
+
+static void
+mg_reply_cancel_cb (GtkWidget *wid, session *sess)
+{
+	reply_state_clear (sess);
+	mg_reply_update (sess);
+}
+
+static void
+mg_send_reply_or_text (session *sess, char *cmd)
+{
+	char *reply_cmd;
+
+	if (!sess->reply_msgid || cmd[0] == prefs.hex_input_command_char[0])
+	{
+		handle_multiline (sess, cmd, TRUE, FALSE);
+		return;
+	}
+
+	if (!sess->server->connected || !mg_client_tag_allowed (sess->server, "reply"))
+	{
+		PrintText (sess, _("Replies are not supported on this server. Sending normally.\n"));
+		reply_state_clear (sess);
+		mg_reply_update (sess);
+		handle_multiline (sess, cmd, TRUE, FALSE);
+		return;
+	}
+
+	reply_cmd = g_strdup_printf ("%cREPLY %s %s", prefs.hex_input_command_char[0], sess->reply_msgid, cmd);
+	handle_multiline (sess, reply_cmd, TRUE, FALSE);
+	g_free (reply_cmd);
+	reply_state_clear (sess);
+	mg_reply_update (sess);
+}
+
+static void
+mg_inputbox_changed (GtkEditable *editable, session_gui *gui)
+{
+        key_check_replace_on_change (editable, NULL);
+        if (current_sess && current_sess->gui == gui)
+                mg_typing_update (current_sess, gtk_entry_get_text (GTK_ENTRY (editable)));
+}
+
 void
 mg_inputbox_cb (GtkWidget *igad, session_gui *gui)
 {
@@ -772,7 +931,7 @@ mg_inputbox_cb (GtkWidget *igad, session_gui *gui)
         }
 
         if (sess)
-                handle_multiline (sess, cmd, TRUE, FALSE);
+                mg_send_reply_or_text (sess, cmd);
 
         g_free (cmd);
 }
@@ -4541,6 +4700,20 @@ mg_create_entry (session *sess, GtkWidget *box)
         };
         const char *emoji_fallback_icon_name;
 
+        gui->reply_box = mg_box_new (GTK_ORIENTATION_HORIZONTAL, FALSE, 6);
+        gtk_widget_set_name (gui->reply_box, "zoitechat-replybar");
+        gtk_widget_set_no_show_all (gui->reply_box, TRUE);
+        gtk_box_pack_start (GTK_BOX (box), gui->reply_box, 0, 0, 0);
+        gui->reply_label = gtk_label_new ("");
+        gtk_label_set_ellipsize (GTK_LABEL (gui->reply_label), PANGO_ELLIPSIZE_END);
+        gtk_box_pack_start (GTK_BOX (gui->reply_box), gui->reply_label, TRUE, TRUE, 8);
+        but = gtk_button_new_with_label ("×");
+        gtk_button_set_relief (GTK_BUTTON (but), GTK_RELIEF_NONE);
+        gtk_widget_set_can_focus (but, FALSE);
+        gtk_box_pack_start (GTK_BOX (gui->reply_box), but, FALSE, FALSE, 0);
+        g_signal_connect (G_OBJECT (but), "clicked", G_CALLBACK (mg_reply_cancel_cb), sess);
+        gtk_widget_hide (gui->reply_box);
+
         hbox = mg_box_new (GTK_ORIENTATION_HORIZONTAL, FALSE, 0);
         gtk_box_pack_start (GTK_BOX (box), hbox, 0, 0, 0);
 
@@ -4562,7 +4735,7 @@ mg_create_entry (session *sess, GtkWidget *box)
         g_signal_connect (G_OBJECT (entry), "activate",
                                                         G_CALLBACK (mg_inputbox_cb), gui);
         g_signal_connect (G_OBJECT (entry), "changed",
-                                                        G_CALLBACK (key_check_replace_on_change), NULL);
+                                                        G_CALLBACK (mg_inputbox_changed), gui);
         gtk_box_pack_start (GTK_BOX (hbox), entry, TRUE, TRUE, 0);
 
         gtk_widget_set_name (entry, "zoitechat-inputbox");
@@ -5194,6 +5367,12 @@ fe_set_channel (session *sess)
                 chan_rename (sess->res->tab, sess->channel, prefs.hex_gui_tab_trunc);
 }
 
+void
+fe_set_typing (session *sess, const char *nick, const char *state)
+{
+        fe_userlist_set_typing (sess, nick, state);
+}
+
 void
 mg_changui_new (session *sess, restore_gui *res, int tab, int focus)
 {

src/fe-gtk/maingui.h

@@ -48,6 +48,7 @@ void mg_dnd_drop_file (session *sess, char *target, char *uri);
 void mg_change_layout (int type);
 void mg_update_meters (session_gui *);
 void mg_inputbox_cb (GtkWidget *igad, session_gui *gui);
+void mg_reply_update (session *sess);
 void mg_create_icon_item (char *label, char *stock, GtkWidget *menu, void *callback, void *userdata);
 GtkWidget *mg_submenu (GtkWidget *menu, char *text);
 /* DND */

src/fe-gtk/menu.c

@@ -36,6 +36,7 @@
 #include "../common/zoitechatc.h"
 #include "../common/cfgfiles.h"
 #include "../common/outbound.h"
+#include "../common/inbound.h"
 #include "../common/ignore.h"
 #include "../common/fe.h"
 #include "../common/server.h"
@@ -784,6 +785,25 @@ fe_userlist_update (session *sess, struct User *user)
 	}
 }
 
+
+static void
+menu_reply_to_latest_cb (GtkWidget *wid, gpointer data)
+{
+	reply_item *item;
+
+	item = reply_cache_latest_from (current_sess, str_copy);
+	if (!item)
+	{
+		PrintText (current_sess, _("No recent message to reply to.\n"));
+		return;
+	}
+
+	reply_state_set (current_sess, item->msgid, current_sess->channel, item->nick, item->text);
+	mg_reply_update (current_sess);
+	if (current_sess->gui && current_sess->gui->input_box)
+		gtk_widget_grab_focus (current_sess->gui->input_box);
+}
+
 void
 menu_nickmenu (session *sess, GdkEventButton *event, char *nick, int num_sel)
 {
@@ -827,6 +847,12 @@ menu_nickmenu (session *sess, GdkEventButton *event, char *nick, int num_sel)
 	else
 		menu_create (menu, popup_list, str_copy, FALSE);
 
+	if (num_sel <= 1)
+	{
+		menu_quick_item_with_callback (menu_reply_to_latest_cb, _("Reply"), menu, 0);
+		menu_quick_item (0, 0, menu, XCMENU_SHADED, 0, 0);
+	}
+
 	if (num_sel == 0)	/* xtext click */
 		menu_add_plugin_items (menu, "\x5$NICK", str_copy);
 	else	/* userlist treeview click */

src/fe-gtk/userlistgui.c

@@ -19,6 +19,7 @@
 #include <stdio.h>
 #include <string.h>
 #include <stdlib.h>
+#include <time.h>
 
 #include "fe-gtk.h"
 
@@ -53,6 +54,36 @@ enum
 
 static void userlist_store_color (GtkListStore *store, GtkTreeIter *iter, ThemeSemanticToken token, gboolean has_token);
 
+static const char *
+userlist_typing_suffix (session *sess, struct User *user)
+{
+	static const char *active[] = { " [✎]", " [✎.]", " [✎..]" };
+
+	if (!user || !user->typing)
+		return "";
+
+	if (user->typing == 2)
+		return " [✎…]";
+
+	return active[sess->typing_animation_frame % G_N_ELEMENTS (active)];
+}
+
+static char *
+userlist_nick_markup (session *sess, struct User *user)
+{
+	char *nick = g_markup_escape_text (user->nick, -1);
+	const char *typing = userlist_typing_suffix (sess, user);
+
+	if (*typing)
+	{
+		char *marked = g_strdup_printf ("%s%s", nick, typing);
+		g_free (nick);
+		return marked;
+	}
+
+	return nick;
+}
+
 static const char *
 userlist_prefix_color (char prefix)
 {
@@ -463,6 +494,87 @@ fe_userlist_remove (session *sess, struct User *user)
 	return sel;
 }
 
+
+static gboolean
+userlist_typing_tick (session *sess)
+{
+	GtkTreeModel *model;
+	GtkTreeIter iter;
+	gboolean valid;
+	gboolean keep = FALSE;
+	time_t now = time (NULL);
+
+	if (!sess || !sess->res || !sess->res->user_model)
+		return FALSE;
+
+	sess->typing_animation_frame++;
+	model = GTK_TREE_MODEL (sess->res->user_model);
+	valid = gtk_tree_model_get_iter_first (model, &iter);
+
+	while (valid)
+	{
+		struct User *user = NULL;
+
+		gtk_tree_model_get (model, &iter, COL_USER, &user, -1);
+		if (user && user->typing)
+		{
+			char *nick;
+
+			if ((user->typing == 1 && now - user->typing_time >= 6) || (user->typing == 2 && now - user->typing_time >= 30))
+				user->typing = 0;
+
+			nick = userlist_nick_markup (sess, user);
+			gtk_list_store_set (sess->res->user_model, &iter, COL_NICK, nick, -1);
+			g_free (nick);
+			if (user->typing)
+				keep = TRUE;
+		}
+		valid = gtk_tree_model_iter_next (model, &iter);
+	}
+
+	if (!keep)
+	{
+		sess->typing_animation_tag = 0;
+		return FALSE;
+	}
+
+	return TRUE;
+}
+
+void
+fe_userlist_set_typing (session *sess, const char *nick, const char *state)
+{
+	struct User *user;
+	GtkTreeIter *iter;
+	int sel;
+
+	if (!sess || !nick || !sess->res || !sess->res->user_model)
+		return;
+
+	user = userlist_find (sess, nick);
+	if (!user)
+		return;
+
+	if (!strcmp (state, "active"))
+		user->typing = 1;
+	else if (!strcmp (state, "paused"))
+		user->typing = 2;
+	else
+		user->typing = 0;
+	user->typing_time = time (NULL);
+
+	iter = find_row (sess, GTK_TREE_VIEW (sess->gui->user_tree), GTK_TREE_MODEL (sess->res->user_model), user, &sel);
+	if (iter)
+	{
+		char *nick = userlist_nick_markup (sess, user);
+		gtk_list_store_set (sess->res->user_model, iter, COL_NICK, nick, -1);
+		g_free (nick);
+	}
+
+	if (user->typing && !sess->typing_animation_tag)
+		sess->typing_animation_tag = fe_timeout_add (350, userlist_typing_tick, sess);
+}
+
 void
 fe_userlist_rehash (session *sess, struct User *user)
 {
@@ -493,9 +605,14 @@ fe_userlist_rehash (session *sess, struct User *user)
 		}
 	}
 
-	gtk_list_store_set (GTK_LIST_STORE (sess->res->user_model), iter,
+	{
+		char *nick = userlist_nick_markup (sess, user);
+		gtk_list_store_set (GTK_LIST_STORE (sess->res->user_model), iter,
+							  COL_NICK, nick,
 							  COL_HOST, user->hostname,
 							  -1);
+		g_free (nick);
+	}
 	userlist_store_color (GTK_LIST_STORE (sess->res->user_model), iter, nick_token, have_nick_token);
 }
 
@@ -506,7 +623,6 @@ fe_userlist_insert (session *sess, struct User *newuser, gboolean sel)
 	GdkPixbuf *pix = get_user_icon (sess->server, newuser);
 	GtkTreeIter iter;
 	char *nick;
-	char *nick_escaped;
 	char *prefix = NULL;
 	char *prefix_escaped;
 	char prefix_text[2];
@@ -530,8 +646,7 @@ fe_userlist_insert (session *sess, struct User *newuser, gboolean sel)
 		}
 	}
 
-	nick_escaped = g_markup_escape_text (newuser->nick, -1);
+	nick = userlist_nick_markup (sess, newuser);
-	nick = nick_escaped;
 	if (!prefs.hex_gui_ulist_icons)
 	{
 		if (newuser->prefix[0] != '\0' && newuser->prefix[0] != ' ')
@@ -559,7 +674,7 @@ fe_userlist_insert (session *sess, struct User *newuser, gboolean sel)
 	userlist_store_color (GTK_LIST_STORE (model), &iter, nick_token, have_nick_token);
 
 	g_free (prefix);
-	g_free (nick_escaped);
+	g_free (nick);
 
 	userlist_row_map_set (sess, model, newuser, &iter);
 
@@ -757,6 +872,7 @@ userlist_add_columns (GtkTreeView * treeview)
 	gtk_tree_view_column_pack_start (column, renderer, TRUE);
 	gtk_tree_view_column_add_attribute (column, renderer, "markup", COL_NICK);
 	gtk_tree_view_column_add_attribute (column, renderer, THEME_GTK_FOREGROUND_PROPERTY, COL_GDKCOLOR);
+
 	column = gtk_tree_view_get_column (GTK_TREE_VIEW (treeview), 1);
 	gtk_tree_view_column_set_sizing (column, GTK_TREE_VIEW_COLUMN_FIXED);
 	gtk_tree_view_column_set_expand (column, TRUE);

src/fe-gtk/userlistgui.h

@@ -26,6 +26,7 @@ GtkWidget *userlist_create (GtkWidget *box);
 GtkListStore *userlist_create_model (session *sess);
 void userlist_show (session *sess);
 void userlist_select (session *sess, char *name);
+void fe_userlist_set_typing (session *sess, const char *nick, const char *state);
 char **userlist_selection_list (GtkWidget *widget, int *num_ret);
 GdkPixbuf *get_user_icon (server *serv, struct User *user);
 

src/fe-text/fe-text.c

@@ -647,6 +647,11 @@ void
 fe_set_topic (struct session *sess, char *topic, char *stripped_topic)
 {
 }
+
+void
+fe_set_typing (struct session *sess, const char *nick, const char *state)
+{
+}
 void
 fe_cleanup (void)
 {