Skip to content

Commit

Permalink
Always pass head object when emitting 'request' event
Browse files Browse the repository at this point in the history
  • Loading branch information
markyen committed Mar 9, 2015
1 parent b916cce commit 8b7be30
Showing 1 changed file with 10 additions and 4 deletions.
14 changes: 10 additions & 4 deletions index.js
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@ var PingReqSender = require('./lib/swim').PingReqSender;
var PingSender = require('./lib/swim').PingSender;
var safeParse = require('./lib/util').safeParse;
var RequestProxy = require('./lib/request-proxy');
var serializeHead = require('./lib/request-proxy-util.js').serializeHead;
var Suspicion = require('./lib/swim.js').Suspicion;

var HOST_PORT_PATTERN = /^(\d+.\d+.\d+.\d+):\d+$/;
Expand Down Expand Up @@ -849,24 +850,29 @@ RingPop.prototype.handleOrProxyAll =
}

dests.forEach(function(dest) {
var destKeys = keysByDest[dest];
var res = hammock.Response(function(err, resp) {
onResponse(err, resp, dest);
});
if (whoami === dest) {
self.logger.trace('handleOrProxyAll was handled', {
keys: keys,
keys: destKeys,
url: req && req.url,
dest: dest
});
self.emit('request', req, res);
var head = serializeHead(req, {
checksum: self.membership.checksum,
keys: destKeys
});
self.emit('request', req, res, head);
} else {
self.logger.trace('handleOrProxyAll was proxied', {
keys: keys,
keys: destKeys,
url: req && req.url,
dest: dest
});
self.proxyReq(_.defaults({
keys: keys,
keys: destKeys,
req: req,
res: res,
dest: dest
Expand Down

0 comments on commit 8b7be30

Please sign in to comment.