add oninfo event to main interface

Author: avistramer

README.md

@@ -163,6 +163,11 @@ Where `options` is a hash which can contain:
     the number of expected round trips. This setting will establish a minimum,
     but if the calculated timeout is higher, that will be used.
 
+  * **transportOptions (object)**
+
+    Additional options to pass per transport, keyed on transport name. For example:
+    ```{ 'xhr-streaming': { headers: { Authorization: 'xxx' } } }```
+
 Although the 'SockJS' object tries to emulate the 'WebSocket'
 behaviour, it's impossible to support all of its features. An
 important SockJS limitation is the fact that you're not allowed to

lib/event/info.js

@@ -0,0 +1,17 @@
+'use strict';
+
+var inherits = require('inherits')
+  , Event = require('./event')
+  ;
+
+function InfoEvent(info, rtt, headers) {
+  Event.call(this);
+  this.initEvent('info', false, false);
+  this.info = info;
+  this.rtt = rtt;
+  this.headers = headers;
+}
+
+inherits(InfoEvent, Event);
+
+module.exports = InfoEvent;

lib/info-ajax.js

@@ -18,7 +18,7 @@ function InfoAjax(url, AjaxObject, opts) {
   var t0 = +new Date();
   this.xo = new AjaxObject('GET', url, null, opts);
 
-  this.xo.once('finish', function(status, text) {
+  this.xo.once('finish', function(status, text, headers) {
     var info, rtt;
     if (status === 200) {
       rtt = (+new Date()) - t0;
@@ -34,7 +34,7 @@ function InfoAjax(url, AjaxObject, opts) {
         info = {};
       }
     }
-    self.emit('finish', info, rtt);
+    self.emit('finish', info, rtt, headers);
     self.removeAllListeners();
   });
 }

lib/info-receiver.js

@@ -61,10 +61,10 @@ InfoReceiver.prototype.doXhr = function(baseUrl, urlInfo, transportOptions) {
     self.emit('finish');
   }, InfoReceiver.timeout);
 
-  this.xo.once('finish', function(info, rtt) {
-    debug('finish', info, rtt);
+  this.xo.once('finish', function(info, rtt, headers) {
+    debug('finish', info, rtt, headers);
     self._cleanup(true);
-    self.emit('finish', info, rtt);
+    self.emit('finish', info, rtt, headers || {});
   });
 };
 

lib/main.js

@@ -18,6 +18,7 @@ var URL = require('url-parse')
   , loc = require('./location')
   , CloseEvent = require('./event/close')
   , TransportMessageEvent = require('./event/trans-message')
+  , InfoEvent = require('./event/info')
   , InfoReceiver = require('./info-receiver')
   ;
 
@@ -174,8 +175,9 @@ SockJS.OPEN = 1;
 SockJS.CLOSING = 2;
 SockJS.CLOSED = 3;
 
-SockJS.prototype._receiveInfo = function(info, rtt) {
+SockJS.prototype._receiveInfo = function(info, rtt, headers) {
   debug('_receiveInfo', rtt);
+  this.dispatchEvent(new InfoEvent(info, rtt, headers));
   this._ir = null;
   if (!info) {
     this._close(1002, 'Cannot connect to server');

lib/transport/driver/xhr.js

@@ -39,7 +39,7 @@ function XhrDriver(method, url, payload, opts) {
     });
     res.once('end', function() {
       debug('end');
-      self.emit('finish', res.statusCode, responseText);
+      self.emit('finish', res.statusCode, responseText, res.headers);
       self.req = null;
     });
   });