node: start using blgr and bcfg.
This commit is contained in:
Christopher Jeffrey
parent
fe03b42936
commit
401829db5a
2
bin/cli
2
bin/cli
@ -2,7 +2,7 @@
|
||||
|
||||
'use strict';
|
||||
|
||||
const Config = require('../lib/node/config');
|
||||
const Config = require('bcfg');
|
||||
const {NodeClient, WalletClient} = require('bclient');
|
||||
|
||||
const nports = {
|
||||
|
||||
@ -11,7 +11,7 @@ const assert = require('assert');
|
||||
const path = require('path');
|
||||
const AsyncObject = require('../utils/asyncobject');
|
||||
const Network = require('../protocol/network');
|
||||
const Logger = require('../node/logger');
|
||||
const Logger = require('blgr');
|
||||
const ChainDB = require('./chaindb');
|
||||
const common = require('./common');
|
||||
const consensus = require('../protocol/consensus');
|
||||
|
||||
@ -15,7 +15,7 @@ const policy = require('../protocol/policy');
|
||||
const BufferReader = require('bbuf/lib/reader');
|
||||
const StaticWriter = require('bbuf/lib/staticwriter');
|
||||
const encoding = require('bbuf/lib/encoding');
|
||||
const Logger = require('../node/logger');
|
||||
const Logger = require('blgr');
|
||||
|
||||
/*
|
||||
* Constants
|
||||
|
||||
@ -23,7 +23,7 @@ const base58 = require('bstr/lib/base58');
|
||||
const encoding = require('bbuf/lib/encoding');
|
||||
const IP = require('binet');
|
||||
const dns = require('./dns');
|
||||
const Logger = require('../node/logger');
|
||||
const Logger = require('blgr');
|
||||
|
||||
/**
|
||||
* Represents a BIP150 input/output stream.
|
||||
|
||||
@ -19,7 +19,7 @@ const List = require('../utils/list');
|
||||
const common = require('./common');
|
||||
const seeds = require('./seeds');
|
||||
const dns = require('./dns');
|
||||
const Logger = require('../node/logger');
|
||||
const Logger = require('blgr');
|
||||
const POOL32 = Buffer.allocUnsafe(32);
|
||||
|
||||
/**
|
||||
|
||||
@ -27,7 +27,7 @@ const TX = require('../primitives/tx');
|
||||
const encoding = require('bbuf/lib/encoding');
|
||||
const NetAddress = require('../primitives/netaddress');
|
||||
const Network = require('../protocol/network');
|
||||
const Logger = require('../node/logger');
|
||||
const Logger = require('blgr');
|
||||
const tcp = require('./tcp');
|
||||
const services = common.services;
|
||||
const invTypes = InvItem.types;
|
||||
|
||||
1127
lib/node/config.js
1127
lib/node/config.js
File diff suppressed because it is too large
Load Diff
@ -10,10 +10,8 @@
|
||||
* @module node
|
||||
*/
|
||||
|
||||
exports.Config = require('./config');
|
||||
exports.FullNode = require('./fullnode');
|
||||
exports.HTTP = require('./http');
|
||||
exports.Logger = require('./logger');
|
||||
exports.Node = require('./node');
|
||||
exports.RPC = require('./rpc');
|
||||
exports.SPVNode = require('./spvnode');
|
||||
|
||||
@ -1,995 +0,0 @@
|
||||
/*!
|
||||
* logger.js - basic logger for bcoin
|
||||
* Copyright (c) 2014-2017, Christopher Jeffrey (MIT License).
|
||||
* https://github.com/bcoin-org/bcoin
|
||||
*/
|
||||
|
||||
'use strict';
|
||||
|
||||
const assert = require('assert');
|
||||
const {format, inspect} = require('util');
|
||||
const fs = require('bfile');
|
||||
const util = require('../utils/util');
|
||||
const co = require('../utils/co');
|
||||
const Lock = require('../utils/lock');
|
||||
|
||||
/*
|
||||
* Constants
|
||||
*/
|
||||
|
||||
const inspectOptions = {
|
||||
showHidden: false,
|
||||
depth: 20,
|
||||
colors: false,
|
||||
customInspect: true,
|
||||
showProxy: false,
|
||||
maxArrayLength: Infinity,
|
||||
breakLength: 60
|
||||
};
|
||||
|
||||
/**
|
||||
* Basic stdout and file logger.
|
||||
* @alias module:node.Logger
|
||||
* @constructor
|
||||
* @param {(String|Object)?} options/level
|
||||
* @param {String?} options.level
|
||||
* @param {Boolean} [options.colors=true]
|
||||
*/
|
||||
|
||||
function Logger(options) {
|
||||
if (!(this instanceof Logger))
|
||||
return new Logger(options);
|
||||
|
||||
this.level = Logger.levels.NONE;
|
||||
this.colors = Logger.HAS_TTY;
|
||||
this.console = true;
|
||||
this.shrink = true;
|
||||
this.closed = true;
|
||||
this.closing = false;
|
||||
this.filename = null;
|
||||
this.stream = null;
|
||||
this.contexts = Object.create(null);
|
||||
this.locker = new Lock();
|
||||
|
||||
if (options)
|
||||
this.set(options);
|
||||
}
|
||||
|
||||
/**
|
||||
* Whether stdout is a tty FD.
|
||||
* @const {Boolean}
|
||||
*/
|
||||
|
||||
Logger.HAS_TTY = Boolean(process.stdout && process.stdout.isTTY);
|
||||
|
||||
/**
|
||||
* Maximum file size.
|
||||
* @const {Number}
|
||||
* @default
|
||||
*/
|
||||
|
||||
Logger.MAX_FILE_SIZE = 20 << 20;
|
||||
|
||||
/**
|
||||
* Available log levels.
|
||||
* @enum {Number}
|
||||
*/
|
||||
|
||||
Logger.levels = {
|
||||
NONE: 0,
|
||||
ERROR: 1,
|
||||
WARNING: 2,
|
||||
INFO: 3,
|
||||
DEBUG: 4,
|
||||
SPAM: 5
|
||||
};
|
||||
|
||||
/**
|
||||
* Available log levels.
|
||||
* @const {String[]}
|
||||
* @default
|
||||
*/
|
||||
|
||||
Logger.levelsByVal = [
|
||||
'none',
|
||||
'error',
|
||||
'warning',
|
||||
'info',
|
||||
'debug',
|
||||
'spam'
|
||||
];
|
||||
|
||||
/**
|
||||
* Available log levels.
|
||||
* @const {String[]}
|
||||
* @default
|
||||
*/
|
||||
|
||||
Logger.prefixByVal = [
|
||||
'N',
|
||||
'E',
|
||||
'W',
|
||||
'I',
|
||||
'D',
|
||||
'S'
|
||||
];
|
||||
|
||||
/**
|
||||
* Default CSI colors.
|
||||
* @const {String[]}
|
||||
* @default
|
||||
*/
|
||||
|
||||
Logger.styles = [
|
||||
'0',
|
||||
'1;31',
|
||||
'1;33',
|
||||
'94',
|
||||
'90',
|
||||
'90'
|
||||
];
|
||||
|
||||
/**
|
||||
* Set logger options.
|
||||
* @param {Object} options
|
||||
*/
|
||||
|
||||
Logger.prototype.set = function set(options) {
|
||||
assert(options);
|
||||
assert(this.closed);
|
||||
|
||||
if (typeof options === 'string') {
|
||||
this.setLevel(options);
|
||||
return;
|
||||
}
|
||||
|
||||
if (options.level != null) {
|
||||
assert(typeof options.level === 'string');
|
||||
this.setLevel(options.level);
|
||||
}
|
||||
|
||||
if (options.colors != null && Logger.HAS_TTY) {
|
||||
assert(typeof options.colors === 'boolean');
|
||||
this.colors = options.colors;
|
||||
}
|
||||
|
||||
if (options.console != null) {
|
||||
assert(typeof options.console === 'boolean');
|
||||
this.console = options.console;
|
||||
}
|
||||
|
||||
if (options.shrink != null) {
|
||||
assert(typeof options.shrink === 'boolean');
|
||||
this.shrink = options.shrink;
|
||||
}
|
||||
|
||||
if (options.filename != null) {
|
||||
assert(typeof options.filename === 'string', 'Bad file.');
|
||||
this.filename = options.filename;
|
||||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* Open the logger.
|
||||
* @method
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
Logger.prototype.open = async function open() {
|
||||
const unlock = await this.locker.lock();
|
||||
try {
|
||||
return await this._open();
|
||||
} finally {
|
||||
unlock();
|
||||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* Open the logger (no lock).
|
||||
* @method
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
Logger.prototype._open = async function _open() {
|
||||
if (!this.filename) {
|
||||
this.closed = false;
|
||||
return;
|
||||
}
|
||||
|
||||
if (this.stream) {
|
||||
this.closed = false;
|
||||
return;
|
||||
}
|
||||
|
||||
if (fs.unsupported) {
|
||||
this.closed = false;
|
||||
return;
|
||||
}
|
||||
|
||||
if (this.shrink)
|
||||
await this.truncate();
|
||||
|
||||
this.stream = await openStream(this.filename);
|
||||
this.stream.once('error', this.handleError.bind(this));
|
||||
this.closed = false;
|
||||
};
|
||||
|
||||
/**
|
||||
* Destroy the write stream.
|
||||
* @method
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
Logger.prototype.close = async function close() {
|
||||
const unlock = await this.locker.lock();
|
||||
try {
|
||||
return await this._close();
|
||||
} finally {
|
||||
unlock();
|
||||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* Destroy the write stream (no lock).
|
||||
* @method
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
Logger.prototype._close = async function _close() {
|
||||
if (this.timer != null) {
|
||||
co.clearTimeout(this.timer);
|
||||
this.timer = null;
|
||||
}
|
||||
|
||||
if (fs.unsupported) {
|
||||
this.closed = true;
|
||||
this.stream = null;
|
||||
return;
|
||||
}
|
||||
|
||||
if (this.stream) {
|
||||
try {
|
||||
this.closing = true;
|
||||
await closeStream(this.stream);
|
||||
} finally {
|
||||
this.closing = false;
|
||||
}
|
||||
this.stream = null;
|
||||
}
|
||||
|
||||
this.closed = true;
|
||||
};
|
||||
|
||||
/**
|
||||
* Truncate the log file to the last 20mb.
|
||||
* @method
|
||||
* @private
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
Logger.prototype.truncate = async function truncate() {
|
||||
if (!this.filename)
|
||||
return;
|
||||
|
||||
if (fs.unsupported)
|
||||
return;
|
||||
|
||||
assert(!this.stream);
|
||||
|
||||
let stat;
|
||||
try {
|
||||
stat = await fs.stat(this.filename);
|
||||
} catch (e) {
|
||||
if (e.code === 'ENOENT')
|
||||
return;
|
||||
throw e;
|
||||
}
|
||||
|
||||
const maxSize = Logger.MAX_FILE_SIZE;
|
||||
|
||||
if (stat.size <= maxSize + (maxSize / 10))
|
||||
return;
|
||||
|
||||
this.debug('Truncating log file to %d bytes.', maxSize);
|
||||
|
||||
const fd = await fs.open(this.filename, 'r+');
|
||||
const data = Buffer.allocUnsafe(maxSize);
|
||||
|
||||
await fs.read(fd, data, 0, maxSize, stat.size - maxSize);
|
||||
await fs.ftruncate(fd, maxSize);
|
||||
await fs.write(fd, data, 0, maxSize, 0);
|
||||
await fs.close(fd);
|
||||
};
|
||||
|
||||
/**
|
||||
* Handle write stream error.
|
||||
* @param {Error} err
|
||||
*/
|
||||
|
||||
Logger.prototype.handleError = function handleError(err) {
|
||||
try {
|
||||
this.stream.close();
|
||||
} catch (e) {
|
||||
;
|
||||
}
|
||||
|
||||
this.stream = null;
|
||||
this.retry();
|
||||
};
|
||||
|
||||
/**
|
||||
* Try to reopen the logger.
|
||||
* @method
|
||||
* @private
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
Logger.prototype.reopen = async function reopen() {
|
||||
const unlock = await this.locker.lock();
|
||||
try {
|
||||
return await this._reopen();
|
||||
} finally {
|
||||
unlock();
|
||||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* Try to reopen the logger (no lock).
|
||||
* @method
|
||||
* @private
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
Logger.prototype._reopen = async function _reopen() {
|
||||
if (this.stream)
|
||||
return;
|
||||
|
||||
if (this.closed)
|
||||
return;
|
||||
|
||||
if (fs.unsupported)
|
||||
return;
|
||||
|
||||
try {
|
||||
this.stream = await openStream(this.filename);
|
||||
} catch (e) {
|
||||
this.retry();
|
||||
return;
|
||||
}
|
||||
|
||||
this.stream.once('error', this.handleError.bind(this));
|
||||
};
|
||||
|
||||
/**
|
||||
* Try to reopen the logger after a timeout.
|
||||
* @method
|
||||
* @private
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
Logger.prototype.retry = function retry() {
|
||||
assert(this.timer == null);
|
||||
this.timer = co.setTimeout(() => {
|
||||
this.timer = null;
|
||||
this.reopen();
|
||||
}, 10000, this);
|
||||
};
|
||||
|
||||
/**
|
||||
* Set the log file location.
|
||||
* @param {String} filename
|
||||
*/
|
||||
|
||||
Logger.prototype.setFile = function setFile(filename) {
|
||||
assert(typeof filename === 'string');
|
||||
assert(!this.stream, 'Log stream has already been created.');
|
||||
this.filename = filename;
|
||||
};
|
||||
|
||||
/**
|
||||
* Set or reset the log level.
|
||||
* @param {String} level
|
||||
*/
|
||||
|
||||
Logger.prototype.setLevel = function setLevel(name) {
|
||||
const level = Logger.levels[name.toUpperCase()];
|
||||
assert(level != null, 'Invalid log level.');
|
||||
this.level = level;
|
||||
};
|
||||
|
||||
/**
|
||||
* Format log.
|
||||
* @param {Array} args
|
||||
* @param {Boolean} colors
|
||||
* @returns {String}
|
||||
*/
|
||||
|
||||
Logger.prototype.fmt = function fmt(args, colors) {
|
||||
if (args.length > 0) {
|
||||
const [obj] = args;
|
||||
if (obj && typeof obj === 'object') {
|
||||
inspectOptions.colors = colors;
|
||||
return inspect(obj, inspectOptions);
|
||||
}
|
||||
}
|
||||
return format(...args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `error` log level.
|
||||
* @param {String|Object|Error} err
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
Logger.prototype.error = function error(...args) {
|
||||
if (this.level < Logger.levels.ERROR)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.ERROR, null, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.ERROR, null, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `warning` log level.
|
||||
* @param {String|Object} obj
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
Logger.prototype.warning = function warning(...args) {
|
||||
if (this.level < Logger.levels.WARNING)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.WARNING, null, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.WARNING, null, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `info` log level.
|
||||
* @param {String|Object} obj
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
Logger.prototype.info = function info(...args) {
|
||||
if (this.level < Logger.levels.INFO)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.INFO, null, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.INFO, null, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `debug` log level.
|
||||
* @param {String|Object} obj
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
Logger.prototype.debug = function debug(...args) {
|
||||
if (this.level < Logger.levels.DEBUG)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.DEBUG, null, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.DEBUG, null, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `spam` log level.
|
||||
* @param {String|Object} obj
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
Logger.prototype.spam = function spam(...args) {
|
||||
if (this.level < Logger.levels.SPAM)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.SPAM, null, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.SPAM, null, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the desired log level.
|
||||
* Note that this bypasses the level check.
|
||||
* @param {String} level
|
||||
* @param {String|null} module
|
||||
* @param {Object[]} args
|
||||
*/
|
||||
|
||||
Logger.prototype.log = function log(level, module, args) {
|
||||
if (this.closed)
|
||||
return;
|
||||
|
||||
if (this.level < level)
|
||||
return;
|
||||
|
||||
this.writeConsole(level, module, args);
|
||||
this.writeStream(level, module, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Create logger context.
|
||||
* @param {String} module
|
||||
* @returns {LoggerContext}
|
||||
*/
|
||||
|
||||
Logger.prototype.context = function context(module) {
|
||||
let ctx = this.contexts[module];
|
||||
|
||||
if (!ctx) {
|
||||
ctx = new LoggerContext(this, module);
|
||||
this.contexts[module] = ctx;
|
||||
}
|
||||
|
||||
return ctx;
|
||||
};
|
||||
|
||||
/**
|
||||
* Write log to the console.
|
||||
* @param {String} level
|
||||
* @param {String|null} module
|
||||
* @param {Object[]} args
|
||||
*/
|
||||
|
||||
Logger.prototype.writeConsole = function writeConsole(level, module, args) {
|
||||
const name = Logger.levelsByVal[level];
|
||||
|
||||
assert(name, 'Invalid log level.');
|
||||
|
||||
if (!this.console)
|
||||
return false;
|
||||
|
||||
if (!process.stdout) {
|
||||
let msg = `[${name}] `;
|
||||
|
||||
if (module)
|
||||
msg += `(${module}) `;
|
||||
|
||||
if (typeof args[0] === 'object') {
|
||||
return level === Logger.levels.ERROR
|
||||
? console.error(msg, args[0])
|
||||
: console.log(msg, args[0]);
|
||||
}
|
||||
|
||||
msg += this.fmt(args, false);
|
||||
|
||||
if (level === Logger.levels.ERROR) {
|
||||
console.error(msg);
|
||||
return true;
|
||||
}
|
||||
|
||||
console.log(msg);
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
let msg;
|
||||
if (this.colors) {
|
||||
const color = Logger.styles[level];
|
||||
assert(color);
|
||||
|
||||
msg = `\x1b[${color}m[${name}]\x1b[m `;
|
||||
} else {
|
||||
msg = `[${name}] `;
|
||||
}
|
||||
|
||||
if (module)
|
||||
msg += `(${module}) `;
|
||||
|
||||
msg += this.fmt(args, this.colors);
|
||||
msg += '\n';
|
||||
|
||||
return level === Logger.levels.ERROR
|
||||
? process.stderr.write(msg)
|
||||
: process.stdout.write(msg);
|
||||
};
|
||||
|
||||
/**
|
||||
* Write a string to the output stream (usually a file).
|
||||
* @param {String} level
|
||||
* @param {String|null} module
|
||||
* @param {Object[]} args
|
||||
*/
|
||||
|
||||
Logger.prototype.writeStream = function writeStream(level, module, args) {
|
||||
const name = Logger.prefixByVal[level];
|
||||
|
||||
assert(name, 'Invalid log level.');
|
||||
|
||||
if (!this.stream)
|
||||
return;
|
||||
|
||||
if (this.closing)
|
||||
return;
|
||||
|
||||
let msg = `[${name}:${util.date()}] `;
|
||||
|
||||
if (module)
|
||||
msg += `(${module}) `;
|
||||
|
||||
msg += this.fmt(args, false);
|
||||
msg += '\n';
|
||||
|
||||
this.stream.write(msg);
|
||||
};
|
||||
|
||||
/**
|
||||
* Helper to parse an error into a nicer
|
||||
* format. Call's `log` internally.
|
||||
* @private
|
||||
* @param {Number} level
|
||||
* @param {String|null} module
|
||||
* @param {Error} err
|
||||
*/
|
||||
|
||||
Logger.prototype.logError = function logError(level, module, err) {
|
||||
if (this.closed)
|
||||
return;
|
||||
|
||||
if (fs.unsupported && this.console) {
|
||||
if (level <= Logger.levels.WARNING)
|
||||
console.error(err);
|
||||
}
|
||||
|
||||
let msg = String(err.message).replace(/^ *Error: */, '');
|
||||
|
||||
if (level !== Logger.levels.ERROR)
|
||||
msg = `Error: ${msg}`;
|
||||
|
||||
this.log(level, module, [msg]);
|
||||
|
||||
if (level <= Logger.levels.WARNING) {
|
||||
if (this.stream)
|
||||
this.stream.write(err.stack + '\n');
|
||||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* Get the current memory usage.
|
||||
* @returns {Object}
|
||||
*/
|
||||
|
||||
Logger.prototype.memoryUsage = function memoryUsage() {
|
||||
if (!process.memoryUsage) {
|
||||
return {
|
||||
total: 0,
|
||||
jsHeap: 0,
|
||||
jsHeapTotal: 0,
|
||||
nativeHeap: 0,
|
||||
external: 0
|
||||
};
|
||||
}
|
||||
|
||||
const mem = process.memoryUsage();
|
||||
|
||||
return {
|
||||
total: Math.floor(mem.rss / (1 << 20)),
|
||||
jsHeap: Math.floor(mem.heapUsed / (1 << 20)),
|
||||
jsHeapTotal: Math.floor(mem.heapTotal / (1 << 20)),
|
||||
nativeHeap: Math.floor((mem.rss - mem.heapTotal) / (1 << 20)),
|
||||
external: Math.floor(mem.external / (1 << 20))
|
||||
};
|
||||
};
|
||||
|
||||
/**
|
||||
* Log the current memory usage.
|
||||
* @param {String|null} module
|
||||
*/
|
||||
|
||||
Logger.prototype.memory = function memory(module) {
|
||||
const mem = this.memoryUsage();
|
||||
|
||||
this.log(Logger.levels.DEBUG, module, [
|
||||
'Memory: rss=%dmb, js-heap=%d/%dmb native-heap=%dmb',
|
||||
mem.total,
|
||||
mem.jsHeap,
|
||||
mem.jsHeapTotal,
|
||||
mem.nativeHeap
|
||||
]);
|
||||
};
|
||||
|
||||
/**
|
||||
* Basic stdout and file logger.
|
||||
* @constructor
|
||||
* @ignore
|
||||
* @param {Logger} logger
|
||||
* @param {String} module
|
||||
*/
|
||||
|
||||
function LoggerContext(logger, module) {
|
||||
if (!(this instanceof LoggerContext))
|
||||
return new LoggerContext(logger, module);
|
||||
|
||||
assert(typeof module === 'string');
|
||||
|
||||
this.logger = logger;
|
||||
this.module = module;
|
||||
}
|
||||
|
||||
/**
|
||||
* Open the logger.
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.open = function open() {
|
||||
return this.logger.open();
|
||||
};
|
||||
|
||||
/**
|
||||
* Destroy the write stream.
|
||||
* @returns {Promise}
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.close = function close() {
|
||||
return this.logger.close();
|
||||
};
|
||||
|
||||
/**
|
||||
* Set the log file location.
|
||||
* @param {String} filename
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.setFile = function setFile(filename) {
|
||||
this.logger.setFile(filename);
|
||||
};
|
||||
|
||||
/**
|
||||
* Set or reset the log level.
|
||||
* @param {String} level
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.setLevel = function setLevel(name) {
|
||||
this.logger.setLevel(name);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `error` log level.
|
||||
* @param {String|Object|Error} err
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.error = function error(...args) {
|
||||
if (this.logger.level < Logger.levels.ERROR)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.ERROR, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.ERROR, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `warning` log level.
|
||||
* @param {String|Object} obj
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.warning = function warning(...args) {
|
||||
if (this.logger.level < Logger.levels.WARNING)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.WARNING, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.WARNING, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `info` log level.
|
||||
* @param {String|Object} obj
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.info = function info(...args) {
|
||||
if (this.logger.level < Logger.levels.INFO)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.INFO, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.INFO, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `debug` log level.
|
||||
* @param {String|Object} obj
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.debug = function debug(...args) {
|
||||
if (this.logger.level < Logger.levels.DEBUG)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.DEBUG, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.DEBUG, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the `spam` log level.
|
||||
* @param {String|Object} obj
|
||||
* @param {...Object} args
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.spam = function spam(...args) {
|
||||
if (this.logger.level < Logger.levels.SPAM)
|
||||
return;
|
||||
|
||||
const err = args[0];
|
||||
|
||||
if (err instanceof Error) {
|
||||
this.logError(Logger.levels.SPAM, err);
|
||||
return;
|
||||
}
|
||||
|
||||
this.log(Logger.levels.SPAM, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Output a log to the desired log level.
|
||||
* Note that this bypasses the level check.
|
||||
* @param {String} level
|
||||
* @param {Object[]} args
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.log = function log(level, args) {
|
||||
this.logger.log(level, this.module, args);
|
||||
};
|
||||
|
||||
/**
|
||||
* Create logger context.
|
||||
* @param {String} module
|
||||
* @returns {LoggerContext}
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.context = function context(module) {
|
||||
return new LoggerContext(this.logger, module);
|
||||
};
|
||||
|
||||
/**
|
||||
* Helper to parse an error into a nicer
|
||||
* format. Call's `log` internally.
|
||||
* @private
|
||||
* @param {Number} level
|
||||
* @param {Error} err
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.logError = function logError(level, err) {
|
||||
this.logger.logError(level, this.module, err);
|
||||
};
|
||||
|
||||
/**
|
||||
* Get the current memory usage.
|
||||
* @returns {Object}
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.memoryUsage = function memoryUsage() {
|
||||
return this.logger.memoryUsage();
|
||||
};
|
||||
|
||||
/**
|
||||
* Log the current memory usage.
|
||||
*/
|
||||
|
||||
LoggerContext.prototype.memory = function memory() {
|
||||
this.logger.memory(this.module);
|
||||
};
|
||||
|
||||
/*
|
||||
* Default
|
||||
*/
|
||||
|
||||
Logger.global = new Logger();
|
||||
|
||||
/*
|
||||
* Helpers
|
||||
*/
|
||||
|
||||
function openStream(filename) {
|
||||
return new Promise((resolve, reject) => {
|
||||
const stream = fs.createWriteStream(filename, { flags: 'a' });
|
||||
|
||||
const cleanup = () => {
|
||||
/* eslint-disable */
|
||||
stream.removeListener('error', onError);
|
||||
stream.removeListener('open', onOpen);
|
||||
/* eslint-enable */
|
||||
};
|
||||
|
||||
const onError = (err) => {
|
||||
try {
|
||||
stream.close();
|
||||
} catch (e) {
|
||||
;
|
||||
}
|
||||
cleanup();
|
||||
reject(err);
|
||||
};
|
||||
|
||||
const onOpen = () => {
|
||||
cleanup();
|
||||
resolve(stream);
|
||||
};
|
||||
|
||||
stream.once('error', onError);
|
||||
stream.once('open', onOpen);
|
||||
});
|
||||
}
|
||||
|
||||
function closeStream(stream) {
|
||||
return new Promise((resolve, reject) => {
|
||||
const cleanup = () => {
|
||||
/* eslint-disable */
|
||||
stream.removeListener('error', onError);
|
||||
stream.removeListener('close', onClose);
|
||||
/* eslint-enable */
|
||||
};
|
||||
|
||||
const onError = (err) => {
|
||||
cleanup();
|
||||
reject(err);
|
||||
};
|
||||
|
||||
const onClose = () => {
|
||||
cleanup();
|
||||
resolve(stream);
|
||||
};
|
||||
|
||||
stream.removeAllListeners('error');
|
||||
stream.removeAllListeners('close');
|
||||
stream.once('error', onError);
|
||||
stream.once('close', onClose);
|
||||
|
||||
stream.close();
|
||||
});
|
||||
}
|
||||
|
||||
/*
|
||||
* Expose
|
||||
*/
|
||||
|
||||
module.exports = Logger;
|
||||
@ -11,10 +11,10 @@ const assert = require('assert');
|
||||
const AsyncObject = require('../utils/asyncobject');
|
||||
const util = require('../utils/util');
|
||||
const Network = require('../protocol/network');
|
||||
const Logger = require('./logger');
|
||||
const Logger = require('blgr');
|
||||
const WorkerPool = require('../workers/workerpool');
|
||||
const secp256k1 = require('bcrypto/lib/secp256k1');
|
||||
const Config = require('./config');
|
||||
const Config = require('bcfg');
|
||||
|
||||
/**
|
||||
* Base class from which every other
|
||||
|
||||
@ -22,7 +22,7 @@ const common = require('./common');
|
||||
const Wallet = require('./wallet');
|
||||
const Account = require('./account');
|
||||
const BloomFilter = require('bfilter/lib/bloom');
|
||||
const Logger = require('../node/logger');
|
||||
const Logger = require('blgr');
|
||||
const Outpoint = require('../primitives/outpoint');
|
||||
const layouts = require('./layout');
|
||||
const records = require('./records');
|
||||
|
||||
@ -4,7 +4,7 @@ const assert = require('assert');
|
||||
const FullNode = require('../../lib/node/fullnode');
|
||||
const Network = require('../../lib/protocol/network');
|
||||
const co = require('../../lib/utils/co');
|
||||
const Logger = require('../../lib/node/logger');
|
||||
const Logger = require('blgr');
|
||||
|
||||
function NodeContext(network, size) {
|
||||
if (!(this instanceof NodeContext))
|
||||
|
||||
Loading…
Reference in New Issue
Block a user