Function sendNewCommentEmail

apps/web/lib/Notification.ts:254–333

(params: {
	videoId: string;
	recipientId: string;
	authorId: string;
	comment: { id: string; content: string };
})

}

async function sendNewCommentEmail(params: {
	videoId: string;
	recipientId: string;
	authorId: string;
	comment: { id: string; content: string };
}) {
	try {
		const database = db();

		// Throttle to the same set of events that actually trigger an email: a
		// top-level comment authored by someone other than the owner. Replies and
		// the owner's own comments share comments.type === "text", so without these
		// filters they'd poison the window and suppress legitimate comment emails.
		// Top-level comments persist parentCommentId as "" (not NULL) — see
		// Comment.CommentId.make("") in the share-page comment UI.
		const throttleStart = new Date(Date.now() - COMMENT_EMAIL_THROTTLE_MS);
		const [recentComment] = await database
			.select({ id: comments.id })
			.from(comments)
			.where(
				and(
					eq(comments.videoId, Video.VideoId.make(params.videoId)),
					eq(comments.type, "text"),
					or(
						isNull(comments.parentCommentId),
						eq(comments.parentCommentId, Comment.CommentId.make("")),
					),
					ne(comments.authorId, User.UserId.make(params.recipientId)),
					gte(comments.createdAt, throttleStart),
					ne(comments.id, Comment.CommentId.make(params.comment.id)),
				),
			)
			.limit(1);

		if (recentComment) return;

		const [recipient] = await database
			.select({ email: users.email })
			.from(users)
			.where(eq(users.id, User.UserId.make(params.recipientId)))
			.limit(1);

		if (!recipient?.email) return;

		const [video] = await database
			.select({ name: videos.name })
			.from(videos)
			.where(eq(videos.id, Video.VideoId.make(params.videoId)))
			.limit(1);

		const videoName = video?.name || "Untitled Video";

		const [commenter] = await database
			.select({ name: users.name })
			.from(users)
			.where(eq(users.id, User.UserId.make(params.authorId)))
			.limit(1);