forked from mfts/papermark
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
21 changed files
with
650 additions
and
94 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,162 @@ | ||
| import { logger, task } from "@trigger.dev/sdk/v3"; | ||
|
|
||
| import prisma from "@/lib/prisma"; | ||
|
|
||
| import { ZNotificationPreferencesSchema } from "../types"; | ||
|
|
||
| type NotificationPayload = { | ||
| dataroomId: string; | ||
| dataroomDocumentId: string; | ||
| senderUserId: string; | ||
| teamId: string; | ||
| }; | ||
|
|
||
| export const sendDataroomChangeNotificationTask = task({ | ||
| id: "send-dataroom-change-notification", | ||
| retry: { maxAttempts: 3 }, | ||
| run: async (payload: NotificationPayload) => { | ||
| // Get all verified viewers for this dataroom | ||
| const viewers = await prisma.viewer.findMany({ | ||
| where: { | ||
| teamId: payload.teamId, | ||
| views: { | ||
| some: { | ||
| dataroomId: payload.dataroomId, | ||
| viewType: "DATAROOM_VIEW", | ||
| verified: true, | ||
| }, | ||
| }, | ||
| }, | ||
| select: { | ||
| id: true, | ||
| notificationPreferences: true, | ||
| views: { | ||
| where: { | ||
| dataroomId: payload.dataroomId, | ||
| viewType: "DATAROOM_VIEW", | ||
| verified: true, | ||
| }, | ||
| orderBy: { | ||
| viewedAt: "desc", | ||
| }, | ||
| take: 1, | ||
| include: { | ||
| link: { | ||
| select: { | ||
| id: true, | ||
| slug: true, | ||
| domainSlug: true, | ||
| domainId: true, | ||
| isArchived: true, | ||
| expiresAt: true, | ||
| }, | ||
| }, | ||
| }, | ||
| }, | ||
| }, | ||
| }); | ||
|
|
||
| if (!viewers || viewers.length === 0) { | ||
| logger.info("No verified viewers found for this dataroom", { | ||
| dataroomId: payload.dataroomId, | ||
| }); | ||
| return; | ||
| } | ||
|
|
||
| // Construct simplified viewer objects with email and link info, excluding expired/archived links | ||
| const viewersWithLinks = viewers | ||
| .map((viewer) => { | ||
| const view = viewer.views[0]; | ||
| const link = view?.link; | ||
|
|
||
| // Skip if link is expired or archived | ||
| if ( | ||
| !link || | ||
| link.isArchived || | ||
| (link.expiresAt && new Date(link.expiresAt) < new Date()) | ||
| ) { | ||
| return null; | ||
| } | ||
|
|
||
| // Skip if notifications are disabled for this dataroom | ||
| const parsedPreferences = ZNotificationPreferencesSchema.safeParse( | ||
| viewer.notificationPreferences, | ||
| ); | ||
| if ( | ||
| parsedPreferences.success && | ||
| parsedPreferences.data.dataroom[payload.dataroomId]?.enabled === false | ||
| ) { | ||
| return null; | ||
| } | ||
|
|
||
| let linkUrl = ""; | ||
| if (link.domainId && link.domainSlug && link.slug) { | ||
| linkUrl = `https://${link.domainSlug}/${link.slug}`; | ||
| } else { | ||
| linkUrl = `${process.env.NEXT_PUBLIC_MARKETING_URL}/view/${link.id}`; | ||
| } | ||
|
|
||
| return { | ||
| id: viewer.id, | ||
| linkUrl, | ||
| }; | ||
| }) | ||
| .filter( | ||
| (viewer): viewer is { id: string; linkUrl: string } => viewer !== null, | ||
| ); | ||
|
|
||
| logger.info("Processed viewer links", { | ||
| viewerCount: viewersWithLinks.length, | ||
| }); | ||
|
|
||
| // Send notification to each viewer | ||
| for (const viewer of viewersWithLinks) { | ||
| try { | ||
| const response = await fetch( | ||
| `${process.env.NEXT_PUBLIC_BASE_URL}/api/jobs/send-dataroom-new-document-notification`, | ||
| { | ||
| method: "POST", | ||
| body: JSON.stringify({ | ||
| dataroomId: payload.dataroomId, | ||
| linkUrl: viewer.linkUrl, | ||
| dataroomDocumentId: payload.dataroomDocumentId, | ||
| viewerId: viewer.id, | ||
| senderUserId: payload.senderUserId, | ||
| teamId: payload.teamId, | ||
| }), | ||
| headers: { | ||
| "Content-Type": "application/json", | ||
| Authorization: `Bearer ${process.env.INTERNAL_API_KEY}`, | ||
| }, | ||
| }, | ||
| ); | ||
|
|
||
| if (!response.ok) { | ||
| logger.error("Failed to send dataroom notification", { | ||
| viewerId: viewer.id, | ||
| dataroomId: payload.dataroomId, | ||
| error: await response.text(), | ||
| }); | ||
| continue; | ||
| } | ||
|
|
||
| const { message } = (await response.json()) as { message: string }; | ||
| logger.info("Notification sent successfully", { | ||
| viewerId: viewer.id, | ||
| message, | ||
| }); | ||
| } catch (error) { | ||
| logger.error("Error sending notification", { | ||
| viewerId: viewer.id, | ||
| error, | ||
| }); | ||
| } | ||
| } | ||
|
|
||
| logger.info("Completed sending notifications", { | ||
| dataroomId: payload.dataroomId, | ||
| viewerCount: viewers.length, | ||
| }); | ||
| return; | ||
| }, | ||
| }); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,32 @@ | ||
| import jwt from "jsonwebtoken"; | ||
|
|
||
| const JWT_SECRET = process.env.NEXT_PRIVATE_UNSUBSCRIBE_JWT_SECRET as string; | ||
| const UNSUBSCRIBE_BASE_URL = process.env.NEXT_PUBLIC_BASE_URL as string; | ||
|
|
||
| type UnsubscribePayload = { | ||
| viewerId: string; | ||
| dataroomId: string; | ||
| teamId: string; | ||
| exp?: number; // Expiration timestamp | ||
| }; | ||
|
|
||
| export function generateUnsubscribeUrl(payload: UnsubscribePayload): string { | ||
| // Add expiration of 3 months | ||
| const tokenPayload = { | ||
| ...payload, | ||
| exp: Math.floor(Date.now() / 1000) + 60 * 60 * 24 * 90, | ||
| }; | ||
|
|
||
| const token = jwt.sign(tokenPayload, JWT_SECRET); | ||
| return `${UNSUBSCRIBE_BASE_URL}/api/unsubscribe/dataroom?token=${token}`; | ||
| } | ||
|
|
||
| export function verifyUnsubscribeToken( | ||
| token: string, | ||
| ): UnsubscribePayload | null { | ||
| try { | ||
| return jwt.verify(token, JWT_SECRET) as UnsubscribePayload; | ||
| } catch (error) { | ||
| return null; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.