CrossTalkPM/src/workflows/WorkflowOrchestrator.ts

87 lines
4.1 KiB
TypeScript
Raw Normal View History

2024-02-23 06:18:00 +00:00
import { CommentParser } from "../rdrama/services/CommentParser";
2024-03-01 06:40:34 +00:00
import { CommentPoster } from "../rdrama/services/CommentPoster";
import { MessageFileName, MessageService } from "../utils/MessageService";
2024-03-05 06:25:05 +00:00
import { DatabaseService } from "../db/services/Database";
import { RedditService } from "../reddit/services/Reddit";
2024-03-05 06:25:05 +00:00
import { shouldNotifyUser } from "../utils/ShouldNotify";
2024-03-09 07:34:45 +00:00
import { Comment } from "../rdrama/models/Comment";
2024-02-23 06:18:00 +00:00
class WorkflowOrchestrator {
/**
* Executes the defined workflow for processing comments.
*/
async executeWorkflow(comment: Comment) {
2024-02-23 06:18:00 +00:00
try {
const canSend = await DatabaseService.canSendNotification();
const coolDownHours = process.env.NOTIFICATION_COOLDOWN_HOURS
if (!canSend) {
console.log(`Last Message Sent less than ${coolDownHours ? coolDownHours : 4} hours ago. Set NOTIFICATION_COOLDOWN_HOURS to change this`)
return;
2024-03-05 06:25:05 +00:00
}
await this.processComment(comment);
2024-02-23 06:18:00 +00:00
} catch (error) {
console.error('An error occurred during workflow execution:', error);
}
}
2024-03-09 07:34:45 +00:00
/**
* Processes a single comment, including posting responses and sending notifications.
* @param {Object} comment The comment to process.
*/
async processComment(comment: Comment) {
const redditUsers = CommentParser.extractUsernames(comment);
if (redditUsers.length === 0) return;
console.log('found:', redditUsers);
await this.postCommentAndNotify(comment, redditUsers[0]);
2024-03-09 07:34:45 +00:00
}
/**
* Posts a comment response and sends a notification if the user should be notified.
* @param {Object} comment The original comment.
* @param {string} redditUser The Reddit user to notify.
*/
async postCommentAndNotify(comment: Comment, redditUser: string) {
const placeholdersRdrama = { author_name: comment.author_name };
2024-03-09 07:34:45 +00:00
const userMentionExists = await DatabaseService.userMentionExists(redditUser);
if (userMentionExists) {
const commentPreviouslyMessaged = MessageService.getRandomMessage(MessageFileName.RdramaPreviousMessage, placeholdersRdrama);
if (!commentPreviouslyMessaged) throw new Error('No comments for previous Message found');
const postedComment = await CommentPoster.postComment(`c_${comment.id}`, `${commentPreviouslyMessaged}`);
console.log(`Sent Comment to`, JSON.stringify(postedComment, null, 4));
return;
}
2024-03-09 07:34:45 +00:00
const resultshouldNotifyUser = await shouldNotifyUser(redditUser);
if (!resultshouldNotifyUser) {
const commentShouldntNotify = MessageService.getRandomMessage(MessageFileName.RdramaShouldntNotify, placeholdersRdrama);
if (!commentShouldntNotify) throw new Error('No comments for Shouldnt Notify found');
const postedComment = await CommentPoster.postComment(`c_${comment.id}`, `${commentShouldntNotify}`);
console.log(`Sent Comment to`, JSON.stringify(postedComment, null, 4));
return;
}
const commentResponseRdrama = MessageService.getRandomMessage(MessageFileName.RdramaMessages, placeholdersRdrama);
if (!commentResponseRdrama) throw new Error('No comments for Rdrama found');
const postedComment = await CommentPoster.postComment(`c_${comment.id}`, `${commentResponseRdrama}`);
console.log(`Sent Comment to`, JSON.stringify(postedComment, null, 4));
2024-03-09 07:34:45 +00:00
const placeholdersReddit = {
author_name: comment.author_name,
username: redditUser,
permalink: comment.permalink
};
const redditMessage = MessageService.getRandomMessage(MessageFileName.RedditMessages, placeholdersReddit);
2024-03-09 07:34:45 +00:00
if (!redditMessage) throw new Error('No comments for Reddit found');
await DatabaseService.insertUserMention({
rdrama_comment_id: comment.id,
username: redditUser,
message: redditMessage,
});
await RedditService.sendMessage(redditUser, 'Crosstalk PM Notification', redditMessage);
}
2024-02-23 06:18:00 +00:00
}
export default WorkflowOrchestrator;