AI/firecrawl
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/mendableai/firecrawl synced 2025-08-12 16:59:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: incorporate user preferences and notification categories

Browse Source
This commit is contained in:
Ademílson F. Tonato 2025-04-07 15:59:29 +01:00
parent 66e65d9422
commit 80bf732f50
No known key found for this signature in database
GPG Key ID: 169C7BE271C9FA3A
1 changed files with 59 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
apps/api/src/services/notification/email_notification.ts
View File

@ -48,6 +48,17 @@ const emailTemplates: Record<
},
};
// Map notification types to email categories
const notificationToEmailCategory: Record<NotificationType, 'rate_limit_warnings' | 'system_alerts'> = {
[NotificationType.APPROACHING_LIMIT]: 'system_alerts',
[NotificationType.LIMIT_REACHED]: 'system_alerts',
[NotificationType.RATE_LIMIT_REACHED]: 'rate_limit_warnings',
[NotificationType.AUTO_RECHARGE_SUCCESS]: 'system_alerts',
[NotificationType.AUTO_RECHARGE_FAILED]: 'system_alerts',
[NotificationType.CONCURRENCY_LIMIT_REACHED]: 'rate_limit_warnings',
[NotificationType.AUTO_RECHARGE_FREQUENT]: 'system_alerts',
};
export async function sendNotification(
team_id: string,
notificationType: NotificationType,
@ -66,14 +77,57 @@ export async function sendNotification(
);
}
export async function sendEmailNotification(
async function sendEmailNotification(
email: string,
notificationType: NotificationType,
) {
const resend = new Resend(process.env.RESEND_API_KEY);
try {
const { data, error } = await resend.emails.send({
// Get user's email preferences
const { data: user, error: userError } = await supabase_service
.from("users")
.select("id")
.eq("email", email)
.single();
if (userError) {
logger.debug(`Error fetching user: ${userError}`);
return { success: false };
}
// Check user's email preferences
const { data: preferences, error: prefError } = await supabase_service
.from("notification_preferences")
.select("unsubscribed_all, email_preferences")
.eq("user_id", user.id)
.single();
if (prefError) {
logger.debug(`Error fetching preferences: ${prefError}`);
return { success: false };
}
// If user has unsubscribed from all emails or we can't find their preferences, don't send
if (!preferences || preferences.unsubscribed_all) {
logger.debug(`User ${email} has unsubscribed from all emails or preferences not found`);
return { success: true }; // Return success since this is an expected case
}
// Get the email category for this notification type
const emailCategory = notificationToEmailCategory[notificationType];
// If user has unsubscribed from this category of emails, don't send
if (
preferences.email_preferences &&
Array.isArray(preferences.email_preferences) &&
!preferences.email_preferences.includes(emailCategory)
) {
logger.debug(`User ${email} has unsubscribed from ${emailCategory} emails`);
return { success: true }; // Return success since this is an expected case
}
const { error } = await resend.emails.send({
from: "Firecrawl <firecrawl@getmendableai.com>",
to: [email],
reply_to: "help@firecrawl.com",
@ -85,13 +139,15 @@ export async function sendEmailNotification(
logger.debug(`Error sending email: ${error}`);
return { success: false };
}
return { success: true };
} catch (error) {
logger.debug(`Error sending email (2): ${error}`);
return { success: false };
}
}
export async function sendNotificationInternal(
async function sendNotificationInternal(
team_id: string,
notificationType: NotificationType,
startDateString: string | null,