12769251877

Committed 14 Jan 2025 02:02PM UTC coverage: 48.438% (+0.01%) from 48.424%

Build # 12769251877

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #10195 from hicommonwealth/kaleemNeslit.10139.recap_email

improve the recape email design

Run Details

1310 of 3019 branches covered (43.39%)

Branch coverage included in aggregate %.

19 of 25 new or added lines in 5 files covered. (76.0%)

2582 of 5016 relevant lines covered (51.48%)

34.89 hits per line

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

84.0

/libs/model/src/utils/handleSubscriptionPreferencesUpdate.ts

import { InvalidState } from '@hicommonwealth/core';
import * as schemas from '@hicommonwealth/schemas';
import { SubscriptionPreference } from '@hicommonwealth/schemas';
import { z } from 'zod';
import { models } from '../database';
import { mustExist } from '../middleware/guards';
import { emitEvent } from './utils';

function getDifferences(
  fullObject: Record<string, unknown>,
  subsetObject: Record<string, unknown>,
): Partial<z.infer<typeof SubscriptionPreference>> {
  const differences: Record<string, unknown> = {};
  for (const key in subsetObject) {
    if (
      key !== 'id' &&
      key in subsetObject &&
      subsetObject[key] !== fullObject[key]
    ) {
      differences[key] = subsetObject[key];
    }
  }
  return differences;
}

export async function handleSubscriptionPreferencesUpdate({
  userIdentifier,
  payload,
}: {
  userIdentifier: number;
  payload: Partial<z.infer<typeof SubscriptionPreference>>;
}) {
  const existingPreferences: z.infer<typeof SubscriptionPreference> | null =
    await models.SubscriptionPreference.findOne({
      where: {
        user_id: userIdentifier,
      },
      raw: true,
    });

  mustExist('existingPreferences', existingPreferences);

  const preferenceUpdates = getDifferences(existingPreferences, payload);
  if (!Object.keys(preferenceUpdates).length) {
    return existingPreferences;
  }
  let result;
  await models.sequelize.transaction(async (transaction) => {
    result = await models.SubscriptionPreference.update(payload, {
      where: { user_id: userIdentifier },
      returning: true,
      transaction,
    });
    if (result[1].length !== 1) {
      throw new InvalidState('Failed to update subscription preferences');
    }

    await emitEvent(
      models.Outbox,
      [
        {
          event_name: schemas.EventNames.SubscriptionPreferencesUpdated,
          event_payload: {
            user_id: existingPreferences.user_id,
            ...preferenceUpdates,
          },
        },
      ],
      transaction,
    );
  });

  return result![1][0].get({ plain: true });
}

1	import { InvalidState } from '@hicommonwealth/core';
2	import * as schemas from '@hicommonwealth/schemas';
3	import { SubscriptionPreference } from '@hicommonwealth/schemas';
4	import { z } from 'zod';
5	import { models } from '../database';
6	import { mustExist } from '../middleware/guards';
7	import { emitEvent } from './utils';
8
9	function getDifferences(
10	fullObject: Record<string, unknown>,
11	subsetObject: Record<string, unknown>,
12	): Partial<z.infer<typeof SubscriptionPreference>> {
13	const differences: Record<string, unknown> = {};	7✔
14	for (const key in subsetObject) {	7✔
15	if (	18✔
16	key !== 'id' &&	40✔
17	key in subsetObject &&
18	subsetObject[key] !== fullObject[key]
19	) {
20	differences[key] = subsetObject[key];	11✔
21	}
22	}
23	return differences;	7✔
24	}
25
26	export async function handleSubscriptionPreferencesUpdate({
27	userIdentifier,
28	payload,
29	}: {
30	userIdentifier: number;
31	payload: Partial<z.infer<typeof SubscriptionPreference>>;
32	}) {
33	const existingPreferences: z.infer<typeof SubscriptionPreference> \| null =
34	await models.SubscriptionPreference.findOne({	7✔
35	where: {
36	user_id: userIdentifier,
37	},
38	raw: true,
39	});
40
41	mustExist('existingPreferences', existingPreferences);	7✔
42
43	const preferenceUpdates = getDifferences(existingPreferences, payload);	7✔
44	if (!Object.keys(preferenceUpdates).length) {	7!
NEW 45	return existingPreferences;	×
46	}
47	let result;
48	await models.sequelize.transaction(async (transaction) => {	7✔
49	result = await models.SubscriptionPreference.update(payload, {	7✔
50	where: { user_id: userIdentifier },
51	returning: true,
52	transaction,
53	});
54	if (result[1].length !== 1) {	7!
NEW 55	throw new InvalidState('Failed to update subscription preferences');	×
56	}
57
58	await emitEvent(	7✔
59	models.Outbox,
60	[
61	{
62	event_name: schemas.EventNames.SubscriptionPreferencesUpdated,
63	event_payload: {
64	user_id: existingPreferences.user_id,
65	...preferenceUpdates,
66	},
67	},
68	],
69	transaction,
70	);
71	});
72
73	return result![1][0].get({ plain: true });	7✔
74	}

hicommonwealth / commonwealth / 12769251877

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