20159741168

Committed 12 Dec 2025 07:35AM UTC coverage: 86.181% (-0.001%) from 86.182%

Build # 20159741168

Build Type

Pull #727

github

Committed by

web-flow

Commit Message

Merge 97ffcb5a1 into 78131da9c

Pull Request Pull Request #727: Store maybe-missed socket messages in SQLite

Run Details

984 of 1174 branches covered (83.82%)

Branch coverage included in aggregate %.

123 of 143 new or added lines in 5 files covered. (86.01%)

24 existing lines in 3 files now uncovered.

10273 of 11888 relevant lines covered (86.41%)

98.83 hits per line

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

85.71

/src/migrations/006-socketMessageQueue.cjs

'use strict';

const { sql } = require('kysely');

/**
 * @param {import('umzug').MigrationParams<import('../Uwave').default>} params
 */
async function up({ context: uw }) {
  const { db } = uw;

  await db.schema.createTable('socket_message_queue')
    // This contains a ULID which also encodes the timestamp.
    .addColumn('id', 'text', (col) => col.primaryKey())
    .addColumn('target_user_id', 'uuid', (col) => col.references('users.id'))
    .addColumn('command', 'text', (col) => col.notNull())
    .addColumn('data', 'jsonb', (col) => col.notNull().defaultTo(sql`(jsonb('null'))`))
    .execute();
}

/**
 * @param {import('umzug').MigrationParams<import('../Uwave').default>} params
 */
async function down({ context: uw }) {
  const { db } = uw;

  await db.schema.dropTable('socket_message_queue').execute();
}

module.exports = { up, down };

1	'use strict';	1✔
2		1✔
3	const { sql } = require('kysely');	1✔
4		1✔
5	/**	1✔
6	* @param {import('umzug').MigrationParams<import('../Uwave').default>} params	1✔
7	*/	1✔
8	async function up({ context: uw }) {	154✔
9	const { db } = uw;	154✔
10		154✔
11	await db.schema.createTable('socket_message_queue')	154✔
12	// This contains a ULID which also encodes the timestamp.	154✔
13	.addColumn('id', 'text', (col) => col.primaryKey())	154✔
14	.addColumn('target_user_id', 'uuid', (col) => col.references('users.id'))	154✔
15	.addColumn('command', 'text', (col) => col.notNull())	154✔
16	.addColumn('data', 'jsonb', (col) => col.notNull().defaultTo(sql`(jsonb('null'))`))	154✔
17	.execute();	154✔
18	}	154✔
19		1✔
20	/**	1✔
21	* @param {import('umzug').MigrationParams<import('../Uwave').default>} params	1✔
22	*/	1✔
NEW 23	async function down({ context: uw }) {	×
NEW 24	const { db } = uw;	×
NEW 25		×
NEW 26	await db.schema.dropTable('socket_message_queue').execute();	×
NEW 27	}	×
28		1✔
29	module.exports = { up, down };	1✔

u-wave / core / 20159741168

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