added missing precondition and moved buffer.skip to new file
This commit is contained in:
parent
42288e8354
commit
7e29af4542
23
lib/buffers.js
Normal file
23
lib/buffers.js
Normal file
@ -0,0 +1,23 @@
|
|||||||
|
'use strict';
|
||||||
|
|
||||||
|
var Buffers = require('buffers');
|
||||||
|
|
||||||
|
Buffers.prototype.skip = function(i) {
|
||||||
|
if (i === 0) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (i === this.length) {
|
||||||
|
this.buffers = [];
|
||||||
|
this.length = 0;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
var pos = this.pos(i);
|
||||||
|
this.buffers = this.buffers.slice(pos.buf);
|
||||||
|
this.buffers[0] = new Buffer(this.buffers[0].slice(pos.offset));
|
||||||
|
this.length -= i;
|
||||||
|
};
|
||||||
|
|
||||||
|
module.exports = Buffers;
|
||||||
|
|
||||||
24
lib/peer.js
24
lib/peer.js
@ -1,12 +1,13 @@
|
|||||||
'use strict';
|
'use strict';
|
||||||
|
|
||||||
var Buffers = require('buffers');
|
var Buffers = require('./buffers');
|
||||||
var EventEmitter = require('events').EventEmitter;
|
var EventEmitter = require('events').EventEmitter;
|
||||||
var Net = require('net');
|
var Net = require('net');
|
||||||
var Socks5Client = require('socks5-client');
|
var Socks5Client = require('socks5-client');
|
||||||
var bitcore = require('bitcore');
|
var bitcore = require('bitcore');
|
||||||
var Networks = bitcore.Networks;
|
var Networks = bitcore.Networks;
|
||||||
var Messages = require('./messages');
|
var Messages = require('./messages');
|
||||||
|
var $ = bitcore.util.preconditions;
|
||||||
var util = require('util');
|
var util = require('util');
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -30,6 +31,9 @@ var util = require('util');
|
|||||||
* @constructor
|
* @constructor
|
||||||
*/
|
*/
|
||||||
function Peer(options) {
|
function Peer(options) {
|
||||||
|
/* jshint maxstatements: 20 */
|
||||||
|
/* jshint maxcomplexity: 8 */
|
||||||
|
|
||||||
if (!(this instanceof Peer)) {
|
if (!(this instanceof Peer)) {
|
||||||
return new Peer(options);
|
return new Peer(options);
|
||||||
}
|
}
|
||||||
@ -93,6 +97,8 @@ Peer.STATUS = {
|
|||||||
* @returns {Peer} The same Peer instance.
|
* @returns {Peer} The same Peer instance.
|
||||||
*/
|
*/
|
||||||
Peer.prototype.setProxy = function(host, port) {
|
Peer.prototype.setProxy = function(host, port) {
|
||||||
|
$.checkState(this.status === Peer.STATUS.DISCONNECTED);
|
||||||
|
|
||||||
this.proxy = {
|
this.proxy = {
|
||||||
host: host,
|
host: host,
|
||||||
port: port
|
port: port
|
||||||
@ -203,20 +209,4 @@ Peer.prototype._getSocket = function() {
|
|||||||
return new Net.Socket();
|
return new Net.Socket();
|
||||||
};
|
};
|
||||||
|
|
||||||
// TODO: Remove this PATCH (yemel)
|
|
||||||
Buffers.prototype.skip = function(i) {
|
|
||||||
if (i === 0) return;
|
|
||||||
|
|
||||||
if (i === this.length) {
|
|
||||||
this.buffers = [];
|
|
||||||
this.length = 0;
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
var pos = this.pos(i);
|
|
||||||
this.buffers = this.buffers.slice(pos.buf);
|
|
||||||
this.buffers[0] = new Buffer(this.buffers[0].slice(pos.offset));
|
|
||||||
this.length -= i;
|
|
||||||
};
|
|
||||||
|
|
||||||
module.exports = Peer;
|
module.exports = Peer;
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user