21748551581

Committed 06 Feb 2026 10:23AM UTC coverage: 88.687% (-0.7%) from 89.395%

Build # 21748551581

Build Type

Pull #2909

github

Committed by

PooyaRaki

Commit Message

fix: fix lint errors

Pull Request Pull Request #2909: Release 1.100.0

Run Details

2980 of 3772 branches covered (79.0%)

Branch coverage included in aggregate %.

137 of 167 new or added lines in 15 files covered. (82.04%)

252 existing lines in 34 files now uncovered.

14079 of 15463 relevant lines covered (91.05%)

553.43 hits per line

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

35.71

/src/datasources/cache/cache.module.ts

import { Global, Module } from '@nestjs/common';
import { createClient } from 'redis';
import { IConfigurationService } from '@/config/configuration.service.interface';
import { CacheService } from '@/datasources/cache/cache.service.interface';
import { RedisCacheService } from '@/datasources/cache/redis.cache.service';
import { CacheReadiness } from '@/domain/interfaces/cache-readiness.interface';
import { ILoggingService, LoggingService } from '@/logging/logging.interface';
import { CacheKeyPrefix } from '@/datasources/cache/constants';
import { LogType } from '@/domain/common/entities/log-type.entity';

export type RedisClientType = ReturnType<typeof createClient>;

async function redisClientFactory(
  configurationService: IConfigurationService,
  loggingService: ILoggingService,
): Promise<RedisClientType> {
  const redisUser = configurationService.get<string>('redis.user');
  const redisPass = configurationService.get<string>('redis.pass');
  const redisHost = configurationService.getOrThrow<string>('redis.host');
  const redisPort = configurationService.getOrThrow<string>('redis.port');
  const redisConnectTimeout = configurationService.getOrThrow<number>(
    'redis.connectTimeout',
  );
  const redisKeepAlive =
    configurationService.getOrThrow<number>('redis.keepAlive');
  const redisDisableOfflineQueue = configurationService.getOrThrow<boolean>(
    'redis.disableOfflineQueue',
  );
  const client: RedisClientType = createClient({
    socket: {
      host: redisHost,
      port: Number(redisPort),
      keepAliveInitialDelay: redisKeepAlive,
      connectTimeout: redisConnectTimeout,
    },
    username: redisUser,
    password: redisPass,
    disableOfflineQueue: redisDisableOfflineQueue,
  });
  client.on('error', (err) =>
    loggingService.error({
      type: LogType.CacheError,
      source: 'CacheModule',
      event: err.code ?? err.message,
    }),
  );
  client.on('reconnecting', () =>
    loggingService.warn({
      type: LogType.CacheEvent,
      source: 'CacheModule',
      event: 'Reconnecting to Redis',
    }),
  );
  client.on('end', () =>
    loggingService.warn({
      type: LogType.CacheEvent,
      source: 'CacheModule',
      event: 'Redis connection closed',
    }),
  );
  await client.connect();
  return client;
}

@Global()
@Module({
  providers: [
    {
      provide: 'RedisClient',
      useFactory: redisClientFactory,
      inject: [IConfigurationService, LoggingService],
    },
    { provide: CacheService, useClass: RedisCacheService },
    { provide: CacheReadiness, useExisting: CacheService },
    { provide: CacheKeyPrefix, useValue: '' },
  ],
  exports: [CacheService, CacheReadiness],
})
export class CacheModule {}

1	import { Global, Module } from '@nestjs/common';	100✔
2	import { createClient } from 'redis';	100✔
3	import { IConfigurationService } from '@/config/configuration.service.interface';	100✔
4	import { CacheService } from '@/datasources/cache/cache.service.interface';	100✔
5	import { RedisCacheService } from '@/datasources/cache/redis.cache.service';	100✔
6	import { CacheReadiness } from '@/domain/interfaces/cache-readiness.interface';	100✔
7	import { ILoggingService, LoggingService } from '@/logging/logging.interface';	100✔
8	import { CacheKeyPrefix } from '@/datasources/cache/constants';	100✔
9	import { LogType } from '@/domain/common/entities/log-type.entity';	100✔
10
11	export type RedisClientType = ReturnType<typeof createClient>;
12
13	async function redisClientFactory(
14	configurationService: IConfigurationService,
15	loggingService: ILoggingService,
16	): Promise<RedisClientType> {
UNCOV 17	const redisUser = configurationService.get<string>('redis.user');	×
UNCOV 18	const redisPass = configurationService.get<string>('redis.pass');	×
UNCOV 19	const redisHost = configurationService.getOrThrow<string>('redis.host');	×
UNCOV 20	const redisPort = configurationService.getOrThrow<string>('redis.port');	×
UNCOV 21	const redisConnectTimeout = configurationService.getOrThrow<number>(	×
22	'redis.connectTimeout',
23	);
24	const redisKeepAlive =
UNCOV 25	configurationService.getOrThrow<number>('redis.keepAlive');	×
UNCOV 26	const redisDisableOfflineQueue = configurationService.getOrThrow<boolean>(	×
27	'redis.disableOfflineQueue',
28	);
UNCOV 29	const client: RedisClientType = createClient({	×
30	socket: {
31	host: redisHost,
32	port: Number(redisPort),
33	keepAliveInitialDelay: redisKeepAlive,
34	connectTimeout: redisConnectTimeout,
35	},
36	username: redisUser,
37	password: redisPass,
38	disableOfflineQueue: redisDisableOfflineQueue,
39	});
UNCOV 40	client.on('error', (err) =>	×
41	loggingService.error({	×
42	type: LogType.CacheError,
43	source: 'CacheModule',
44	event: err.code ?? err.message,	×
45	}),
46	);
UNCOV 47	client.on('reconnecting', () =>	×
48	loggingService.warn({	×
49	type: LogType.CacheEvent,
50	source: 'CacheModule',
51	event: 'Reconnecting to Redis',
52	}),
53	);
UNCOV 54	client.on('end', () =>	×
UNCOV 55	loggingService.warn({	×
56	type: LogType.CacheEvent,
57	source: 'CacheModule',
58	event: 'Redis connection closed',
59	}),
60	);
UNCOV 61	await client.connect();	×
UNCOV 62	return client;	×
63	}
64
65	@Global()
66	@Module({
67	providers: [
68	{
69	provide: 'RedisClient',
70	useFactory: redisClientFactory,
71	inject: [IConfigurationService, LoggingService],
72	},
73	{ provide: CacheService, useClass: RedisCacheService },
74	{ provide: CacheReadiness, useExisting: CacheService },
75	{ provide: CacheKeyPrefix, useValue: '' },
76	],
77	exports: [CacheService, CacheReadiness],
78	})
79	export class CacheModule {}	100✔

safe-global / safe-client-gateway / 21748551581

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