24596779791

Committed 18 Apr 2026 04:21AM UTC coverage: 48.812% (-0.3%) from 49.12%

Build # 24596779791

Build Type

Pull #481

github

Committed by

web-flow

Commit Message

Merge db344bdce into 3cb65a66f

Pull Request Pull Request #481: fix: properly await worker teardown in integration tests to prevent open handles

Coverage Stats

470 of 1071 branches covered (43.88%)

Branch coverage included in aggregate %.

6 of 8 new or added lines in 2 files covered. (75.0%)

8 existing lines in 2 files now uncovered.

1338 of 2633 relevant lines covered (50.82%)

9.53 hits per line

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

40.91

/src/cache/client.ts

import { createClient, RedisClientOptions } from 'redis'
import { CacheClient } from '../@types/cache'
import { createLogger } from '../factories/logger-factory'


const debug = createLogger('cache-client')

export const getCacheConfig = (): RedisClientOptions => ({
  url: process.env.REDIS_URI ? process.env.REDIS_URI : `redis://${process.env.REDIS_USER}:${process.env.REDIS_PASSWORD}@${process.env.REDIS_HOST}:${process.env.REDIS_PORT}`,
  password: process.env.REDIS_PASSWORD,
})

let instance: CacheClient | undefined = undefined

export const getCacheClient = (): CacheClient => {
  if (!instance) {
    const config = getCacheConfig()
    // eslint-disable-next-line @typescript-eslint/no-unused-vars
    const { password: _, ...loggableConfig } = config
    debug('config: %o', loggableConfig)
    instance = createClient(config)
  }

  return instance
}

export const closeCacheClient = async (): Promise<void> => {
  if (instance?.isOpen) {
    await instance.disconnect()
    instance = undefined
  }
}

1	import { createClient, RedisClientOptions } from 'redis'	2✔
2	import { CacheClient } from '../@types/cache'
3	import { createLogger } from '../factories/logger-factory'	2✔
4
5
6	const debug = createLogger('cache-client')	2✔
7
8	export const getCacheConfig = (): RedisClientOptions => ({	2✔
9	url: process.env.REDIS_URI ? process.env.REDIS_URI : `redis://${process.env.REDIS_USER}:${process.env.REDIS_PASSWORD}@${process.env.REDIS_HOST}:${process.env.REDIS_PORT}`,	×
10	password: process.env.REDIS_PASSWORD,
11	})
12
13	let instance: CacheClient \| undefined = undefined	2✔
14
15	export const getCacheClient = (): CacheClient => {	2✔
UNCOV 16	if (!instance) {	×
UNCOV 17	const config = getCacheConfig()	×
18	// eslint-disable-next-line @typescript-eslint/no-unused-vars
UNCOV 19	const { password: _, ...loggableConfig } = config	×
UNCOV 20	debug('config: %o', loggableConfig)	×
UNCOV 21	instance = createClient(config)	×
22	}
23
UNCOV 24	return instance	×
25	}
26
27	export const closeCacheClient = async (): Promise<void> => {	2✔
28	if (instance?.isOpen) {	2!
NEW 29	await instance.disconnect()	×
NEW 30	instance = undefined	×
31	}
32	}

cameri / nostream / 24596779791

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