XMPP implementation in JavaScript.

remoting/webapp/unittests/xmpp_stream_parser_unittest.js

+// Copyright 2014 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+(function() {
+
+'use strict';
+
+var onStanzaStr = null;
+var onError = null;
+var parser = null;
+
+module('XmppStreamParser', {
+  setup: function() {
+    onStanzaStr = sinon.spy();
+    onError = sinon.spy();
+    function onStanza(stanza) {
+      onStanzaStr(new XMLSerializer().serializeToString(stanza));
+    }
+    parser = new remoting.XmppStreamParser();
+    parser.setCallbacks(onStanza, onError);
+  }
+});
+
+
+test('should parse XMPP stream', function() {
+  parser.appendData(base.encodeUtf8('<stream><iq>text</iq>'));
+  sinon.assert.calledWith(onStanzaStr, '<iq>text</iq>');
+});
+
+test('should handle multiple incoming stanzas', function() {
+  parser.appendData(base.encodeUtf8('<stream><iq>text</iq><iq>more text</iq>'));
+  sinon.assert.calledWith(onStanzaStr, '<iq>text</iq>');
+  sinon.assert.calledWith(onStanzaStr, '<iq>more text</iq>');
+});
+
+test('should ignore whitespace between stanzas', function() {
+  parser.appendData(base.encodeUtf8('<stream> <iq>text</iq>'));
+  sinon.assert.calledWith(onStanzaStr, '<iq>text</iq>');
+});
+
+test('should assemble messages from small chunks', function() {
+  parser.appendData(base.encodeUtf8('<stream><i'));
+  parser.appendData(base.encodeUtf8('q>'));
+
+  // Split one UTF-8 sequence into two chunks
+  var data = base.encodeUtf8('😃');
+  parser.appendData(data.slice(0, 2));
+  parser.appendData(data.slice(2));
+
+  parser.appendData(base.encodeUtf8('</iq>'));
+
+  sinon.assert.calledWith(onStanzaStr, '<iq>😃</iq>');
+});
+
+test('should stop parsing on errors', function() {
+  parser.appendData(base.encodeUtf8('<stream>error<iq>text</iq>'));
+  sinon.assert.calledWith(onError);
+  sinon.assert.notCalled(onStanzaStr);
+});
+
+test('should fail on invalid stream header', function() {
+  parser.appendData(base.encodeUtf8('<stream p=\'>'));
+  sinon.assert.calledWith(onError);
+});
+
+test('should fail on loose text', function() {
+  parser.appendData(base.encodeUtf8('stream'));
+  sinon.assert.calledWith(onError);
+});
+
+test('should fail on loose text with incomplete UTF-8 sequences', function() {
+  var buffer = base.encodeUtf8('<stream>ф')
+  // Crop last byte.
+  buffer = buffer.slice(0, buffer.byteLength - 1);
+  parser.appendData(buffer);
+  sinon.assert.calledWith(onError);
+});
+
+test('should fail on incomplete UTF-8 sequences', function() {
+  var buffer = base.encodeUtf8('<stream><iq>ф')
+  // Crop last byte.
+  buffer = buffer.slice(0, buffer.byteLength - 1);
+  parser.appendData(buffer);
+  parser.appendData(base.encodeUtf8('</iq>'));
+  sinon.assert.calledWith(onError);
+});
+
+})();