whitespace cleanup
This commit is contained in:
parent
2eb7712ab8
commit
091893b1e4
@ -25,18 +25,18 @@ AddrMessage.fromBuffer = function(payload) {
|
|||||||
var parser = new BufferReader(payload);
|
var parser = new BufferReader(payload);
|
||||||
|
|
||||||
var addrCount = parser.readVarintNum();
|
var addrCount = parser.readVarintNum();
|
||||||
|
|
||||||
var obj = {};
|
var obj = {};
|
||||||
obj.addresses = [];
|
obj.addresses = [];
|
||||||
for (var i = 0; i < addrCount; i++) {
|
for (var i = 0; i < addrCount; i++) {
|
||||||
// todo: time only available on versions >=31402
|
// todo: time only available on versions >=31402
|
||||||
var time = new Date(parser.readUInt32LE() * 1000);
|
var time = new Date(parser.readUInt32LE() * 1000);
|
||||||
|
|
||||||
var addr = utils.parseAddr(parser);
|
var addr = utils.parseAddr(parser);
|
||||||
addr.time = time;
|
addr.time = time;
|
||||||
obj.addresses.push(addr);
|
obj.addresses.push(addr);
|
||||||
}
|
}
|
||||||
|
|
||||||
utils.checkFinished(parser);
|
utils.checkFinished(parser);
|
||||||
return AddrMessage.fromObject(obj);
|
return AddrMessage.fromObject(obj);
|
||||||
};
|
};
|
||||||
@ -44,13 +44,13 @@ AddrMessage.fromBuffer = function(payload) {
|
|||||||
AddrMessage.prototype.getPayload = function() {
|
AddrMessage.prototype.getPayload = function() {
|
||||||
var bw = new BufferWriter();
|
var bw = new BufferWriter();
|
||||||
bw.writeVarintNum(this.addresses.length);
|
bw.writeVarintNum(this.addresses.length);
|
||||||
|
|
||||||
for (var i = 0; i < this.addresses.length; i++) {
|
for (var i = 0; i < this.addresses.length; i++) {
|
||||||
var addr = this.addresses[i];
|
var addr = this.addresses[i];
|
||||||
bw.writeUInt32LE(addr.time.getTime() / 1000);
|
bw.writeUInt32LE(addr.time.getTime() / 1000);
|
||||||
utils.writeAddr(addr, bw);
|
utils.writeAddr(addr, bw);
|
||||||
}
|
}
|
||||||
|
|
||||||
return bw.concat();
|
return bw.concat();
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@ -13,7 +13,7 @@ function AlertMessage(options) {
|
|||||||
Message.call(this, options);
|
Message.call(this, options);
|
||||||
this.magicNumber = magicNumber;
|
this.magicNumber = magicNumber;
|
||||||
this.command = 'alert';
|
this.command = 'alert';
|
||||||
|
|
||||||
this.payload = options.payload || new Buffer(32);
|
this.payload = options.payload || new Buffer(32);
|
||||||
this.signature = options.signature || new Buffer(32);
|
this.signature = options.signature || new Buffer(32);
|
||||||
}
|
}
|
||||||
@ -36,10 +36,10 @@ AlertMessage.prototype.getPayload = function() {
|
|||||||
var bw = new BufferWriter();
|
var bw = new BufferWriter();
|
||||||
bw.writeVarintNum(this.payload.length);
|
bw.writeVarintNum(this.payload.length);
|
||||||
bw.write(this.payload);
|
bw.write(this.payload);
|
||||||
|
|
||||||
bw.writeVarintNum(this.signature.length);
|
bw.writeVarintNum(this.signature.length);
|
||||||
bw.write(this.signature);
|
bw.write(this.signature);
|
||||||
|
|
||||||
return bw.concat();
|
return bw.concat();
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@ -24,7 +24,7 @@ function GetblocksMessage(options) {
|
|||||||
this.command = 'getblocks';
|
this.command = 'getblocks';
|
||||||
this.version = protocolVersion;
|
this.version = protocolVersion;
|
||||||
this.magicNumber = magicNumber;
|
this.magicNumber = magicNumber;
|
||||||
|
|
||||||
options = utils.sanitizeStartStop(options);
|
options = utils.sanitizeStartStop(options);
|
||||||
this.starts = options.starts;
|
this.starts = options.starts;
|
||||||
this.stop = options.stop;
|
this.stop = options.stop;
|
||||||
@ -40,10 +40,10 @@ GetblocksMessage.fromBuffer = function(payload) {
|
|||||||
var obj = {};
|
var obj = {};
|
||||||
var parser = new BufferReader(payload);
|
var parser = new BufferReader(payload);
|
||||||
$.checkArgument(!parser.finished(), 'No data received in payload');
|
$.checkArgument(!parser.finished(), 'No data received in payload');
|
||||||
|
|
||||||
obj.version = parser.readUInt32LE();
|
obj.version = parser.readUInt32LE();
|
||||||
var startCount = parser.readVarintNum();
|
var startCount = parser.readVarintNum();
|
||||||
|
|
||||||
obj.starts = [];
|
obj.starts = [];
|
||||||
for (var i = 0; i < startCount; i++) {
|
for (var i = 0; i < startCount; i++) {
|
||||||
obj.starts.push(parser.read(32));
|
obj.starts.push(parser.read(32));
|
||||||
|
|||||||
@ -25,7 +25,7 @@ GetdataMessage.fromBuffer = function(payload) {
|
|||||||
var obj = {
|
var obj = {
|
||||||
inventory: []
|
inventory: []
|
||||||
};
|
};
|
||||||
|
|
||||||
var parser = new BufferReader(payload);
|
var parser = new BufferReader(payload);
|
||||||
var count = parser.readVarintNum();
|
var count = parser.readVarintNum();
|
||||||
for (var i = 0; i < count; i++) {
|
for (var i = 0; i < count; i++) {
|
||||||
@ -33,7 +33,7 @@ GetdataMessage.fromBuffer = function(payload) {
|
|||||||
var hash = parser.read(32);
|
var hash = parser.read(32);
|
||||||
obj.inventory.push({type: type, hash: hash});
|
obj.inventory.push({type: type, hash: hash});
|
||||||
}
|
}
|
||||||
|
|
||||||
utils.checkFinished(parser);
|
utils.checkFinished(parser);
|
||||||
return GetdataMessage.fromObject(obj);
|
return GetdataMessage.fromObject(obj);
|
||||||
};
|
};
|
||||||
|
|||||||
@ -22,11 +22,11 @@ function GetheadersMessage(options) {
|
|||||||
this.command = 'getheaders';
|
this.command = 'getheaders';
|
||||||
this.version = protocolVersion;
|
this.version = protocolVersion;
|
||||||
this.magicNumber = magicNumber;
|
this.magicNumber = magicNumber;
|
||||||
|
|
||||||
options = utils.sanitizeStartStop(options);
|
options = utils.sanitizeStartStop(options);
|
||||||
this.starts = options.starts;
|
this.starts = options.starts;
|
||||||
this.stop = options.stop;
|
this.stop = options.stop;
|
||||||
|
|
||||||
}
|
}
|
||||||
inherits(GetheadersMessage, Message);
|
inherits(GetheadersMessage, Message);
|
||||||
|
|
||||||
@ -38,10 +38,10 @@ GetheadersMessage.fromBuffer = function(payload) {
|
|||||||
var obj = {};
|
var obj = {};
|
||||||
var parser = new BufferReader(payload);
|
var parser = new BufferReader(payload);
|
||||||
$.checkArgument(!parser.finished(), 'No data received in payload');
|
$.checkArgument(!parser.finished(), 'No data received in payload');
|
||||||
|
|
||||||
obj.version = parser.readUInt32LE();
|
obj.version = parser.readUInt32LE();
|
||||||
var startCount = Math.min(parser.readVarintNum(), 500);
|
var startCount = Math.min(parser.readVarintNum(), 500);
|
||||||
|
|
||||||
obj.starts = [];
|
obj.starts = [];
|
||||||
for (var i = 0; i < startCount; i++) {
|
for (var i = 0; i < startCount; i++) {
|
||||||
obj.starts.push(parser.read(32));
|
obj.starts.push(parser.read(32));
|
||||||
|
|||||||
@ -31,7 +31,7 @@ InvMessage.fromBuffer = function(payload) {
|
|||||||
var obj = {
|
var obj = {
|
||||||
inventory: []
|
inventory: []
|
||||||
};
|
};
|
||||||
|
|
||||||
var parser = new BufferReader(payload);
|
var parser = new BufferReader(payload);
|
||||||
var count = parser.readVarintNum();
|
var count = parser.readVarintNum();
|
||||||
for (var i = 0; i < count; i++) {
|
for (var i = 0; i < count; i++) {
|
||||||
@ -39,7 +39,7 @@ InvMessage.fromBuffer = function(payload) {
|
|||||||
var hash = parser.read(32);
|
var hash = parser.read(32);
|
||||||
obj.inventory.push({type: type, hash: hash});
|
obj.inventory.push({type: type, hash: hash});
|
||||||
}
|
}
|
||||||
|
|
||||||
utils.checkFinished(parser);
|
utils.checkFinished(parser);
|
||||||
return InvMessage.fromObject(obj);
|
return InvMessage.fromObject(obj);
|
||||||
};
|
};
|
||||||
|
|||||||
@ -31,7 +31,7 @@ PingMessage.fromBuffer = function(payload) {
|
|||||||
var obj = {};
|
var obj = {};
|
||||||
var parser = new BufferReader(payload);
|
var parser = new BufferReader(payload);
|
||||||
obj.nonce = parser.read(8);
|
obj.nonce = parser.read(8);
|
||||||
|
|
||||||
utils.checkFinished(parser);
|
utils.checkFinished(parser);
|
||||||
return PingMessage.fromObject(obj);
|
return PingMessage.fromObject(obj);
|
||||||
};
|
};
|
||||||
@ -40,4 +40,3 @@ module.exports = function(options) {
|
|||||||
magicNumber = options.magicNumber || magicNumber;
|
magicNumber = options.magicNumber || magicNumber;
|
||||||
return PingMessage;
|
return PingMessage;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@ -24,7 +24,7 @@ PongMessage.fromBuffer = function(payload) {
|
|||||||
var obj = {};
|
var obj = {};
|
||||||
var parser = new BufferReader(payload);
|
var parser = new BufferReader(payload);
|
||||||
obj.nonce = parser.read(8);
|
obj.nonce = parser.read(8);
|
||||||
|
|
||||||
utils.checkFinished(parser);
|
utils.checkFinished(parser);
|
||||||
return PongMessage.fromObject(obj);
|
return PongMessage.fromObject(obj);
|
||||||
};
|
};
|
||||||
|
|||||||
@ -30,4 +30,3 @@ module.exports = function(options) {
|
|||||||
magicNumber = options.magicNumber || magicNumber;
|
magicNumber = options.magicNumber || magicNumber;
|
||||||
return VerackMessage;
|
return VerackMessage;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user