21966362039

Committed 12 Feb 2026 10:15PM UTC coverage: 85.328% (-9.1%) from 94.396%

Build # 21966362039

Build Type

Pull #28

github

Committed by

web-flow

Commit Message

Merge 9adf24177 into 828e39903

Pull Request Pull Request #28: TypeScript and event dispatching pipeline refactoring

Run Details

671 of 1008 branches covered (66.57%)

927 of 1051 new or added lines in 67 files covered. (88.2%)

49 existing lines in 13 files now uncovered.

1262 of 1479 relevant lines covered (85.33%)

33.76 hits per line

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

64.71

/src/sqlite/SqliteObjectView.ts

import { AbstractSqliteView } from './AbstractSqliteView.ts';
import type { IObjectStorage, IEventLocker } from '../interfaces/index.ts';
import { SqliteObjectStorage } from './SqliteObjectStorage.ts';
import type { Database } from 'better-sqlite3';

/**
 * SQLite-backed object view with restore locking and last-processed-event tracking
 */
export class SqliteObjectView<TRecord> extends AbstractSqliteView implements IObjectStorage<TRecord>, IEventLocker {

        #sqliteObjectStorage: SqliteObjectStorage<TRecord>;

        constructor(options: ConstructorParameters<typeof AbstractSqliteView>[0] & {
                tableNamePrefix: string
        }) {
                if (typeof options.tableNamePrefix !== 'string' || !options.tableNamePrefix.length)
                        throw new TypeError('tableNamePrefix argument must be a non-empty String');
                if (typeof options.schemaVersion !== 'string' || !options.schemaVersion.length)
                        throw new TypeError('schemaVersion argument must be a non-empty String');

                super(options);

                this.#sqliteObjectStorage = new SqliteObjectStorage<TRecord>({
                        viewModelSqliteDb: options.viewModelSqliteDb,
                        viewModelSqliteDbFactory: options.viewModelSqliteDbFactory,
                        tableName: `${options.tableNamePrefix}_${options.schemaVersion}`
                });
        }

        // eslint-disable-next-line class-methods-use-this, @typescript-eslint/no-unused-vars
        protected initialize(db: Database): Promise<void> | void {
                // No need to initialize the table here, it's done in SqliteObjectStorage
        }

        async get(id: string): Promise<TRecord | undefined> {
                if (!this.ready)
                        await this.once('ready');

                return this.#sqliteObjectStorage.get(id);
        }

        getSync(id: string) {
                return this.#sqliteObjectStorage.getSync(id);
        }

        async create(id: string, data: TRecord) {
                await this.#sqliteObjectStorage.create(id, data);
        }

        async update(id: string, update: (r: TRecord) => TRecord) {
                await this.#sqliteObjectStorage.update(id, update);
        }

        async updateEnforcingNew(id: string, update: (r?: TRecord) => TRecord) {
                await this.#sqliteObjectStorage.updateEnforcingNew(id, update);
        }

        async delete(id: string): Promise<boolean> {
                return this.#sqliteObjectStorage.delete(id);
        }
}

1	import { AbstractSqliteView } from './AbstractSqliteView.ts';	8✔
2	import type { IObjectStorage, IEventLocker } from '../interfaces/index.ts';
3	import { SqliteObjectStorage } from './SqliteObjectStorage.ts';	8✔
4	import type { Database } from 'better-sqlite3';
5
6	/**
7	* SQLite-backed object view with restore locking and last-processed-event tracking
8	*/
9	export class SqliteObjectView<TRecord> extends AbstractSqliteView implements IObjectStorage<TRecord>, IEventLocker {	8✔
10
11	#sqliteObjectStorage: SqliteObjectStorage<TRecord>;
12
13	constructor(options: ConstructorParameters<typeof AbstractSqliteView>[0] & {
14	tableNamePrefix: string
15	}) {
16	if (typeof options.tableNamePrefix !== 'string' \|\| !options.tableNamePrefix.length)	8!
NEW 17	throw new TypeError('tableNamePrefix argument must be a non-empty String');	×
18	if (typeof options.schemaVersion !== 'string' \|\| !options.schemaVersion.length)	8✔
NEW 19	throw new TypeError('schemaVersion argument must be a non-empty String');	×
20
21	super(options);	8✔
22
23	this.#sqliteObjectStorage = new SqliteObjectStorage<TRecord>({	8✔
24	viewModelSqliteDb: options.viewModelSqliteDb,
25	viewModelSqliteDbFactory: options.viewModelSqliteDbFactory,
26	tableName: `${options.tableNamePrefix}_${options.schemaVersion}`
27	});
28	}
29
30	// eslint-disable-next-line class-methods-use-this, @typescript-eslint/no-unused-vars
31	protected initialize(db: Database): Promise<void> \| void {
32	// No need to initialize the table here, it's done in SqliteObjectStorage
33	}
34
35	async get(id: string): Promise<TRecord \| undefined> {
36	if (!this.ready)	8✔
37	await this.once('ready');	2✔
38
39	return this.#sqliteObjectStorage.get(id);	8✔
40	}
41
42	getSync(id: string) {
NEW 43	return this.#sqliteObjectStorage.getSync(id);	×
44	}
45
46	async create(id: string, data: TRecord) {
47	await this.#sqliteObjectStorage.create(id, data);	2✔
48	}
49
50	async update(id: string, update: (r: TRecord) => TRecord) {
NEW 51	await this.#sqliteObjectStorage.update(id, update);	×
52	}
53
54	async updateEnforcingNew(id: string, update: (r?: TRecord) => TRecord) {
NEW 55	await this.#sqliteObjectStorage.updateEnforcingNew(id, update);	×
56	}
57
58	async delete(id: string): Promise<boolean> {
NEW 59	return this.#sqliteObjectStorage.delete(id);	×
60	}
61	}

snatalenko / node-cqrs / 21966362039

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