11346136715

Committed 15 Oct 2024 12:33PM UTC coverage: 90.981% (+0.8%) from 90.21%

Build # 11346136715

Build Type

Pull #1988

github

Committed by

PooyaRaki

Commit Message

Add typeorm migration, Log only the query without parameters

Pull Request Pull Request #1988: OrmMigrationAndLogger

Run Details

2602 of 3183 branches covered (81.75%)

Branch coverage included in aggregate %.

84 of 125 new or added lines in 12 files covered. (67.2%)

43 existing lines in 16 files now uncovered.

8575 of 9102 relevant lines covered (94.21%)

422.26 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

19.61

/src/datasources/db/v2/postgresql-logger.service.ts

import type { ILoggingService } from '@/logging/logging.interface';
import { Injectable } from '@nestjs/common';
import {
  AbstractLogger,
  type LoggerOptions,
  type LogLevel,
  type LogMessage,
} from 'typeorm';

@Injectable()
export class PostgresqlLogger extends AbstractLogger {
  public constructor(
    public options?: LoggerOptions,
    private readonly loggingService?: ILoggingService,
  ) {
    super(options);
  }
  /**
   * Write log to specific output.
   *
   * This is taken from the TypeOrm default implementation, check out {@link https://orkhan.gitbook.io/typeorm/docs/logging}
   */
  protected writeLog(
    level: LogLevel,
    logMessage: LogMessage | LogMessage[],
  ): void {
    const messages = this.prepareLogMessages(logMessage, {
      highlightSql: false,
    });

    for (const message of messages) {
      switch (message.type ?? level) {
        case 'log':
        case 'schema-build':
        case 'migration':
          console.log(message.message);
          break;

        case 'info':
        case 'query':
          if (message.prefix) {
            console.info(message.prefix, message.message);
          } else {
            console.info(message.message);
          }
          break;

        case 'warn':
        case 'query-slow':
          if (message.prefix) {
            console.warn(message.prefix, message.message);
          } else {
            console.warn(message.message);
          }
          break;

        case 'error':
        case 'query-error':
          if (message.prefix) {
            console.error(message.prefix, message.message);
          } else {
            console.error(message.message);
          }
          break;
      }
    }
  }

  /**
   * Logs the executed query along with the request URL if available.
   *
   * @param {string} query - The SQL query string that is being executed.
   *
   * @returns {void} This method does not return anything.
   */
  public logQuery(query: string): void {
    if (this.loggingService) {
      this.loggingService.debug(`executing query: '${query}'`);
    } else {
      console.log({
        message: `executing query: '${query}'`,
        build_number: null,
        request_id: null,
        timestamp: new Date().toISOString(),
        version: null,
      });
    }
  }
}

1	import type { ILoggingService } from '@/logging/logging.interface';
2	import { Injectable } from '@nestjs/common';	108✔
3	import {	108✔
4	AbstractLogger,
5	type LoggerOptions,
6	type LogLevel,
7	type LogMessage,
8	} from 'typeorm';
9
10	@Injectable()
11	export class PostgresqlLogger extends AbstractLogger {	108✔
12	public constructor(
13	public options?: LoggerOptions,	1,228✔
14	private readonly loggingService?: ILoggingService,	1,228✔
15	) {
16	super(options);	1,228✔
17	}
18	/**
19	* Write log to specific output.
20	*
21	* This is taken from the TypeOrm default implementation, check out {@link https://orkhan.gitbook.io/typeorm/docs/logging}
22	*/
23	protected writeLog(
24	level: LogLevel,
25	logMessage: LogMessage \| LogMessage[],
26	): void {
NEW 27	const messages = this.prepareLogMessages(logMessage, {	×
28	highlightSql: false,
29	});
30
NEW 31	for (const message of messages) {	×
NEW 32	switch (message.type ?? level) {	×
33	case 'log':
34	case 'schema-build':
35	case 'migration':
NEW 36	console.log(message.message);	×
NEW 37	break;	×
38
39	case 'info':
40	case 'query':
NEW 41	if (message.prefix) {	×
NEW 42	console.info(message.prefix, message.message);	×
43	} else {
NEW 44	console.info(message.message);	×
45	}
NEW 46	break;	×
47
48	case 'warn':
49	case 'query-slow':
NEW 50	if (message.prefix) {	×
NEW 51	console.warn(message.prefix, message.message);	×
52	} else {
NEW 53	console.warn(message.message);	×
54	}
NEW 55	break;	×
56
57	case 'error':
58	case 'query-error':
NEW 59	if (message.prefix) {	×
NEW 60	console.error(message.prefix, message.message);	×
61	} else {
NEW 62	console.error(message.message);	×
63	}
NEW 64	break;	×
65	}
66	}
67	}
68
69	/**
70	* Logs the executed query along with the request URL if available.
71	*
72	* @param {string} query - The SQL query string that is being executed.
73	*
74	* @returns {void} This method does not return anything.
75	*/
76	public logQuery(query: string): void {
77	if (this.loggingService) {	34!
NEW 78	this.loggingService.debug(`executing query: '${query}'`);	×
79	} else {
80	console.log({	34✔
81	message: `executing query: '${query}'`,
82	build_number: null,
83	request_id: null,
84	timestamp: new Date().toISOString(),
85	version: null,
86	});
87	}
88	}
89	}

safe-global / safe-client-gateway / 11346136715

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous