Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 | 12x 12x 5x 2x 3x 10x 10x 25x 10x 16x 8x | import type { Dal } from "../../../dal";
import type { CommunicationGateway } from "../gateway";
import type { CommunicationEventType, CommunicationRequest } from "../types";
export type BlogLifecyclePayload = {
proId: string;
blogId: string;
blogTitle: string;
blogUrl?: string;
approvalUrl?: string;
};
export class BlogLifecycleHandler {
constructor(
private gateway: CommunicationGateway,
private dal: Dal,
) {}
async handleApprovalRequest(payload: BlogLifecyclePayload): Promise<void> {
await this.sendToOwnersAndManagers(
payload,
"blog_approval_request",
"blog-approval-request",
`Review Required: ${payload.blogTitle}`,
);
}
async handleApprovalReminder(payload: BlogLifecyclePayload): Promise<void> {
await this.sendToOwnersAndManagers(
payload,
"blog_approval_reminder",
"blog-approval-reminder",
`Reminder: Blog approval needed - ${payload.blogTitle}`,
);
}
async handlePublished(payload: BlogLifecyclePayload): Promise<void> {
await this.sendToOwnersAndManagers(
payload,
"blog_published",
"blog-published",
`Your blog is live: ${payload.blogTitle}`,
);
}
private async sendToOwnersAndManagers(
payload: BlogLifecyclePayload,
eventType: CommunicationEventType,
template: string,
subject: string,
): Promise<void> {
const teamMembers = await this.dal.userTenantRoles.getProUsersWithContact(payload.proId);
const ownersAndManagers = teamMembers.filter(
(m) => m.role === "owner" || m.role === "manager",
);
if (ownersAndManagers.length === 0) return;
const requests: CommunicationRequest[] = ownersAndManagers.map((member) => ({
channel: "email" as const,
recipient: member.email,
eventType,
proId: payload.proId,
userId: member.userId,
metadata: { blogId: payload.blogId },
content: {
template,
subject,
props: {
blogTitle: payload.blogTitle,
blogUrl: payload.blogUrl,
approvalUrl: payload.approvalUrl,
},
recipientName: member.name,
},
}));
await this.gateway.sendMany(requests);
}
}
|