10474794077

Committed 20 Aug 2024 03:42PM UTC coverage: 0.449% (-14.8%) from 15.248%

Build # 10474794077

Build Type

Pull #8911

github

Committed by

web-flow

Commit Message

Merge 24dd5f0e6 into e90d468fa

Pull Request Pull Request #8911: Remove legacy notifications from client

Run Details

71 of 13950 branches covered (0.51%)

Branch coverage included in aggregate %.

0 of 26 new or added lines in 8 files covered. (0.0%)

3150 existing lines in 298 files now uncovered.

112 of 26823 relevant lines covered (0.42%)

0.01 hits per line

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

0.0

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

import {
  EventHandler,
  logger,
  notificationsProvider,
  WorkflowKeys,
} from '@hicommonwealth/core';
import { models } from '@hicommonwealth/model';
import { safeTruncateBody } from '@hicommonwealth/shared';
import { Op } from 'sequelize';
import z from 'zod';
import { getCommentUrl } from '../util';

const log = logger(import.meta);

const output = z.boolean();

/**
 * This function takes a CommentCreated event and triggers a notifications provider workflow with the user +
 * comment data.
 * @param payload
 * @returns boolean or undefined - A boolean indicating if a workflow was triggered. Undefined is returned if the
 * author or community does not exist
 */
export const processCommentCreated: EventHandler<
  'CommentCreated',
  typeof output
> = async ({ payload }) => {
  const author = await models.Address.findOne({
    where: { id: payload.address_id },
    include: [{ model: models.User, required: true, attributes: ['profile'] }],
  });

  if (!author || !author.user_id) {
    log.error('Full comment author with profile not found!', undefined, {
      payload,
    });
    return false;
  }

  const community = await models.Community.findOne({
    where: { id: payload.community_id },
  });

  if (!community) {
    log.error('Comment community not found!', undefined, {
      payload,
    });
    return false;
  }

  let users: { user_id: number }[] = [];

  if (payload.parent_id) {
    users = (await models.CommentSubscription.findAll({
      where: {
        comment_id: Number(payload.parent_id),
        user_id: { [Op.not]: author.user_id },
      },
      attributes: ['user_id'],
      raw: true,
    })) as { user_id: number }[];
  } else {
    users = (await models.ThreadSubscription.findAll({
      where: {
        thread_id: payload.thread_id,
        user_id: { [Op.not]: author.user_id },
      },
      attributes: ['user_id'],
      raw: true,
    })) as { user_id: number }[];
  }

  if (users.length > 0) {
    const provider = notificationsProvider();

    return await provider.triggerWorkflow({
      key: WorkflowKeys.CommentCreation,
      users: users.map((u) => ({ id: String(u.user_id) })),
      data: {
        // @ts-expect-error StrictNullChecks
        author: author.User.profile.name || author.address.substring(0, 8),
        comment_parent_name: payload.parent_id ? 'comment' : 'thread',
        community_name: community.name,
        comment_body: safeTruncateBody(decodeURIComponent(payload.text), 255),
        comment_url: getCommentUrl(
          payload.community_id,
          payload.thread_id,
          // @ts-expect-error StrictNullChecks
          payload.id,
        ),
        comment_created_event: payload,
      },
      actor: { id: String(author.user_id) },
    });
  }

  return true;
};

1	import {
2	EventHandler,
3	logger,
4	notificationsProvider,
5	WorkflowKeys,
6	} from '@hicommonwealth/core';
7	import { models } from '@hicommonwealth/model';
8	import { safeTruncateBody } from '@hicommonwealth/shared';
9	import { Op } from 'sequelize';
10	import z from 'zod';
11	import { getCommentUrl } from '../util';
12
UNCOV 13	const log = logger(import.meta);	×
14
UNCOV 15	const output = z.boolean();	×
16
17	/**
18	* This function takes a CommentCreated event and triggers a notifications provider workflow with the user +
19	* comment data.
20	* @param payload
21	* @returns boolean or undefined - A boolean indicating if a workflow was triggered. Undefined is returned if the
22	* author or community does not exist
23	*/
24	export const processCommentCreated: EventHandler<
25	'CommentCreated',
26	typeof output
UNCOV 27	> = async ({ payload }) => {	×
UNCOV 28	const author = await models.Address.findOne({	×
29	where: { id: payload.address_id },
30	include: [{ model: models.User, required: true, attributes: ['profile'] }],
31	});
32
UNCOV 33	if (!author \|\| !author.user_id) {	×
UNCOV 34	log.error('Full comment author with profile not found!', undefined, {	×
35	payload,
36	});
UNCOV 37	return false;	×
38	}
39
UNCOV 40	const community = await models.Community.findOne({	×
41	where: { id: payload.community_id },
42	});
43
UNCOV 44	if (!community) {	×
UNCOV 45	log.error('Comment community not found!', undefined, {	×
46	payload,
47	});
UNCOV 48	return false;	×
49	}
50
UNCOV 51	let users: { user_id: number }[] = [];	×
52
UNCOV 53	if (payload.parent_id) {	×
UNCOV 54	users = (await models.CommentSubscription.findAll({	×
55	where: {
56	comment_id: Number(payload.parent_id),
57	user_id: { [Op.not]: author.user_id },
58	},
59	attributes: ['user_id'],
60	raw: true,
61	})) as { user_id: number }[];
62	} else {
UNCOV 63	users = (await models.ThreadSubscription.findAll({	×
64	where: {
65	thread_id: payload.thread_id,
66	user_id: { [Op.not]: author.user_id },
67	},
68	attributes: ['user_id'],
69	raw: true,
70	})) as { user_id: number }[];
71	}
72
UNCOV 73	if (users.length > 0) {	×
UNCOV 74	const provider = notificationsProvider();	×
75
UNCOV 76	return await provider.triggerWorkflow({	×
77	key: WorkflowKeys.CommentCreation,
UNCOV 78	users: users.map((u) => ({ id: String(u.user_id) })),	×
79	data: {
80	// @ts-expect-error StrictNullChecks
81	author: author.User.profile.name \|\| author.address.substring(0, 8),	×
82	comment_parent_name: payload.parent_id ? 'comment' : 'thread',	×
83	community_name: community.name,
84	comment_body: safeTruncateBody(decodeURIComponent(payload.text), 255),
85	comment_url: getCommentUrl(
86	payload.community_id,
87	payload.thread_id,
88	// @ts-expect-error StrictNullChecks
89	payload.id,
90	),
91	comment_created_event: payload,
92	},
93	actor: { id: String(author.user_id) },
94	});
95	}
96
UNCOV 97	return true;	×
98	};

hicommonwealth / commonwealth / 10474794077

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