Skip to content

Commit

Permalink
add some missing protocol messages
Browse files Browse the repository at this point in the history
  • Loading branch information
digicontributer committed Jul 13, 2019
1 parent 2eeef9f commit 489a4c1
Show file tree
Hide file tree
Showing 4 changed files with 89 additions and 1 deletion.
5 changes: 4 additions & 1 deletion lib/messages/builder.js
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,10 @@ function builder(options) {
getblocks: 'GetBlocks',
getheaders: 'GetHeaders',
mempool: 'MemPool',
getaddr: 'GetAddr'
getaddr: 'GetAddr',
sendheaders: 'SendHeaders',
sendcmpct: 'SendCmpct',
feefilter: 'FeeFilter'
},
commands: {}
};
Expand Down
35 changes: 35 additions & 0 deletions lib/messages/commands/feefilter.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
'use strict';

var Message = require('../message');
var inherits = require('util').inherits;
var digibyte = require('digibyte');
var utils = require('../utils');
var BufferReader = digibyte.encoding.BufferReader;
var BufferWriter = digibyte.encoding.BufferWriter;

/**
* @param {Array=} arg - An array of addrs
* @param {Object=} options
* @extends Message
* @constructor
*/
function FeeFilter(arg, options) {
Message.call(this, options);
this.command = 'feefilter';
this.minFee = null;
}
inherits(FeeFilter, Message);

FeeFilter.prototype.setPayload = function(payload) {
var parser = new BufferReader(payload);
this.minFee = parser.readUInt64LEBN();
utils.checkFinished(parser);
};

FeeFilter.prototype.getPayload = function() {
var bw = new BufferWriter();
bw.writeUInt64LEBN(this.minFee);
return bw.concat();
};

module.exports = FeeFilter;
25 changes: 25 additions & 0 deletions lib/messages/commands/sendcmpct.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
'use strict';

var Message = require('../message');
var inherits = require('util').inherits;
var digibyte = require('digibyte');

/**
* @param {Array=} arg - An array of addrs
* @param {Object=} options
* @extends Message
* @constructor
*/
function SendCmpct(arg, options) {
Message.call(this, options);
this.command = 'sendcmpct';
}
inherits(SendCmpct, Message);

SendCmpct.prototype.setPayload = function(payload) {
};

SendCmpct.prototype.getPayload = function() {
};

module.exports = SendCmpct;
25 changes: 25 additions & 0 deletions lib/messages/commands/sendheaders.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
'use strict';

var Message = require('../message');
var inherits = require('util').inherits;
var digibyte = require('digibyte');

/**
* @param {Array=} arg - An array of addrs
* @param {Object=} options
* @extends Message
* @constructor
*/
function SendHeadersMessage(arg, options) {
Message.call(this, options);
this.command = 'sendheaders';
}
inherits(SendHeadersMessage, Message);

SendHeadersMessage.prototype.setPayload = function(payload) {
};

SendHeadersMessage.prototype.getPayload = function() {
};

module.exports = SendHeadersMessage;

0 comments on commit 489a4c1

Please sign in to comment.