9547309928

Committed 17 Jun 2024 12:04PM UTC coverage: 12.843% (-0.002%) from 12.845%

Build # 9547309928

Build Type

Pull #8138

github

Committed by

web-flow

Commit Message

Merge 795c7151b into ea44a68a7

Pull Request Pull Request #8138: Contest rollover fix

Run Details

3841 of 35355 branches covered (10.86%)

Branch coverage included in aggregate %.

4 of 16 new or added lines in 3 files covered. (25.0%)

4 existing lines in 2 files now uncovered.

5186 of 34935 relevant lines covered (14.84%)

4.79 hits per line

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

69.16

/packages/commonwealth/server/workers/knock/eventHandlers/subscriptionPreferencesUpdated.ts

import {
  EventHandler,
  logger,
  notificationsProvider,
  RepeatFrequency,
  WorkflowKeys,
} from '@hicommonwealth/core';
import { models } from '@hicommonwealth/model';
import { DaysOfWeek } from '@knocklabs/node';
import { fileURLToPath } from 'node:url';
import z from 'zod';

const __filename = fileURLToPath(import.meta.url);
const log = logger(__filename);

const output = z.boolean();

function mapDateToDaysOfWeek(
  date: Date,
  // @ts-expect-error StrictNullChecks
): typeof DaysOfWeek[keyof typeof DaysOfWeek] {
  switch (date.getDay()) {
    case 0:
      return DaysOfWeek.Sun;
    case 1:
      return DaysOfWeek.Mon;
    case 2:
      return DaysOfWeek.Tue;
    case 3:
      return DaysOfWeek.Wed;
    case 4:
      return DaysOfWeek.Thu;
    case 5:
      return DaysOfWeek.Fri;
    case 6:
      return DaysOfWeek.Sat;
  }
}

async function createScheduleIfNotExists(
  workflowKey: WorkflowKeys.EmailRecap | WorkflowKeys.EmailDigest,
  userId: string,
): Promise<boolean> {
  const provider = notificationsProvider();

  const existingSchedules = await provider.getSchedules({
    user_id: userId,
    workflow_id: workflowKey,
  });

  if (existingSchedules.length === 0) {
    await provider.createSchedules({
      user_ids: [userId],
      workflow_id: workflowKey,
      schedule: [
        {
          frequency: RepeatFrequency.Weekly,
          days: [mapDateToDaysOfWeek(new Date())],
          hours: 12,
        },
      ],
    });
    return true;
  } else if (existingSchedules.length > 1) {
    log.error(
      `User ${userId} has more than 1 scheduled ${workflowKey} workflow run`,
      undefined,
      {
        userId,
        workflowKey,
        existingSchedules,
      },
    );
    return false;
  }

  return true;
}

async function deleteScheduleIfExists(
  workflowKey: WorkflowKeys.EmailRecap | WorkflowKeys.EmailDigest,
  userId: string,
): Promise<boolean> {
  const provider = notificationsProvider();

  const existingSchedules = await provider.getSchedules({
    user_id: userId,
    workflow_id: workflowKey,
  });

  if (existingSchedules.length === 0) return true;

  await provider.deleteSchedules({
    schedule_ids: existingSchedules.map((s) => s.id),
  });

  return true;
}

export const processSubscriptionPreferencesUpdated: EventHandler<
  'SubscriptionPreferencesUpdated',
  typeof output
> = async ({ payload }) => {
  const provider = notificationsProvider();

  // remove recap/digest email schedules if emails are completely disabled
  if (payload.email_notifications_enabled === false) {
    const existingSchedules = await provider.getSchedules({
      user_id: String(payload.user_id),
    });
    const ids = existingSchedules
      .filter(
        (s) =>
          s.workflow === WorkflowKeys.EmailDigest ||
          s.workflow === WorkflowKeys.EmailRecap,
      )
      .map((s) => s.id);
    const deletedSchedules = await provider.deleteSchedules({
      schedule_ids: ids,
    });
    const allDeleted = ids.every((id) => deletedSchedules.has(id));
    if (!allDeleted) {
      throw new Error('Failed to delete schedules');
    }

    return true;
  }

  const subPreferences = await models.SubscriptionPreference.findOne({
    where: {
      id: payload.id,
      user_id: payload.user_id,
    },
  });

  // @ts-expect-error StrictNullChecks
  if (subPreferences.email_notifications_enabled) {
    if (payload.recap_email_enabled === true) {
      await createScheduleIfNotExists(
        WorkflowKeys.EmailRecap,
        String(payload.user_id),
      );
    }

    if (payload.digest_email_enabled === true) {
      await createScheduleIfNotExists(
        WorkflowKeys.EmailDigest,
        String(payload.user_id),
      );
    }
  }

  if (payload.recap_email_enabled === false) {
    await deleteScheduleIfExists(
      WorkflowKeys.EmailRecap,
      String(payload.user_id),
    );
  }

  if (payload.digest_email_enabled === false) {
    await deleteScheduleIfExists(
      WorkflowKeys.EmailDigest,
      String(payload.user_id),
    );
  }

  return true;
};

1	import {
2	EventHandler,
3	logger,
4	notificationsProvider,
5	RepeatFrequency,
6	WorkflowKeys,
7	} from '@hicommonwealth/core';
8	import { models } from '@hicommonwealth/model';
9	import { DaysOfWeek } from '@knocklabs/node';
10	import { fileURLToPath } from 'node:url';
11	import z from 'zod';
12
13	const __filename = fileURLToPath(import.meta.url);	1✔
14	const log = logger(__filename);	1✔
15
16	const output = z.boolean();	1✔
17
18	function mapDateToDaysOfWeek(
19	date: Date,
20	// @ts-expect-error StrictNullChecks
21	): typeof DaysOfWeek[keyof typeof DaysOfWeek] {
22	switch (date.getDay()) {	1!
23	case 0:
24	return DaysOfWeek.Sun;	×
25	case 1:
26	return DaysOfWeek.Mon;	1✔
27	case 2:
28	return DaysOfWeek.Tue;	×
29	case 3:
30	return DaysOfWeek.Wed;	×
31	case 4:
32	return DaysOfWeek.Thu;	×
33	case 5:
UNCOV 34	return DaysOfWeek.Fri;	×
35	case 6:
36	return DaysOfWeek.Sat;	×
37	}
38	}
39
40	async function createScheduleIfNotExists(
41	workflowKey: WorkflowKeys.EmailRecap \| WorkflowKeys.EmailDigest,
42	userId: string,
43	): Promise<boolean> {
44	const provider = notificationsProvider();	2✔
45
46	const existingSchedules = await provider.getSchedules({	2✔
47	user_id: userId,
48	workflow_id: workflowKey,
49	});
50
51	if (existingSchedules.length === 0) {	2✔
52	await provider.createSchedules({	1✔
53	user_ids: [userId],
54	workflow_id: workflowKey,
55	schedule: [
56	{
57	frequency: RepeatFrequency.Weekly,
58	days: [mapDateToDaysOfWeek(new Date())],
59	hours: 12,
60	},
61	],
62	});
63	return true;	1✔
64	} else if (existingSchedules.length > 1) {	1!
65	log.error(	×
66	`User ${userId} has more than 1 scheduled ${workflowKey} workflow run`,
67	undefined,
68	{
69	userId,
70	workflowKey,
71	existingSchedules,
72	},
73	);
74	return false;	×
75	}
76
77	return true;	1✔
78	}
79
80	async function deleteScheduleIfExists(
81	workflowKey: WorkflowKeys.EmailRecap \| WorkflowKeys.EmailDigest,
82	userId: string,
83	): Promise<boolean> {
84	const provider = notificationsProvider();	2✔
85
86	const existingSchedules = await provider.getSchedules({	2✔
87	user_id: userId,
88	workflow_id: workflowKey,
89	});
90
91	if (existingSchedules.length === 0) return true;	2✔
92
93	await provider.deleteSchedules({	1✔
94	schedule_ids: existingSchedules.map((s) => s.id),	1✔
95	});
96
97	return true;	1✔
98	}
99
100	export const processSubscriptionPreferencesUpdated: EventHandler<
101	'SubscriptionPreferencesUpdated',
102	typeof output
103	> = async ({ payload }) => {	1✔
104	const provider = notificationsProvider();	5✔
105
106	// remove recap/digest email schedules if emails are completely disabled
107	if (payload.email_notifications_enabled === false) {	5✔
108	const existingSchedules = await provider.getSchedules({	1✔
109	user_id: String(payload.user_id),
110	});
111	const ids = existingSchedules	1✔
112	.filter(
113	(s) =>
114	s.workflow === WorkflowKeys.EmailDigest \|\|	2✔
115	s.workflow === WorkflowKeys.EmailRecap,
116	)
117	.map((s) => s.id);	2✔
118	const deletedSchedules = await provider.deleteSchedules({	1✔
119	schedule_ids: ids,
120	});
121	const allDeleted = ids.every((id) => deletedSchedules.has(id));	2✔
122	if (!allDeleted) {	1!
123	throw new Error('Failed to delete schedules');	×
124	}
125
126	return true;	1✔
127	}
128
129	const subPreferences = await models.SubscriptionPreference.findOne({	4✔
130	where: {
131	id: payload.id,
132	user_id: payload.user_id,
133	},
134	});
135
136	// @ts-expect-error StrictNullChecks
137	if (subPreferences.email_notifications_enabled) {	4!
138	if (payload.recap_email_enabled === true) {	4✔
139	await createScheduleIfNotExists(	2✔
140	WorkflowKeys.EmailRecap,
141	String(payload.user_id),
142	);
143	}
144
145	if (payload.digest_email_enabled === true) {	4!
146	await createScheduleIfNotExists(	×
147	WorkflowKeys.EmailDigest,
148	String(payload.user_id),
149	);
150	}
151	}
152
153	if (payload.recap_email_enabled === false) {	4✔
154	await deleteScheduleIfExists(	2✔
155	WorkflowKeys.EmailRecap,
156	String(payload.user_id),
157	);
158	}
159
160	if (payload.digest_email_enabled === false) {	4!
161	await deleteScheduleIfExists(	×
162	WorkflowKeys.EmailDigest,
163	String(payload.user_id),
164	);
165	}
166
167	return true;	4✔
168	};

hicommonwealth / commonwealth / 9547309928

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