email on trigger cloud function

cloud_functions/functions/src/emailOnTrigger/index.ts

@@ -0,0 +1,134 @@
+import { firestore } from "firebase-functions";
+
+import { sendEmail } from "../utils/email";
+import _config from "../functionConfig"; // generated using generateConfig.ts
+const functionConfig: any = _config;
+type EmailOnTriggerConfig = {
+  collectionPath: string;
+  templateId: string;
+  categories: string[];
+  onCreate: Boolean;
+  from: Function;
+  to: Function;
+  requiredFields: string[];
+  shouldSend: (
+    snapshot:
+      | firestore.DocumentSnapshot
+      | {
+          before: firestore.DocumentSnapshot;
+          after: firestore.DocumentSnapshot;
+        }
+  ) => Boolean;
+  onUpdate: Boolean;
+};
+
+const hasRequiredField = (requiredFields: string[], snapshotData: any) =>
+  requiredFields.reduce((acc: boolean, currField: string) => {
+    if (
+      snapshotData[currField] === undefined ||
+      snapshotData[currField] === null
+    )
+      return false;
+    else return acc;
+  }, true);
+const emailOnCreate = (config: EmailOnTriggerConfig) =>
+  firestore
+    .document(`${config.collectionPath}/{docId}`)
+    .onCreate(async (snapshot) => {
+      try {
+        const snapshotData = snapshot.data();
+        if (!snapshotData) throw Error("no snapshot data");
+
+        const shouldSend = config.shouldSend(snapshot);
+        const hasAllRequiredFields = hasRequiredField(
+          config.requiredFields,
+          snapshotData
+        );
+        const to = await config.to(snapshotData);
+        const from = await config.from(snapshotData);
+        if (shouldSend && hasAllRequiredFields) {
+          const msg = {
+            from,
+            personalizations: [
+              {
+                to,
+                dynamic_template_data: {
+                  ...snapshotData,
+                },
+              },
+            ],
+            template_id: config.templateId,
+            categories: config.categories,
+            attachments: snapshotData.attachments,
+          };
+          const resp = await sendEmail(msg);
+          console.log(JSON.stringify(resp));
+          return true;
+        } else {
+          console.log("requirements were not met");
+          return false;
+        }
+      } catch (error) {
+        console.warn(JSON.stringify(error.response.body));
+        return false;
+      }
+    });
+
+const emailOnUpdate = (config: EmailOnTriggerConfig) =>
+  firestore
+    .document(`${config.collectionPath}/{docId}`)
+    .onUpdate(async (change) => {
+      try {
+        const beforeData = change.before.data();
+        const afterData = change.after.data();
+        if (!beforeData || !afterData) throw Error("no data found in snapshot");
+        const shouldSend = config.shouldSend(change);
+        const hasAllRequiredFields = hasRequiredField(
+          config.requiredFields,
+          afterData
+        );
+        const dynamic_template_data = config.requiredFields.reduce(
+          (acc: any, curr: string) => {
+            return { ...acc, [curr]: afterData[curr] };
+          },
+          {}
+        );
+        if (shouldSend && hasAllRequiredFields) {
+          const from = await config.from(afterData);
+          const to = await config.to(afterData);
+          const msg = {
+            from,
+            personalizations: [
+              {
+                to,
+                dynamic_template_data,
+              },
+            ],
+            template_id: config.templateId,
+            categories: config.categories,
+          };
+          const resp = await sendEmail(msg);
+          console.log(JSON.stringify(resp));
+
+          return true;
+        } else {
+          console.log("requirements were not met");
+          return false;
+        }
+      } catch (error) {
+        console.warn(error);
+        return false;
+      }
+    });
+
+const emailOnTriggerFns = (config: EmailOnTriggerConfig) =>
+  Object.entries({
+    onCreate: config.onCreate ? emailOnCreate(config) : null,
+    onUpdate: config.onUpdate ? emailOnUpdate(config) : null,
+  }).reduce((a, [k, v]) => (v === null ? a : { ...a, [k]: v }), {});
+
+export const FT_email = {
+  [functionConfig.collectionPath
+    .replace(/\//g, "_")
+    .replace(/_{.*?}_/g, "_")]: emailOnTriggerFns(functionConfig),
+};

cloud_functions/functions/src/index.ts

@@ -17,3 +17,4 @@ export { FT_subTableStats } from "./subTableStats";
 export { FT_compressedThumbnail } from "./compressedThumbnail";
 export { actionScript } from "./actionScript";
 export { webhook } from "./webhooks";
+export { FT_email } from "./emailOnTrigger";