23323684713

Committed 20 Mar 2026 12:32AM UTC coverage: 98.066%. First build

Build # 23323684713

Build Type

Pull #38

github

Committed by

web-flow

Commit Message

Merge 8ff0f1e14 into a33b40157

Pull Request Pull Request #38: New: Redis-backed projection views with distributed locking (experimental)

Coverage Stats

510 of 561 branches covered (90.91%)

176 of 206 new or added lines in 9 files covered. (85.44%)

1521 of 1551 relevant lines covered (98.07%)

41.82 hits per line

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

42.86

/src/redis/AbstractRedisProjection.ts

import type { IContainer } from 'node-cqrs';
import { AbstractProjection } from '../AbstractProjection.ts';
import { RedisView } from './RedisView.ts';

export abstract class AbstractRedisProjection<T> extends AbstractProjection<RedisView<T>> {

        static get tableName(): string {
                throw new Error('tableName is not defined');
        }

        static get schemaVersion(): string {
                throw new Error('schemaVersion is not defined');
        }

        constructor({ viewModelRedis, viewModelRedisFactory, logger }:
                Partial<Pick<IContainer, 'viewModelRedis' | 'viewModelRedisFactory' | 'logger'>>
        ) {
                super({ logger });

                this.view = new RedisView({
                        schemaVersion: new.target.schemaVersion,
                        projectionName: new.target.name,
                        viewModelRedis,
                        viewModelRedisFactory,
                        tableNamePrefix: new.target.tableName,
                        logger
                });
        }
}

1	import type { IContainer } from 'node-cqrs';
2	import { AbstractProjection } from '../AbstractProjection.ts';	3✔
3	import { RedisView } from './RedisView.ts';	3✔
4
5	export abstract class AbstractRedisProjection<T> extends AbstractProjection<RedisView<T>> {	3✔
6
7	static get tableName(): string {
NEW 8	throw new Error('tableName is not defined');	×
9	}
10
11	static get schemaVersion(): string {
NEW 12	throw new Error('schemaVersion is not defined');	×
13	}
14
15	constructor({ viewModelRedis, viewModelRedisFactory, logger }:
16	Partial<Pick<IContainer, 'viewModelRedis' \| 'viewModelRedisFactory' \| 'logger'>>
17	) {
NEW 18	super({ logger });	×
19
NEW 20	this.view = new RedisView({	×
21	schemaVersion: new.target.schemaVersion,
22	projectionName: new.target.name,
23	viewModelRedis,
24	viewModelRedisFactory,
25	tableNamePrefix: new.target.tableName,
26	logger
27	});
28	}
29	}

snatalenko / node-cqrs / 23323684713

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