| 1 | "use strict";
|
| 2 | Object.defineProperty(exports, "__esModule", { value: true });
|
| 3 | const riverpig = require("riverpig");
|
| 4 | const debug = require("debug");
|
| 5 | const through2 = require("through2");
|
| 6 | const logStream = through2();
|
| 7 | logStream.pipe(process.stdout);
|
| 8 | class ConnectorLogger {
|
| 9 | constructor(namespace, config0) {
|
| 10 | this.river = riverpig(namespace, config0);
|
| 11 | this.tracer = this.river.trace || debug(namespace + ':trace');
|
| 12 | }
|
| 13 | info(msg, ...elements) {
|
| 14 | this.river.info(msg, ...elements);
|
| 15 | }
|
| 16 | warn(msg, ...elements) {
|
| 17 | this.river.warn(msg, ...elements);
|
| 18 | }
|
| 19 | error(msg, ...elements) {
|
| 20 | this.river.error(msg, ...elements);
|
| 21 | }
|
| 22 | debug(msg, ...elements) {
|
| 23 | this.river.debug(msg, ...elements);
|
| 24 | }
|
| 25 | trace(msg, ...elements) {
|
| 26 | this.tracer(msg, ...elements);
|
| 27 | }
|
| 28 | }
|
| 29 | exports.ConnectorLogger = ConnectorLogger;
|
| 30 | exports.createRaw = (namespace) => {
|
| 31 | return new ConnectorLogger(namespace, {
|
| 32 | stream: logStream
|
| 33 | });
|
| 34 | };
|
| 35 | exports.create = (namespace) => exports.createRaw('connector:' + namespace);
|
| 36 | let outputStream = process.stdout;
|
| 37 | exports.setOutputStream = (newOutputStream) => {
|
| 38 | logStream.unpipe(outputStream);
|
| 39 | logStream.pipe(newOutputStream);
|
| 40 | outputStream = newOutputStream;
|
| 41 | };
|
| 42 | |
| \ | No newline at end of file |