14612811384

Committed 23 Apr 2025 07:50AM UTC coverage: 45.5% (-0.4%) from 45.902%

Build # 14612811384

Build Type

Pull #11922

github

Committed by

web-flow

Commit Message

Merge f2dd1f286 into faf8a2222

Pull Request Pull Request #11922: Thread Rankings

Run Details

1639 of 3988 branches covered (41.1%)

Branch coverage included in aggregate %.

11 of 74 new or added lines in 14 files covered. (14.86%)

2 existing lines in 1 file now uncovered.

3017 of 6245 relevant lines covered (48.31%)

39.81 hits per line

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

0.0

/libs/model/src/utils/pgMultiRowUpdate.ts

import { QueryTypes, Transaction } from 'sequelize';
import { models } from '../database';

type Column = {
  setColumn: string;
  rows: { newValue: string | number; whenCaseValue: string | number }[];
};

/**
 * WARNING: NEVER USE WITH USER DERIVED INPUT. All inputs are NOT escaped!
 */
export async function pgMultiRowUpdate(
  tableName: string,
  columns: [Column, ...Column[]],
  caseColumn: string,
  transaction?: Transaction,
  updatedAtColumn?: boolean,
) {
  if (columns.length === 0) return false;

  let hasRows = false;
  for (const column of columns) {
    if (column.rows.length > 0) {
      hasRows = true;
      break;
    }
  }
  if (!hasRows) return false;

  let updates = ``;
  for (const { setColumn, rows } of columns) {
    if (rows.length === 0) continue;
    if (updates.length > 0) updates += `, \n`;

    updates += `${setColumn} = CASE `;
    for (const { whenCaseValue, newValue } of rows) {
      updates += `\n\tWHEN ${caseColumn} = ${whenCaseValue} THEN ${newValue}`;
    }
    updates += ` \n\tEND`;
  }

  const caseValues = new Set(
    columns.map((c) => c.rows.map((r) => r.whenCaseValue)).flat(),
  );
  const query = `
    UPDATE "${tableName}"
    SET ${updates} ${updatedAtColumn ? `, updated_at = NOW()` : ''}
    WHERE ${caseColumn} IN (${Array.from(caseValues).join(', ')});
  `;

  await models.sequelize.query(query, {
    transaction,
    type: QueryTypes.UPDATE,
  });
  return true;
}

1	import { QueryTypes, Transaction } from 'sequelize';
2	import { models } from '../database';
3
4	type Column = {
5	setColumn: string;
6	rows: { newValue: string \| number; whenCaseValue: string \| number }[];
7	};
8
9	/**
10	* WARNING: NEVER USE WITH USER DERIVED INPUT. All inputs are NOT escaped!
11	*/
12	export async function pgMultiRowUpdate(
13	tableName: string,
14	columns: [Column, ...Column[]],
15	caseColumn: string,
16	transaction?: Transaction,
17	updatedAtColumn?: boolean,
18	) {
19	if (columns.length === 0) return false;	×
20
21	let hasRows = false;	×
22	for (const column of columns) {	×
23	if (column.rows.length > 0) {	×
24	hasRows = true;	×
25	break;	×
26	}
27	}
28	if (!hasRows) return false;	×
29
30	let updates = ``;	×
31	for (const { setColumn, rows } of columns) {	×
32	if (rows.length === 0) continue;	×
33	if (updates.length > 0) updates += `, \n`;	×
34
35	updates += `${setColumn} = CASE `;	×
36	for (const { whenCaseValue, newValue } of rows) {	×
NEW 37	updates += `\n\tWHEN ${caseColumn} = ${whenCaseValue} THEN ${newValue}`;	×
38	}
39	updates += ` \n\tEND`;	×
40	}
41
42	const caseValues = new Set(	×
43	columns.map((c) => c.rows.map((r) => r.whenCaseValue)).flat(),	×
44	);
45	const query = `	×
46	UPDATE "${tableName}"
47	SET ${updates} ${updatedAtColumn ? `, updated_at = NOW()` : ''}	×
48	WHERE ${caseColumn} IN (${Array.from(caseValues).join(', ')});
49	`;
50
UNCOV 51	await models.sequelize.query(query, {	×
52	transaction,
53	type: QueryTypes.UPDATE,
54	});
UNCOV 55	return true;	×
56	}

hicommonwealth / commonwealth / 14612811384

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