add brevo email

broker/ecosystem.config.example.cjs

@@ -7,9 +7,7 @@ module.exports = {
             script: './dist/producer/src/index.js',
             env: {
                 EMAIL_SERVICE: "",
-                EMAIL_HOST: "",
-                EMAIL_USER: "",
-                EMAIL_PASS: "",
+                BREVO_API_KEY: "",
                 PORT: "",
                 MONGO_CONNECTION_STRING: "",
                 REDIS_URL: "",

broker/package.json

@@ -1,5 +1,6 @@
 {
   "dependencies": {
+    "@getbrevo/brevo": "^2.2.0",
     "cors": "^2.8.5",
     "express": "^4.19.2",
     "mongoose": "^8.3.2",

broker/src/Controller.ts

@@ -6,12 +6,7 @@ import { requireEnv } from "../../shared/utilts/requireEnv";
 import { TProjectLimit } from "@schema/ProjectsLimits";
 
 if (process.env.EMAIL_SERVICE) {
-    EmailService.createTransport(
-        requireEnv('EMAIL_SERVICE'),
-        requireEnv('EMAIL_HOST'),
-        requireEnv('EMAIL_USER'),
-        requireEnv('EMAIL_PASS'),
-    );
+    EmailService.init(requireEnv('BREVO_API_KEY'));
 }
 
 export async function checkLimitsForEmail(projectCounts: TProjectLimit) {

broker/src/StreamLoopController.ts

@@ -33,7 +33,6 @@ export async function processStreamEvent(data: Record<string, string>) {
         const eventType = data._type;
         if (!eventType) return;
 
-
         const { pid, sessionHash } = data;
 
         const project = await ProjectModel.exists({ _id: pid });