Function notifyUsers

apps/app-server/src/utils/notifications.ts:32–89

(
  notifications: {
    type: DeepNotesNotificationType;

    recipients: Record<string, { encryptedSymmetricKey: Uint8Array }>;

    encryptedContent: Uint8Array;
  }[],
)

export type NotificationsResponse = z.infer<typeof notificationsResponseSchema>;

export async function notifyUsers(
  notifications: {
    type: DeepNotesNotificationType;

    recipients: Record<string, { encryptedSymmetricKey: Uint8Array }>;

    encryptedContent: Uint8Array;
  }[],
) {
  await dataAbstraction().transaction(async ({ trx }) => {
    const dateTime = new Date();

    await Promise.all(
      notifications.map(async ({ recipients, type, encryptedContent }) => {
        const notificationId = parseInt(
          (
            await NotificationModel.query(trx)
              .insert({
                type,

                encrypted_content: encryptedContent,

                datetime: dateTime,
              })
              .returning('id')
          ).id as any,
        );

        await Promise.all(
          objEntries(recipients).map(
            async ([userId, { encryptedSymmetricKey }]) => {
              await UserNotificationModel.query(trx).insert({
                user_id: userId,
                notification_id: notificationId,

                encrypted_symmetric_key: encryptedSymmetricKey,
              });

              await getRedis().publish(
                `user-notification:${userId}`,
                pack({
                  id: notificationId,

                  type,

                  encryptedSymmetricKey: encryptedSymmetricKey,
                  encryptedContent: encryptedContent,

                  dateTime,
                } as DeepNotesNotification),
              );
            },
          ),
        );
      }),
    );
  });
}