added hook to send mail to moderators upon post creation

auth-server/src/controllers/eventsHook.ts

@@ -8,8 +8,8 @@ import Address from '../model/Address';
 import Notification from '../model/Notification';
 import PostSubscription from '../model/PostSubscription';
 import User from '../model/User';
-import { sendCommentMentionMail, sendNewProposalCreatedEmail, sendOwnProposalCreatedEmail, sendPostSubscriptionMail } from '../services/email';
-import { CommentCreationHookDataType, HookResponseMessageType, MessageType, OnchainLinkType, PostTypeEnum } from '../types';
+import { sendCommentMentionMail, sendNewPostCreatedEmail, sendNewProposalCreatedEmail, sendOwnProposalCreatedEmail, sendPostSubscriptionMail } from '../services/email';
+import { CommentCreationHookDataType, HookResponseMessageType, MessageType, OnchainLinkType, PostCreateType, PostTypeEnum } from '../types';
 import getMentions from '../utils/getMentions';
 import getPostCommentLink from '../utils/getPostCommentLink';
 import getPostId from '../utils/getPostId';
@@ -219,6 +219,31 @@ const sendNewProposalCreated = async (onchainLink: OnchainLinkType, responseMess
 	return { ...responseMessage, sendNewProposalCreatedMessage: messages.NEW_PROPOSAL_CREATED_MAIL_SENT };
 };
 
+const sendNewPostCreated = async (post: PostCreateType): Promise<HookResponseMessageType> => {
+	const { id, author_id, title, content } = post;
+
+	if (!id) {
+		return { sendNewPostCreatedMessage: messages.EVENT_POST_ID_NOT_FOUND };
+	}
+
+	if (!author_id) {
+		return { sendNewPostCreatedMessage: messages.EVENT_AUTHOR_ID_NOT_FOUND };
+	}
+
+	const user = await User
+		.query()
+		.findById(author_id);
+
+	if (!user) {
+		console.error('sendNewPostCreated - Unexpected empty user');
+		return { sendNewPostCreatedMessage: messages.USER_NOT_FOUND };
+	}
+
+	sendNewPostCreatedEmail(user, id, title, content);
+
+	return { sendNewPostCreatedMessage: messages.EVENT_POST_CREATED_MAIL_SENT };
+};
+
 export const commentCreateHook = async (req: Request, res: Response): Promise<void> => {
 	if (process.env.HASURA_EVENT_SECRET !== req.headers.hasura_event_secret) {
 		console.error("comment create hook failed, secrets don't match");
@@ -253,3 +278,23 @@ export const onchainLinksCreateHook = async (req: Request, res: Response): Promi
 		res.json(response);
 	}
 };
+
+export const postCreateHook = async (req: Request, res: Response): Promise<void> => {
+	if (process.env.HASURA_EVENT_SECRET !== req.headers.hasura_event_secret) {
+		console.error("post create hook failed, secrets don't match");
+		res.status(403).json({ message: messages.UNAUTHORISED });
+		return;
+	}
+
+	const post = req.body?.event?.data?.new || {};
+
+	// Doing this in background as several emails need to be sent
+	const response = await sendNewPostCreated(post);
+
+	// this response goes to hasura
+	if (response.sendNewPostCreatedMessage !== messages.EVENT_POST_CREATED_MAIL_SENT) {
+		res.status(400).json(response);
+	} else {
+		res.json(response);
+	}
+};

auth-server/src/routes.ts

@@ -6,7 +6,7 @@
 
 import { Router } from 'express';
 
-import { commentCreateHook, onchainLinksCreateHook } from './controllers/eventsHook';
+import { commentCreateHook, onchainLinksCreateHook, postCreateHook } from './controllers/eventsHook';
 
 const router = Router();
 
@@ -16,5 +16,6 @@ router.get('/healthcheck', (req, res) => {
 
 router.post('/auth/event/comment/create', commentCreateHook);
 router.post('/auth/event/onchain_link/create', onchainLinksCreateHook);
+router.post('/auth/event/post/create', postCreateHook);
 
 export default router;

auth-server/src/services/email.ts

@@ -11,6 +11,7 @@ import User from '../model/User';
 import { CommentCreationHookDataType, PostType, PostTypeEnum } from '../types';
 import {
 	commentMentionEmailTemplate,
+	newPostCreatedEmailTemplate,
 	newProposalCreatedEmailTemplate,
 	ownProposalCreatedEmailTemplate,
 	postSubscriptionMailTemplate,
@@ -226,6 +227,32 @@ export const sendNewProposalCreatedEmail = (user: User, type: PostType, url: str
 		console.error('Proposal created email not sent', e));
 };
 
+export const sendNewPostCreatedEmail = (user: User, id: number | string, title: string | undefined, content: string | undefined): void => {
+	if (!apiKey) {
+		console.warn('New proposal created email not sent due to missing API key');
+		return;
+	}
+
+	const text = ejs.render(newPostCreatedEmailTemplate, {
+		content: content,
+		domain: DOMAIN,
+		id: id,
+		title: title,
+		username: user.username || ''
+	});
+
+	const msg = {
+		from: FROM,
+		html: text,
+		subject: 'New post created',
+		text,
+		to: process.env.MODERATOR_MAIL
+	};
+
+	sgMail.send(msg).catch(e =>
+		console.error('Post created email not sent', e));
+};
+
 export const sendReportContentEmail = (username: string, network: string, reportType: string, contentId: string, reason: string, comments: string): void => {
 	if (!apiKey) {
 		console.warn('Report Content Email not sent due to missing API key');

auth-server/src/types.ts

@@ -76,6 +76,7 @@ export interface MessageType {
 export interface HookResponseMessageType {
     sendNewProposalCreatedMessage?: string;
     sendOwnProposalCreatedMessage?: string;
+    sendNewPostCreatedMessage?: string;
 }
 
 export interface ChangeResponseType extends MessageType, TokenType {}
@@ -355,3 +356,12 @@ export interface EditPostArgs {
     proposalType: string;
     proposalId: string;
 }
+
+export interface PostCreateType {
+    id: number;
+    author_id: number;
+    content?: string;
+    title?: string;
+    topic_id?: number;
+    type_id?: number;
+}

auth-server/src/utils/emailTemplates.ts

@@ -144,6 +144,20 @@ export const newProposalCreatedEmailTemplate = container(`
     </p>
 `);
 
+export const newPostCreatedEmailTemplate = container(`
+    <p>
+        Created by <%= username %>!<br/><br/>
+
+        There is a new post.<br />
+
+        Title: <%= title %><br/><br/>
+
+        Content: <%= content %><br/><br/>
+
+        Polkassembly Team
+    </p>
+`);
+
 export const reportContentEmailTemplate = container(`
     <p>
         Content Reported.<br />

auth-server/src/utils/messages.ts

@@ -40,6 +40,7 @@ export default {
 	EVENT_ADDRESS_NOT_VERIFIED: 'Address not verified.',
 	EVENT_AUTHOR_ID_NOT_FOUND: 'Author id not found',
 	EVENT_AUTHOR_NOT_FOUND: 'Author not found',
+	EVENT_POST_CREATED_MAIL_SENT: 'Post created mail sent.',
 	EVENT_POST_ID_NOT_FOUND: 'Post id not found in event.',
 	EVENT_POST_SUBSCRIPTION_MAIL_SENT: 'Post subscription mail sent.',
 	EVENT_PROPOSAL_CREATED_MAIL_SENT: 'Proposal created mail sent.',

hasura/hasura-migrations/metadata/actions.graphql

@@ -1,2 +0,0 @@
-
-

hasura/hasura-migrations/metadata/tables.yaml

@@ -880,3 +880,17 @@
             proposer_address:
               _in: X-Hasura-Polkadot
       check: null
+  event_triggers:
+  - name: post_create
+    definition:
+      enable_manual: false
+      insert:
+        columns: '*'
+    retry_conf:
+      num_retries: 0
+      interval_sec: 10
+      timeout_sec: 60
+    webhook_from_env: HASURA_POST_CREATE_EVENT_HOOK
+    headers:
+    - value: HASURA_EVENT_SECRET
+      name: HASURA_EVENT_SECRET