RanchiMall/flocore-p2p
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

moved ping and verack to seperate files

Browse Source
This commit is contained in:
Braydon Fuller 2015-03-12 04:48:58 -04:00
parent 6ca2f6982c
commit 3c2afed5f5
3 changed files with 78 additions and 52 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
lib/messages/builder.js
View File

@ -5,7 +5,6 @@ var BloomFilter = require('../bloomfilter');
var inherits = require('util').inherits;
var bitcore = require('bitcore');
var BN = bitcore.crypto.BN;
var BufferReader = bitcore.encoding.BufferReader;
var BufferWriter = bitcore.encoding.BufferWriter;
var BufferUtil = bitcore.util.buffer;
@ -48,57 +47,8 @@ function builder(options) {
};
commands.version = require('./commands/version')({magicNumber: magicNumber});
/* verack */
commands.verack = function(options) {
Message.call(this, options);
this.magicNumber = magicNumber;
this.command = 'verack';
};
inherits(commands.verack, Message);
commands.verack.fromObject = function(obj) {
return new commands.verack(obj);
};
commands.verack.fromBuffer = function(payload) {
return commands.verack.fromObject({});
};
commands.verack.prototype.getPayload = function() {
return BufferUtil.EMPTY_BUFFER;
};
/* ping */
commands.ping = function(options) {
if (!options) {
options = {};
}
Message.call(this, options);
this.command = 'ping';
this.magicNumber = magicNumber;
this.nonce = options.nonce || utils.getNonce();
};
inherits(commands.ping, Message);
commands.ping.prototype.getPayload = function() {
return this.nonce;
};
commands.ping.fromObject = function(obj) {
return new commands.ping(obj);
};
commands.ping.fromBuffer = function(payload) {
var obj = {};
var parser = new BufferReader(payload);
obj.nonce = parser.read(8);
utils.checkFinished(parser);
return commands.ping.fromObject(obj);
};
commands.verack = require('./commands/verack')({magicNumber: magicNumber});
commands.ping = require('./commands/ping')({magicNumber: magicNumber});
/* pong */

43
lib/messages/commands/ping.js Normal file
View File

@ -0,0 +1,43 @@
'use strict';
var Message = require('../message');
var inherits = require('util').inherits;
var bitcore = require('bitcore');
var utils = require('../utils');
var BufferReader = bitcore.encoding.BufferReader;
var magicNumber = bitcore.Networks.defaultNetwork.networkMagic.readUInt32LE(0);
function PingMessage(options) {
if (!options) {
options = {};
}
Message.call(this, options);
this.command = 'ping';
this.magicNumber = magicNumber;
this.nonce = options.nonce || utils.getNonce();
};
inherits(PingMessage, Message);
PingMessage.prototype.getPayload = function() {
return this.nonce;
};
PingMessage.fromObject = function(obj) {
return new PingMessage(obj);
};
PingMessage.fromBuffer = function(payload) {
var obj = {};
var parser = new BufferReader(payload);
obj.nonce = parser.read(8);
utils.checkFinished(parser);
return PingMessage.fromObject(obj);
};
module.exports = function(options) {
magicNumber = options.magicNumber || magicNumber;
return PingMessage;
};

33
lib/messages/commands/verack.js Normal file
View File

@ -0,0 +1,33 @@
'use strict';
var Message = require('../message');
var inherits = require('util').inherits;
var bitcore = require('bitcore');
var BufferUtil = bitcore.util.buffer;
var magicNumber = bitcore.Networks.defaultNetwork.networkMagic.readUInt32LE(0);
function VerackMessage(options) {
Message.call(this, options);
this.magicNumber = magicNumber;
this.command = 'verack';
};
inherits(VerackMessage, Message);
VerackMessage.fromObject = function(obj) {
return new VerackMessage(obj);
};
VerackMessage.fromBuffer = function(payload) {
return VerackMessage.fromObject({});
};
VerackMessage.prototype.getPayload = function() {
return BufferUtil.EMPTY_BUFFER;
};
module.exports = function(options) {
magicNumber = options.magicNumber || magicNumber;
return VerackMessage;
};