/opt/canhelp/node_modules/kysely/dist/esm/util
Edit: /opt/canhelp/node_modules/kysely/dist/esm/util/log.js (1695B)
///
import { freeze, isFunction } from './object-utils.js';
const logLevels = ['query', 'error'];
export const LOG_LEVELS = freeze(logLevels);
export class Log {
#levels;
#logger;
constructor(config) {
if (isFunction(config)) {
this.#logger = config;
this.#levels = freeze({
query: true,
error: true,
});
}
else {
this.#logger = defaultLogger;
this.#levels = freeze({
query: config.includes('query'),
error: config.includes('error'),
});
}
}
isLevelEnabled(level) {
return this.#levels[level];
}
async query(getEvent) {
if (this.#levels.query) {
await this.#logger(getEvent());
}
}
async error(getEvent) {
if (this.#levels.error) {
await this.#logger(getEvent());
}
}
}
function defaultLogger(event) {
if (event.level === 'query') {
const prefix = `kysely:query:${event.isStream ? 'stream:' : ''}`;
console.log(`${prefix} ${event.query.sql}`);
console.log(`${prefix} duration: ${event.queryDurationMillis.toFixed(1)}ms`);
}
else if (event.level === 'error') {
if (event.error instanceof Error) {
console.error(`kysely:error: ${event.error.stack ?? event.error.message}`);
}
else {
console.error(`kysely:error: ${JSON.stringify({
error: event.error,
query: event.query.sql,
queryDurationMillis: event.queryDurationMillis,
})}`);
}
}
}