feat(cloud): add notification client (#253)

packages/auth/src/auth.ts

@@ -14,7 +14,7 @@ import * as subscriptionRepo from "@kan/db/repository/subscription.repo";
 import * as userRepo from "@kan/db/repository/user.repo";
 import * as workspaceRepo from "@kan/db/repository/workspace.repo";
 import * as schema from "@kan/db/schema";
-import { cloudMailerClient, sendEmail } from "@kan/email";
+import { notificationClient, sendEmail } from "@kan/email";
 import { createStripeClient } from "@kan/stripe";
 
 export const configuredProviders = socialProviderList.reduce<
@@ -348,17 +348,7 @@ export const initAuth = (db: dbClient) => {
             return Promise.resolve(true);
           },
           async after(user) {
-            if (cloudMailerClient) {
-              await cloudMailerClient.events.track({
-                event: "user-signup",
-                email: user.email,
-                data: {
-                  name: user.name,
-                  userId: user.id,
-                },
-              });
-            }
-
+            let avatarKey = user.image;
             if (
               user.image &&
               !user.image.includes(process.env.NEXT_PUBLIC_STORAGE_DOMAIN!)
@@ -391,6 +381,9 @@ export const initAuth = (db: dbClient) => {
                     ACL: "public-read",
                   }),
                 );
+
+                avatarKey = key;
+
                 await userRepo.update(db, user.id, {
                   image: key,
                 });
@@ -398,6 +391,40 @@ export const initAuth = (db: dbClient) => {
                 console.error(error);
               }
             }
+
+            if (notificationClient) {
+              try {
+                const [firstName, ...rest] = user.name
+                  .split(" ")
+                  .filter(Boolean);
+                const lastName = rest.length ? rest.join(" ") : undefined;
+                const avatarUrl = avatarKey
+                  ? `${env("NEXT_PUBLIC_STORAGE_URL")}/${env("NEXT_PUBLIC_AVATAR_BUCKET_NAME")}/${avatarKey}`
+                  : undefined;
+
+                await notificationClient.trigger({
+                  to: {
+                    subscriberId: user.id,
+                    firstName: firstName,
+                    lastName: lastName,
+                    email: user.email,
+                    avatar: avatarUrl,
+                    data: {
+                      emailVerified: user.emailVerified,
+                      stripeCustomerId: user.stripeCustomerId,
+                      createdAt: user.createdAt,
+                      updatedAt: user.updatedAt,
+                    },
+                  },
+                  workflowId: "user-signup",
+                });
+              } catch (error) {
+                console.error(
+                  "Error adding user to notification client",
+                  error,
+                );
+              }
+            }
           },
         },
       },

packages/email/package.json

@@ -23,7 +23,7 @@
     "typecheck": "tsc --noEmit --emitDeclarationOnly false"
   },
   "dependencies": {
-    "@plunk/node": "^3.0.3",
+    "@novu/api": "^3.11.0",
     "@react-email/components": "^0.0.25",
     "nodemailer": "^7.0.3",
     "react-email": "^3.0.1"

packages/email/src/cloudMailerClient.tsx

@@ -1,10 +0,0 @@
-import Plunk from "@plunk/node";
-
-export const cloudMailerClient =
-  process.env.NEXT_PUBLIC_KAN_ENV === "cloud" &&
-  process.env.PLUNK_API_KEY &&
-  process.env.PLUNK_API_URL
-    ? new Plunk(process.env.PLUNK_API_KEY ?? "", {
-        baseUrl: process.env.PLUNK_API_URL,
-      })
-    : null;

packages/email/src/index.tsx

@@ -1,4 +1,4 @@
 export const name = "email";
 
 export { sendEmail } from "./sendEmail";
-export { cloudMailerClient } from "./cloudMailerClient";
+export { notificationClient } from "./notificationClient";

packages/email/src/notificationClient.tsx

@@ -0,0 +1,6 @@
+import { Novu } from "@novu/api";
+
+export const notificationClient =
+  process.env.NEXT_PUBLIC_KAN_ENV === "cloud" && process.env.NOVU_API_KEY
+    ? new Novu({ secretKey: process.env.NOVU_API_KEY })
+    : null;

packages/email/src/sendEmail.tsx

@@ -1,7 +1,6 @@
 import { render } from "@react-email/render";
 import nodemailer from "nodemailer";
 
-import { cloudMailerClient } from "./cloudMailerClient";
 import JoinWorkspaceTemplate from "./templates/join-workspace";
 import MagicLinkTemplate from "./templates/magic-link";
 import ResetPasswordTemplate from "./templates/reset-password";
@@ -45,15 +44,6 @@ export const sendEmail = async (
       html,
     };
 
-    // if (cloudMailerClient) {
-    //   const response = await cloudMailerClient.emails.send({
-    //     ...options,
-    //     body: html,
-    //   });
-
-    //   return response;
-    // }
-
     const response = await transporter.sendMail(options);
 
     if (!response.accepted.length) {