11144328428

Committed 02 Oct 2024 01:03PM UTC coverage: 90.153% (-0.06%) from 90.21%

Build # 11144328428

Build Type

Pull #1988

github

Committed by

PooyaRaki

Commit Message

Destroys database connection in tests

Pull Request Pull Request #1988: OrmMigrationAndLogger

Run Details

2616 of 3274 branches covered (79.9%)

Branch coverage included in aggregate %.

48 of 78 new or added lines in 9 files covered. (61.54%)

1 existing line in 1 file now uncovered.

8499 of 9055 relevant lines covered (93.86%)

438.92 hits per line

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

95.65

/src/datasources/db/v2/postgres-database.service.ts

import {
  LoggingService,
  type ILoggingService,
} from '@/logging/logging.interface';
import { InjectDataSource } from '@nestjs/typeorm';
import { Inject, Injectable } from '@nestjs/common';
import { DataSource, type ObjectLiteral, type Repository } from 'typeorm';

@Injectable()
export class PostgresDatabaseService {
  public constructor(
    @Inject(LoggingService) private readonly loggingService: ILoggingService,
    @InjectDataSource() private readonly dataSource: DataSource,
  ) {}

  /**
   * Returns the datasource object
   *
   * @returns {DataSource} Datasource object
   */
  public getDataSource(): DataSource {
    return this.dataSource;
  }

  /**
   * Checks whether the datasource has been initialized or not
   *
   * @returns {boolean} True if the datasource has already been initialized
   */
  public isInitialized(): boolean {
    return this.dataSource.isInitialized;
  }

  /**
   * Initializes the database connection. If the connection is not initialized, it initializes the connection.
   *
   * @returns {Promise<DataSource>} The database connection.
   */
  public async initializeDatabaseConnection(): Promise<DataSource> {
    if (!this.dataSource.isInitialized) {
      this.loggingService.info('PostgresDatabaseService initialized...');
      await this.dataSource.initialize();
    }

    return this.dataSource;
  }

  /**
   * Destroys the database connection. If the connection is not initialized, it initializes the connection.
   *
   * @returns {Promise<DataSource>} The database connection.
   */
  public async destroyDatabaseConnection(): Promise<DataSource> {
    if (this.dataSource.isInitialized) {
      this.loggingService.info('PostgresDatabaseService Destroyed...');
      await this.dataSource.destroy();
    }

    return this.dataSource;
  }

  /**
   * Fetches a repository for the given entity.
   *
   * @param {Object} entity - The entity class.
   *
   * @returns {Promise<Repository<T>>} The repository for the entity.
   */
  public async getRepository<T extends ObjectLiteral>(entity: {
    new (): T;
  }): Promise<Repository<T>> {
    const connection = await this.initializeDatabaseConnection();

    return connection.getRepository<T>(entity);
  }
}

1	import {	102✔
2	LoggingService,
3	type ILoggingService,
4	} from '@/logging/logging.interface';
5	import { InjectDataSource } from '@nestjs/typeorm';	102✔
6	import { Inject, Injectable } from '@nestjs/common';	102✔
7	import { DataSource, type ObjectLiteral, type Repository } from 'typeorm';	102✔
8
9	@Injectable()
10	export class PostgresDatabaseService {	102✔
11	public constructor(
12	@Inject(LoggingService) private readonly loggingService: ILoggingService,	1,602✔
13	@InjectDataSource() private readonly dataSource: DataSource,	1,602✔
14	) {}
15
16	/**
17	* Returns the datasource object
18	*
19	* @returns {DataSource} Datasource object
20	*/
21	public getDataSource(): DataSource {
NEW 22	return this.dataSource;	×
23	}
24
25	/**
26	* Checks whether the datasource has been initialized or not
27	*
28	* @returns {boolean} True if the datasource has already been initialized
29	*/
30	public isInitialized(): boolean {
31	return this.dataSource.isInitialized;	4✔
32	}
33
34	/**
35	* Initializes the database connection. If the connection is not initialized, it initializes the connection.
36	*
37	* @returns {Promise<DataSource>} The database connection.
38	*/
39	public async initializeDatabaseConnection(): Promise<DataSource> {
40	if (!this.dataSource.isInitialized) {	10✔
41	this.loggingService.info('PostgresDatabaseService initialized...');	10✔
42	await this.dataSource.initialize();	10✔
43	}
44
45	return this.dataSource;	10✔
46	}
47
48	/**
49	* Destroys the database connection. If the connection is not initialized, it initializes the connection.
50	*
51	* @returns {Promise<DataSource>} The database connection.
52	*/
53	public async destroyDatabaseConnection(): Promise<DataSource> {
54	if (this.dataSource.isInitialized) {	6✔
55	this.loggingService.info('PostgresDatabaseService Destroyed...');	6✔
56	await this.dataSource.destroy();	6✔
57	}
58
59	return this.dataSource;	6✔
60	}
61
62	/**
63	* Fetches a repository for the given entity.
64	*
65	* @param {Object} entity - The entity class.
66	*
67	* @returns {Promise<Repository<T>>} The repository for the entity.
68	*/
69	public async getRepository<T extends ObjectLiteral>(entity: {
70	new (): T;
71	}): Promise<Repository<T>> {
72	const connection = await this.initializeDatabaseConnection();	2✔
73
74	return connection.getRepository<T>(entity);	2✔
75	}
76	}

safe-global / safe-client-gateway / 11144328428

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