Arnaud
4d5269aced
New Settings → Notifications section with a toggle per category (follow, comment, reply, reaction, rating, mention, leftover-expiring, shared shopping list) — previously it was all-or-nothing (browser permission only). userNotificationPrefs (one row per user, defaults all-on so existing users see no behavior change until they opt out of something). Gated the push send in the three places that dispatch one: lib/notifications.ts (the 6 in-app notification types), the leftover-expiry cron, and shopping-list-notify — in-app notification-center entries and email are unaffected, this only gates the push itself, matching the literal ask. Verified locally: GET/PUT round-trips correctly, disabling a category and confirming the settings page renders all 8 toggles.
96 lines
3.2 KiB
TypeScript
96 lines
3.2 KiB
TypeScript
import { db, notifications, users, recipes, eq } from "@epicure/db";
|
|
import { randomUUID } from "crypto";
|
|
import { sendPushNotification } from "./push";
|
|
import { sendEmail, notificationEmailHtml } from "./email";
|
|
import { getMessages, formatMessage } from "./i18n/server";
|
|
import { isNotificationCategoryEnabled } from "./notification-prefs";
|
|
|
|
type NotificationType = "follow" | "comment" | "reply" | "reaction" | "rating" | "mention";
|
|
|
|
type CreateNotificationOpts = {
|
|
userId: string;
|
|
type: NotificationType;
|
|
actorId: string;
|
|
recipeId?: string;
|
|
commentId?: string;
|
|
/** Rating score (1-5), only relevant for type "rating" — included in the push/email copy. */
|
|
score?: number;
|
|
};
|
|
|
|
export async function createNotification(opts: CreateNotificationOpts): Promise<void> {
|
|
if (opts.userId === opts.actorId) return; // never notify yourself
|
|
|
|
await db.insert(notifications).values({
|
|
id: randomUUID(),
|
|
userId: opts.userId,
|
|
type: opts.type,
|
|
actorId: opts.actorId,
|
|
recipeId: opts.recipeId,
|
|
commentId: opts.commentId,
|
|
});
|
|
|
|
// Push + email are best-effort side effects — never let a slow/failing SMTP
|
|
// or push provider delay or break the caller (which already does `void
|
|
// createNotification(...)`). Fire-and-forget from here too.
|
|
void dispatchAlerts(opts).catch((err) => {
|
|
console.error("[notifications] failed to dispatch push/email", err);
|
|
});
|
|
}
|
|
|
|
async function dispatchAlerts(opts: CreateNotificationOpts): Promise<void> {
|
|
const [actor, recipient, recipe] = await Promise.all([
|
|
db.query.users.findFirst({
|
|
where: eq(users.id, opts.actorId),
|
|
columns: { name: true, username: true },
|
|
}),
|
|
db.query.users.findFirst({
|
|
where: eq(users.id, opts.userId),
|
|
columns: { email: true, locale: true },
|
|
}),
|
|
opts.recipeId
|
|
? db.query.recipes.findFirst({
|
|
where: eq(recipes.id, opts.recipeId),
|
|
columns: { title: true },
|
|
})
|
|
: Promise.resolve(undefined),
|
|
]);
|
|
|
|
if (!actor || !recipient) return;
|
|
|
|
const messages = getMessages(recipient.locale);
|
|
const n = messages.notifications as Record<string, unknown>;
|
|
const detail = (n["detail"] ?? {}) as Record<string, string>;
|
|
const pushTitle = (n["pushTitle"] ?? {}) as Record<string, string>;
|
|
|
|
const template = detail[opts.type] ?? (n[opts.type] as string | undefined);
|
|
if (!template) return;
|
|
|
|
const body = formatMessage(template, {
|
|
name: actor.name,
|
|
title: recipe?.title ?? "",
|
|
stars: opts.score != null ? String(opts.score) : "",
|
|
});
|
|
const title = pushTitle[opts.type] ?? "Epicure";
|
|
|
|
const url = opts.type === "follow"
|
|
? (actor.username ? `/u/${actor.username}` : "/")
|
|
: opts.recipeId ? `/recipes/${opts.recipeId}` : "/";
|
|
|
|
if (await isNotificationCategoryEnabled(opts.userId, opts.type)) {
|
|
void sendPushNotification(opts.userId, { title, body, url }).catch((err) => {
|
|
console.error("[notifications] push failed", err);
|
|
});
|
|
}
|
|
|
|
if (recipient.email) {
|
|
const baseUrl = process.env["BETTER_AUTH_URL"] ?? "http://localhost:3000";
|
|
void sendEmail({
|
|
to: recipient.email,
|
|
subject: title,
|
|
html: notificationEmailHtml(title, body, `${baseUrl}${url}`),
|
|
}).catch((err) => {
|
|
console.error("[notifications] email failed", err);
|
|
});
|
|
}
|
|
}
|