1 files changed, 80 insertions, 0 deletions
diff --git a/build/js/jsxc/lib/strophe.chatstates/index.js b/build/js/jsxc/lib/strophe.chatstates/index.js
new file mode 100644
index 0000000..4343b58
--- /dev/null
+++ b/build/js/jsxc/lib/strophe.chatstates/index.js
@@ -0,0 +1,80 @@
+/**
+ * Chat state notifications (XEP 0085) plugin
+ * @see http://xmpp.org/extensions/xep-0085.html
+ */
+Strophe.addConnectionPlugin('chatstates',
+{
+	init: function (connection)
+	{
+		this._connection = connection;
+
+		Strophe.addNamespace('CHATSTATES', 'http://jabber.org/protocol/chatstates');
+	},
+
+	statusChanged: function (status)
+	{
+		if (status === Strophe.Status.CONNECTED
+			|| status === Strophe.Status.ATTACHED)
+		{
+			this._connection.addHandler(this._notificationReceived.bind(this),
+				Strophe.NS.CHATSTATES, "message");
+		}
+	},
+
+	addActive: function(message)
+	{
+		return message.c('active', {xmlns: Strophe.NS.CHATSTATES}).up();
+	},
+
+	_notificationReceived: function(message)
+	{
+		var composing = $(message).find('composing'),
+		paused = $(message).find('paused'),
+		active = $(message).find('active'),
+		jid = $(message).attr('from');
+
+		if (composing.length > 0)
+		{
+			$(document).trigger('composing.chatstates', jid);
+		}
+
+		if (paused.length > 0)
+		{
+			$(document).trigger('paused.chatstates', jid);
+		}
+
+		if (active.length > 0)
+		{
+			$(document).trigger('active.chatstates', jid);
+		}
+
+		return true;
+	},
+
+	sendActive: function(jid, type)
+	{
+		this._sendNotification(jid, type, 'active');
+	},
+
+	sendComposing: function(jid, type)
+	{
+		this._sendNotification(jid, type, 'composing');
+	},
+
+	sendPaused: function(jid, type)
+	{
+		this._sendNotification(jid, type, 'paused');
+	},
+
+	_sendNotification: function(jid, type, notification)
+	{
+		if (!type) type = 'chat';
+
+		this._connection.send($msg(
+		{
+			to: jid,
+			type: type
+		})
+		.c(notification, {xmlns: Strophe.NS.CHATSTATES}));
+	}
+});