anders/Wallet
1
0
Fork 0
Code Issues Projects Releases Packages Wiki Activity

fix Async to remove soop

Browse source
This commit is contained in:
Manuel Araoz 2014-08-18 10:33:00 -04:00
commit fd9d8d9e2e
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
js/models/network/Async.js
View file

@ -1,11 +1,11 @@
'use strict'; 'use strict';
var imports = require('soop').imports(); var EventEmitter = require('events').EventEmitter;
var EventEmitter = imports.EventEmitter || require('events').EventEmitter;
var bitcore = require('bitcore'); var bitcore = require('bitcore');
var AuthMessage = bitcore.AuthMessage; var AuthMessage = bitcore.AuthMessage;
var util = bitcore.util; var util = bitcore.util;
var extend = require('util')._extend; var nodeUtil = require('util');
var extend = nodeUtil._extend;
var io = require('socket.io-client'); var io = require('socket.io-client');
var preconditions = require('preconditions').singleton(); var preconditions = require('preconditions').singleton();
@ -30,7 +30,7 @@ function Network(opts) {
this.cleanUp(); this.cleanUp();
} }
Network.parent = EventEmitter; nodeUtil.inherits(Network, EventEmitter);
Network.prototype.cleanUp = function() { Network.prototype.cleanUp = function() {
this.started = false; this.started = false;
@ -213,7 +213,7 @@ Network.prototype._onMessage = function(enc) {
*/ */
console.log('receiving '+JSON.stringify(payload)); console.log('receiving ' + JSON.stringify(payload));
var self = this; var self = this;
switch (payload.type) { switch (payload.type) {
@ -352,7 +352,7 @@ Network.prototype.send = function(copayerIds, payload, cb) {
}; };
var copayerIdBuf = new Buffer(copayerId, 'hex'); var copayerIdBuf = new Buffer(copayerId, 'hex');
var message = AuthMessage.encode(copayerIdBuf, self.getKey(), payload, opts); var message = AuthMessage.encode(copayerIdBuf, self.getKey(), payload, opts);
console.log('sending '+JSON.stringify(payload)); console.log('sending ' + JSON.stringify(payload));
self.socket.emit('message', message); self.socket.emit('message', message);
}); });
if (typeof cb === 'function') cb(); if (typeof cb === 'function') cb();
@ -382,4 +382,4 @@ Network.prototype.disconnect = function(cb, forced) {
}); });
}; };
module.exports = require('soop')(Network); module.exports = Network;