Populate the Message.data field before handing off to extensions.
This commit is contained in:
@@ -219,6 +219,7 @@ var instance = {
|
||||
if (runExtensions && this.MESSAGE_OPCODES.indexOf(frame.opcode) >= 0) {
|
||||
var message = new Message(frame.opcode === 1 ? 'text' : 'binary');
|
||||
message.pushFrame(frame);
|
||||
message.read();
|
||||
|
||||
return this._extensions.processOutgoingMessage(message, function(error, message) {
|
||||
if (error) return this._fail('extension_error', error.message);
|
||||
@@ -424,13 +425,14 @@ var instance = {
|
||||
},
|
||||
|
||||
_emitMessage: function(message, runExtensions) {
|
||||
var payload = message.read();
|
||||
|
||||
if (runExtensions)
|
||||
return this._extensions.processIncomingMessage(message, function(error, message) {
|
||||
if (error) return this._fail('extension_error', error.message);
|
||||
this._emitMessage(message);
|
||||
}, this);
|
||||
|
||||
var payload = message.read();
|
||||
if (message.type === 'text') payload = this._encode(payload);
|
||||
delete this._message;
|
||||
|
||||
|
||||
Reference in New Issue
Block a user