Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 | 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 60x 60x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 24x 24x 24x 24x 1x 1x 24x 24x 24x 24x 24x 24x 6x 6x 6x 6x 6x 6x 6x 6x 6x 6x 32x 32x 534x 534x 534x 534x 534x 534x 534x 534x 534x 534x 534x 534x 534x 534x 534x 263x 534x 532x 534x 532x 534x 534x 534x 534x 534x 534x 534x 534x 1x | import {withProgress} from '@feasibleone/blong-lib';
import {Internal, type ILog, type ILogger} from '@feasibleone/blong/types';
import {pino, type Logger, type LoggerOptions} from 'pino';
import {monotonicFactory} from 'ulidx';
import type {CacacheTransportOptions} from './pino-cacache.js';
// echo -e "\u001B]8;;https://google.com\u001B\\Кликни тук\u001B]8;;\e\\"
export interface LogConfig extends LoggerOptions {
/** When provided, log entries are cached to disk via cacache for later inspection. */
cacache?: CacacheTransportOptions;
}
const ulid = monotonicFactory();
const ignoreArgPatterns = [
'--tls-cipher-list=',
'--v8-pool-size=',
'--trace-event-file-pattern=',
'--secure-heap-min=',
'--node-snapshot',
'--use-largepages=',
'--secure-heap=',
'--stack-trace-limit=',
];
// Pino transports run in worker threads. When the entry-point is ESM,
// `require.main` is undefined in CommonJS modules (including pino's transport
// loader). Pino interprets this as a "preload phase" and resets the worker's
// execArgv to [], stripping the TypeScript loader. We work around this by
// explicitly forwarding process.execArgv so the TypeScript loader is available
// inside the transport worker thread.
//
// However, when the process is started under `tap` (e.g. `blong-dev test`),
// process.execArgv contains tap's own `--import` hooks (@tapjs/typescript →
// pirates/ts-node). Those hooks intercept `.ts` loads in the worker and bypass
// Node's native type stripping, which fails on `import type` constructs
// (SyntaxError: Unexpected identifier 'PinoPretty' in pino-pretty.ts). So we
// drop tap's hooks from the worker execArgv.
//
// Dropping the hooks alone is not enough: pino's multi-target transport loads
// `.ts`/`.cts` targets with `realRequire()` (CJS require, relying on ts-node),
// which fails regardless of execArgv. We therefore point both transports at
// tiny `.mjs` shims (pino-pretty.mjs / pino-cacache.mjs) that re-export the
// `.ts` modules. Pino then treats them as non-TypeScript targets and loads
// them with `realImport()` (dynamic ESM import), where Node's native type
// stripping handles the re-exported `.ts` — in both tap and normal dev runs.
const WORKER_OPTS = {
execArgv: process.execArgv.filter(
arg =>
!ignoreArgPatterns.some(pattern => arg.startsWith(pattern)) &&
!(arg.startsWith('--import=') && arg.includes('@tapjs')),
),
};
const PRETTY_TRANSPORT = {
target: './pino-pretty.mjs',
worker: WORKER_OPTS,
options: {
singleLine: true,
colorizeObjects: true,
ignore: [
'context',
'prefix',
'pid',
'hostname',
'$meta.mtid',
'$meta.method',
'req',
'res',
'config',
'configBase',
'id',
].join(','),
},
};
export default class Log extends Internal implements ILog {
#logger: Logger;
#config: LogConfig = {
level: 'info',
transport: PRETTY_TRANSPORT,
};
public constructor(config: LogConfig) {
super();
this.merge(this.#config, config);
// Inject a monotonic ULID `id` into every log entry before it reaches any transport
if (this.#config.cacache) {
this.#config.mixin = () => ({id: ulid()});
// Multi-target transport: pretty console + cacache storage
const cacacheOptions = this.#config.cacache;
this.#config.transport = {
targets: [
PRETTY_TRANSPORT,
{
target: './pino-cacache.mjs',
worker: WORKER_OPTS,
options: cacacheOptions,
},
],
};
}
// Remove the cacache option before passing to pino — it is not a pino option
const {cacache: _cacacheConfig, ...pinoConfig} = this.#config;
this.#logger = pino(pinoConfig);
}
public child<T extends string>(...params: Parameters<Logger<never>['child']>): Logger<T> {
return this.#logger.child(...params) as Logger<T>;
}
public logger(
level: LoggerOptions['level'] = this.#config.level,
bindings: object,
): ReturnType<ILog['logger']> {
const child = this.#logger.child(bindings, {level});
const result: ILogger = {
trace: undefined,
debug: undefined,
info: undefined,
warn: undefined,
error: undefined,
fatal: undefined,
};
switch (level) {
case 'trace':
result.trace = child.trace.bind(child);
case 'debug':
result.debug = child.debug.bind(child);
case 'info':
result.info = child.info.bind(child);
case 'warn':
result.warn = child.warn.bind(child);
case 'error':
result.error = child.error.bind(child);
case 'fatal':
result.fatal = child.fatal.bind(child);
}
return {
...result,
progress: (label, promise, options) => withProgress(result, label, promise, options),
};
}
}
|