escape only invalid character sequences in reliable socket

escaping is needed to prevent disconnects on chrome
see d7fec5188600a9cff7d0e505ad680332fb6e10be

node_modules/kaefer/lib/reliable_socket.js

@@ -64,10 +64,22 @@ Object.defineProperty(ReliableSocket.prototype, "readyState", {
     }
 });
 
+function utf8escape(str) {
+    return str.replace(/[\ud799-\uDFFF]/g, function(x) {
+        return "\ud799" + String.fromCharCode(x.charCodeAt(0) - 0xd700);
+    });
+}
+
+function utf8unescape(str) {
+    return str.replace(/\ud799./g, function(x) {
+        return String.fromCharCode(x.charCodeAt(1) + 0xd700);
+    });
+}
+
 ReliableSocket.prototype.onMessage = function(msg) {
     if (typeof msg == "string") {
         try {
-            msg = JSON.parse(unescape(msg));
+            msg = JSON.parse(utf8unescape(msg));
         } catch(e) {}
     }
     this.debug && console.log("on message", msg, this.seq);
@@ -228,7 +240,7 @@ ReliableSocket.prototype._cancelDelayedAck = function() {
 ReliableSocket.prototype._ack = function() {
     if (this.socket.readyState == "open") {
         this.debug && console.log("send ack", this.recId);
-        this.socket.send(encodeURI(JSON.stringify({
+        this.socket.send(utf8escape(JSON.stringify({
             ack: this.recId
         })));
     }
@@ -324,7 +336,7 @@ ReliableSocket.prototype._sendMessage = function(data, type) {
                 that._updateRetransmissionTimeout(Date.now() - msg.ts);
         },
         serialize: function() {
-            return escape(JSON.stringify({
+            return utf8escape(JSON.stringify({
                 ack: that.recId,
                 seq: msg.seq,
                 d: data,

node_modules/kaefer/lib/version.js

@@ -2,6 +2,6 @@ define(function(require, exports, module) {
 
 // on each backwards incompatible protocol change the version number must be
 // increased
-exports.protocol = 9;
+exports.protocol = 10;
 
 });