make listening optional and fixed peer test
This commit is contained in:
parent
7f61fc62d4
commit
6461748cd5
@ -31,7 +31,7 @@ var util = require('util');
|
|||||||
* @constructor
|
* @constructor
|
||||||
*/
|
*/
|
||||||
function Peer(options) {
|
function Peer(options) {
|
||||||
/* jshint maxstatements: 20 */
|
/* jshint maxstatements: 25 */
|
||||||
/* jshint maxcomplexity: 8 */
|
/* jshint maxcomplexity: 8 */
|
||||||
|
|
||||||
if (!(this instanceof Peer)) {
|
if (!(this instanceof Peer)) {
|
||||||
@ -51,6 +51,7 @@ function Peer(options) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
this.network = Networks.get(options.network) || Networks.defaultNetwork;
|
this.network = Networks.get(options.network) || Networks.defaultNetwork;
|
||||||
|
|
||||||
if (!this.port) {
|
if (!this.port) {
|
||||||
this.port = this.network.port;
|
this.port = this.network.port;
|
||||||
}
|
}
|
||||||
|
|||||||
@ -127,8 +127,6 @@ Pool.prototype.connect = function connect() {
|
|||||||
} else {
|
} else {
|
||||||
self._fillConnections();
|
self._fillConnections();
|
||||||
}
|
}
|
||||||
|
|
||||||
this.listen();
|
|
||||||
return this;
|
return this;
|
||||||
};
|
};
|
||||||
|
|
||||||
@ -340,7 +338,7 @@ Pool.prototype.sendMessage = function(message) {
|
|||||||
Pool.prototype.listen = function() {
|
Pool.prototype.listen = function() {
|
||||||
var self = this;
|
var self = this;
|
||||||
|
|
||||||
// Create server
|
// Create server
|
||||||
this.server = net.createServer(function(socket) {
|
this.server = net.createServer(function(socket) {
|
||||||
var addr = {
|
var addr = {
|
||||||
ip: {}
|
ip: {}
|
||||||
|
|||||||
@ -139,6 +139,7 @@ describe('Peer', function() {
|
|||||||
var peer = new Peer({host: 'localhost'});
|
var peer = new Peer({host: 'localhost'});
|
||||||
var socket = new EventEmitter();
|
var socket = new EventEmitter();
|
||||||
socket.connect = sinon.spy();
|
socket.connect = sinon.spy();
|
||||||
|
socket.destroy = sinon.spy();
|
||||||
peer._getSocket = function() {
|
peer._getSocket = function() {
|
||||||
return socket;
|
return socket;
|
||||||
};
|
};
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user