diff --git a/lib/net/proxysocket.js b/lib/net/proxysocket.js index 6ee3e7a7..2c988591 100644 --- a/lib/net/proxysocket.js +++ b/lib/net/proxysocket.js @@ -2,6 +2,7 @@ var bcoin = require('../env'); var utils = bcoin.utils; +var crypto = require('../crypto/crypto'); var BufferWriter = require('../utils/writer'); var assert = utils.assert; var EventEmitter = require('events').EventEmitter; @@ -28,6 +29,8 @@ function ProxySocket(uri) { this._init(); } +utils.inherits(ProxySocket, EventEmitter); + ProxySocket.prototype._init = function _init() { var self = this; @@ -82,8 +85,6 @@ ProxySocket.prototype._init = function _init() { }); }; -utils.inherits(ProxySocket, EventEmitter); - ProxySocket.prototype.connect = function connect(port, host) { var nonce = 0; var i, pow; @@ -115,7 +116,7 @@ ProxySocket.prototype.connect = function connect(port, host) { nonce++; assert(nonce <= 0xffffffff, 'Could not create socket.'); pow.writeUInt32LE(nonce, 0, true); - } while (utils.cmp(utils.dsha256(pow), this.target) > 0); + } while (utils.cmp(crypto.hash256(pow), this.target) > 0); utils.log('Solved proof of work: %d', nonce); } @@ -129,13 +130,13 @@ ProxySocket.prototype.connect = function connect(port, host) { }; ProxySocket.prototype.write = function write(data) { - this.bytesWritten += data.length; - if (!this.info) { this.sendBuffer.push(data); return true; } + this.bytesWritten += data.length; + this.socket.emit('tcp data', data.toString('hex')); return true;