From 3b9c44b0a8af5a9867ce2e9ca4b8939764c87178 Mon Sep 17 00:00:00 2001
From: Patrick Fic <>
Date: Mon, 22 Aug 2022 13:02:02 -0700
Subject: [PATCH] IO-1984 Email Audit Trail

---
 bodyshop_translations.babel                   | 107 ++++++++++++++++-
 .../audit-trail-list.container.jsx            |  20 +++-
 .../email-audit-trail-list.component.jsx      |  64 +++++++++++
 .../email-overlay/email-overlay.container.jsx |   8 +-
 .../job-audit-trail.component.jsx             | 108 ++++++++++++++++--
 client/src/graphql/audit_trail.queries.js     |  14 +++
 client/src/translations/en_us/common.json     |   5 +
 client/src/translations/es/common.json        |   5 +
 client/src/translations/fr/common.json        |   5 +
 hasura/metadata/tables.yaml                   | 108 ++++++++++++++++++
 .../down.sql                                  |   1 +
 .../up.sql                                    |  18 +++
 .../down.sql                                  |   1 +
 .../up.sql                                    |  18 +++
 .../down.sql                                  |   1 +
 .../up.sql                                    |   5 +
 .../down.sql                                  |   1 +
 .../up.sql                                    |   5 +
 .../down.sql                                  |   1 +
 .../up.sql                                    |   5 +
 server/email/sendemail.js                     |  30 ++++-
 server/graphql-client/queries.js              |   7 ++
 22 files changed, 518 insertions(+), 19 deletions(-)
 create mode 100644 client/src/components/audit-trail-list/email-audit-trail-list.component.jsx
 create mode 100644 hasura/migrations/1661191155179_create_table_public_email_audit_trail/down.sql
 create mode 100644 hasura/migrations/1661191155179_create_table_public_email_audit_trail/up.sql
 create mode 100644 hasura/migrations/1661193068342_create_table_public_email_audit_trail/down.sql
 create mode 100644 hasura/migrations/1661193068342_create_table_public_email_audit_trail/up.sql
 create mode 100644 hasura/migrations/1661193112109_set_fk_public_email_audit_trail_bodyshopid/down.sql
 create mode 100644 hasura/migrations/1661193112109_set_fk_public_email_audit_trail_bodyshopid/up.sql
 create mode 100644 hasura/migrations/1661193135139_set_fk_public_email_audit_trail_jobid/down.sql
 create mode 100644 hasura/migrations/1661193135139_set_fk_public_email_audit_trail_jobid/up.sql
 create mode 100644 hasura/migrations/1661193154564_set_fk_public_email_audit_trail_useremail/down.sql
 create mode 100644 hasura/migrations/1661193154564_set_fk_public_email_audit_trail_useremail/up.sql

diff --git a/bodyshop_translations.babel b/bodyshop_translations.babel
index 889b1b9ab..6308f9813 100644
--- a/bodyshop_translations.babel
+++ b/bodyshop_translations.babel
@@ -1,4 +1,4 @@
-<babeledit_project be_version="2.7.1" version="1.2">
+<babeledit_project version="1.2" be_version="2.7.1">
     <!--
 
     BabelEdit project file
@@ -1149,6 +1149,48 @@
                             <folder_node>
                                 <name>fields</name>
                                 <children>
+                                    <concept_node>
+                                        <name>cc</name>
+                                        <definition_loaded>false</definition_loaded>
+                                        <description></description>
+                                        <comment></comment>
+                                        <default_text></default_text>
+                                        <translations>
+                                            <translation>
+                                                <language>en-US</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>es-MX</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>fr-CA</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                        </translations>
+                                    </concept_node>
+                                    <concept_node>
+                                        <name>contents</name>
+                                        <definition_loaded>false</definition_loaded>
+                                        <description></description>
+                                        <comment></comment>
+                                        <default_text></default_text>
+                                        <translations>
+                                            <translation>
+                                                <language>en-US</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>es-MX</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>fr-CA</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                        </translations>
+                                    </concept_node>
                                     <concept_node>
                                         <name>created</name>
                                         <definition_loaded>false</definition_loaded>
@@ -1191,6 +1233,48 @@
                                             </translation>
                                         </translations>
                                     </concept_node>
+                                    <concept_node>
+                                        <name>subject</name>
+                                        <definition_loaded>false</definition_loaded>
+                                        <description></description>
+                                        <comment></comment>
+                                        <default_text></default_text>
+                                        <translations>
+                                            <translation>
+                                                <language>en-US</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>es-MX</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>fr-CA</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                        </translations>
+                                    </concept_node>
+                                    <concept_node>
+                                        <name>to</name>
+                                        <definition_loaded>false</definition_loaded>
+                                        <description></description>
+                                        <comment></comment>
+                                        <default_text></default_text>
+                                        <translations>
+                                            <translation>
+                                                <language>en-US</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>es-MX</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>fr-CA</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                        </translations>
+                                    </concept_node>
                                     <concept_node>
                                         <name>useremail</name>
                                         <definition_loaded>false</definition_loaded>
@@ -27364,6 +27448,27 @@
                                             </translation>
                                         </translations>
                                     </concept_node>
+                                    <concept_node>
+                                        <name>emailaudit</name>
+                                        <definition_loaded>false</definition_loaded>
+                                        <description></description>
+                                        <comment></comment>
+                                        <default_text></default_text>
+                                        <translations>
+                                            <translation>
+                                                <language>en-US</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>es-MX</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>fr-CA</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                        </translations>
+                                    </concept_node>
                                     <concept_node>
                                         <name>employeeassignments</name>
                                         <definition_loaded>false</definition_loaded>
diff --git a/client/src/components/audit-trail-list/audit-trail-list.container.jsx b/client/src/components/audit-trail-list/audit-trail-list.container.jsx
index 71a8b56a3..966f8e2ff 100644
--- a/client/src/components/audit-trail-list/audit-trail-list.container.jsx
+++ b/client/src/components/audit-trail-list/audit-trail-list.container.jsx
@@ -4,6 +4,8 @@ import { useQuery } from "@apollo/client";
 import { QUERY_AUDIT_TRAIL } from "../../graphql/audit_trail.queries";
 import AlertComponent from "../alert/alert.component";
 import { logImEXEvent } from "../../firebase/firebase.utils";
+import EmailAuditTrailListComponent from "./email-audit-trail-list.component";
+import { Card, Row } from "antd";
 
 export default function AuditTrailListContainer({ recordId }) {
   const { loading, error, data } = useQuery(QUERY_AUDIT_TRAIL, {
@@ -18,10 +20,20 @@ export default function AuditTrailListContainer({ recordId }) {
       {error ? (
         <AlertComponent type="error" message={error.message} />
       ) : (
-        <AuditTrailListComponent
-          loading={loading}
-          data={data ? data.audit_trail : null}
-        />
+        <Row gutter={[16, 16]}>
+          <Card>
+            <AuditTrailListComponent
+              loading={loading}
+              data={data ? data.audit_trail : []}
+            />
+          </Card>
+          <Card>
+            <EmailAuditTrailListComponent
+              loading={loading}
+              data={data ? data.audit_trail : []}
+            />
+          </Card>
+        </Row>
       )}
     </div>
   );
diff --git a/client/src/components/audit-trail-list/email-audit-trail-list.component.jsx b/client/src/components/audit-trail-list/email-audit-trail-list.component.jsx
new file mode 100644
index 000000000..e40c6b7ed
--- /dev/null
+++ b/client/src/components/audit-trail-list/email-audit-trail-list.component.jsx
@@ -0,0 +1,64 @@
+import React, { useState } from "react";
+import { Table } from "antd";
+import { alphaSort } from "../../utils/sorters";
+import { DateTimeFormatter } from "../../utils/DateFormatter";
+import { useTranslation } from "react-i18next";
+import AuditTrailValuesComponent from "../audit-trail-values/audit-trail-values.component";
+
+export default function EmailAuditTrailListComponent({ loading, data }) {
+  const [state, setState] = useState({
+    sortedInfo: {},
+    filteredInfo: {},
+  });
+  const { t } = useTranslation();
+  const columns = [
+    {
+      title: t("audit.fields.created"),
+      dataIndex: " created",
+      key: " created",
+      width: "10%",
+      render: (text, record) => (
+        <DateTimeFormatter>{record.created}</DateTimeFormatter>
+      ),
+      sorter: (a, b) => a.created - b.created,
+      sortOrder:
+        state.sortedInfo.columnKey === "created" && state.sortedInfo.order,
+    },
+
+    {
+      title: t("audit.fields.useremail"),
+      dataIndex: "useremail",
+      key: "useremail",
+      width: "10%",
+      sorter: (a, b) => alphaSort(a.useremail, b.useremail),
+      sortOrder:
+        state.sortedInfo.columnKey === "useremail" && state.sortedInfo.order,
+    },
+  ];
+
+  const formItemLayout = {
+    labelCol: {
+      xs: { span: 12 },
+      sm: { span: 5 },
+    },
+    wrapperCol: {
+      xs: { span: 24 },
+      sm: { span: 12 },
+    },
+  };
+  const handleTableChange = (pagination, filters, sorter) => {
+    setState({ ...state, filteredInfo: filters, sortedInfo: sorter });
+  };
+
+  return (
+    <Table
+      {...formItemLayout}
+      loading={loading}
+      pagination={{ position: "top", defaultPageSize: 25 }}
+      columns={columns}
+      rowKey="id"
+      dataSource={data}
+      onChange={handleTableChange}
+    />
+  );
+}
diff --git a/client/src/components/email-overlay/email-overlay.container.jsx b/client/src/components/email-overlay/email-overlay.container.jsx
index b6728b698..95ad60426 100644
--- a/client/src/components/email-overlay/email-overlay.container.jsx
+++ b/client/src/components/email-overlay/email-overlay.container.jsx
@@ -77,6 +77,9 @@ export function EmailOverlayContainer({
     setSending(true);
     try {
       await axios.post("/sendemail", {
+        bodyshopid: bodyshop.id,
+        jobid: emailConfig.jobid,
+
         ...defaultEmailFrom,
         ReplyTo: {
           Email: from,
@@ -181,10 +184,11 @@ export function EmailOverlayContainer({
         loading: sending,
         disabled:
           selectedMedia &&
-         ( (selectedMedia
+          (selectedMedia
             .filter((s) => s.isSelected)
             .reduce((acc, val) => (acc = acc + val.size), 0) >=
-            10485760 - new Blob([form.getFieldValue("html")]).size) || selectedMedia.filter((s) => s.isSelected).length > 10),
+            10485760 - new Blob([form.getFieldValue("html")]).size ||
+            selectedMedia.filter((s) => s.isSelected).length > 10),
       }}
     >
       <Form layout="vertical" form={form} onFinish={handleFinish}>
diff --git a/client/src/components/job-audit-trail/job-audit-trail.component.jsx b/client/src/components/job-audit-trail/job-audit-trail.component.jsx
index 28730dab0..e6015c381 100644
--- a/client/src/components/job-audit-trail/job-audit-trail.component.jsx
+++ b/client/src/components/job-audit-trail/job-audit-trail.component.jsx
@@ -1,5 +1,6 @@
 import { useQuery } from "@apollo/client";
-import { Card, Table } from "antd";
+import { Button, Card, Col, Row, Table, Tag } from "antd";
+import { SyncOutlined } from "@ant-design/icons";
 import React from "react";
 import { useTranslation } from "react-i18next";
 import { QUERY_AUDIT_TRAIL } from "../../graphql/audit_trail.queries";
@@ -7,7 +8,7 @@ import { DateTimeFormatter } from "../../utils/DateFormatter";
 
 export default function JobAuditTrail({ jobId }) {
   const { t } = useTranslation();
-  const { loading, data } = useQuery(QUERY_AUDIT_TRAIL, {
+  const { loading, data, refetch } = useQuery(QUERY_AUDIT_TRAIL, {
     variables: { jobid: jobId },
     skip: !jobId,
     fetchPolicy: "network-only",
@@ -34,15 +35,102 @@ export default function JobAuditTrail({ jobId }) {
       key: "operation",
     },
   ];
+  const emailColumns = [
+    {
+      title: t("audit.fields.created"),
+      dataIndex: " created_at",
+      key: " created_at",
+      width: "10%",
+      render: (text, record) => (
+        <DateTimeFormatter>{record.created_at}</DateTimeFormatter>
+      ),
+    },
 
+    {
+      title: t("audit.fields.useremail"),
+      dataIndex: "useremail",
+      key: "useremail",
+      width: "10%",
+    },
+
+    {
+      title: t("audit.fields.to"),
+      dataIndex: "to",
+      key: "to",
+      width: "10%",
+      render: (text, record) =>
+        record.to &&
+        record.to.map((email, idx) => <Tag key={idx}>{email}</Tag>),
+    },
+    {
+      title: t("audit.fields.cc"),
+      dataIndex: "cc",
+      key: "cc",
+      width: "10%",
+      render: (text, record) =>
+        record.cc &&
+        record.cc.map((email, idx) => <Tag key={idx}>{email}</Tag>),
+    },
+    {
+      title: t("audit.fields.subject"),
+      dataIndex: "subject",
+      key: "subject",
+      width: "10%",
+    },
+    // {
+    //   title: t("audit.fields.contents"),
+    //   dataIndex: "contents",
+    //   key: "contents",
+    //   width: "10%",
+    //   render: (text, record) => (
+    //     <Button
+    //       onClick={() => {
+    //         var win = window.open(
+    //           "",
+    //           "Title",
+    //           "toolbar=no,location=no,directories=no,status=no,menubar=no,scrollbars=yes,resizable=yes,width=780,height=400,"
+    //         );
+    //         win.document.body.innerHTML = record.contents;
+    //       }}
+    //     >
+    //       Preview
+    //     </Button>
+    //   ),
+    // },
+  ];
   return (
-    <Card title={t("jobs.labels.audit")}>
-      <Table
-        loading={loading}
-        columns={columns}
-        rowKey="id"
-        dataSource={data ? data.audit_trail : []}
-      />
-    </Card>
+    <Row gutter={[16, 16]}>
+      <Col span={24}>
+        <Card
+          title={t("jobs.labels.audit")}
+          extra={
+            <Button
+              onClick={() => {
+                refetch();
+              }}
+            >
+              <SyncOutlined />
+            </Button>
+          }
+        >
+          <Table
+            loading={loading}
+            columns={columns}
+            rowKey="id"
+            dataSource={data ? data.audit_trail : []}
+          />
+        </Card>
+      </Col>
+      <Col span={24}>
+        <Card title={t("jobs.labels.emailaudit")}>
+          <Table
+            loading={loading}
+            columns={emailColumns}
+            rowKey="id"
+            dataSource={data ? data.email_audit_trail : []}
+          />
+        </Card>
+      </Col>
+    </Row>
   );
 }
diff --git a/client/src/graphql/audit_trail.queries.js b/client/src/graphql/audit_trail.queries.js
index 8fd59136e..b0c0b3f40 100644
--- a/client/src/graphql/audit_trail.queries.js
+++ b/client/src/graphql/audit_trail.queries.js
@@ -13,6 +13,20 @@ export const QUERY_AUDIT_TRAIL = gql`
       created
       bodyshopid
     }
+    email_audit_trail(
+      where: { jobid: { _eq: $jobid } }
+      order_by: { created_at: desc }
+    ) {
+      cc
+      contents
+      created_at
+      id
+      jobid
+      noteid
+      subject
+      to
+      useremail
+    }
   }
 `;
 
diff --git a/client/src/translations/en_us/common.json b/client/src/translations/en_us/common.json
index 7e6168576..bb8c56266 100644
--- a/client/src/translations/en_us/common.json
+++ b/client/src/translations/en_us/common.json
@@ -82,8 +82,12 @@
 		},
 		"audit": {
 			"fields": {
+				"cc": "CC",
+				"contents": "Contents",
 				"created": "Time",
 				"operation": "Operation",
+				"subject": "Subject",
+				"to": "To",
 				"useremail": "User",
 				"values": "Values"
 			}
@@ -1614,6 +1618,7 @@
 				"documents-images": "Images",
 				"documents-other": "Other Documents",
 				"duplicateconfirm": "Are you sure you want to duplicate this job? Some elements of this job will not be duplicated.",
+				"emailaudit": "Email Audit Trail",
 				"employeeassignments": "Employee Assignments",
 				"estimatelines": "Estimate Lines",
 				"estimator": "Estimator",
diff --git a/client/src/translations/es/common.json b/client/src/translations/es/common.json
index 2b8cf64e8..d922e3796 100644
--- a/client/src/translations/es/common.json
+++ b/client/src/translations/es/common.json
@@ -82,8 +82,12 @@
 		},
 		"audit": {
 			"fields": {
+				"cc": "",
+				"contents": "",
 				"created": "",
 				"operation": "",
+				"subject": "",
+				"to": "",
 				"useremail": "",
 				"values": ""
 			}
@@ -1614,6 +1618,7 @@
 				"documents-images": "",
 				"documents-other": "",
 				"duplicateconfirm": "",
+				"emailaudit": "",
 				"employeeassignments": "",
 				"estimatelines": "",
 				"estimator": "",
diff --git a/client/src/translations/fr/common.json b/client/src/translations/fr/common.json
index c79d4c61a..85fbba71a 100644
--- a/client/src/translations/fr/common.json
+++ b/client/src/translations/fr/common.json
@@ -82,8 +82,12 @@
 		},
 		"audit": {
 			"fields": {
+				"cc": "",
+				"contents": "",
 				"created": "",
 				"operation": "",
+				"subject": "",
+				"to": "",
 				"useremail": "",
 				"values": ""
 			}
@@ -1614,6 +1618,7 @@
 				"documents-images": "",
 				"documents-other": "",
 				"duplicateconfirm": "",
+				"emailaudit": "",
 				"employeeassignments": "",
 				"estimatelines": "",
 				"estimator": "",
diff --git a/hasura/metadata/tables.yaml b/hasura/metadata/tables.yaml
index c4ba440e2..74da59587 100644
--- a/hasura/metadata/tables.yaml
+++ b/hasura/metadata/tables.yaml
@@ -752,6 +752,13 @@
           table:
             schema: public
             name: documents
+    - name: email_audit_trails
+      using:
+        foreign_key_constraint_on:
+          column: bodyshopid
+          table:
+            schema: public
+            name: email_audit_trail
     - name: employees
       using:
         foreign_key_constraint_on:
@@ -1827,6 +1834,93 @@
                           _eq: X-Hasura-User-Id
                     - active:
                         _eq: true
+- table:
+    schema: public
+    name: email_audit_trail
+  object_relationships:
+    - name: bodyshop
+      using:
+        foreign_key_constraint_on: bodyshopid
+    - name: job
+      using:
+        foreign_key_constraint_on: jobid
+    - name: user
+      using:
+        foreign_key_constraint_on: useremail
+  insert_permissions:
+    - role: user
+      permission:
+        check:
+          bodyshop:
+            associations:
+              _and:
+                - user:
+                    authid:
+                      _eq: X-Hasura-User-Id
+                - active:
+                    _eq: true
+        columns:
+          - cc
+          - to
+          - contents
+          - subject
+          - useremail
+          - created_at
+          - updated_at
+          - bodyshopid
+          - id
+          - jobid
+          - noteid
+        backend_only: false
+  select_permissions:
+    - role: user
+      permission:
+        columns:
+          - cc
+          - to
+          - contents
+          - subject
+          - useremail
+          - created_at
+          - updated_at
+          - bodyshopid
+          - id
+          - jobid
+          - noteid
+        filter:
+          bodyshop:
+            associations:
+              _and:
+                - user:
+                    authid:
+                      _eq: X-Hasura-User-Id
+                - active:
+                    _eq: true
+  update_permissions:
+    - role: user
+      permission:
+        columns:
+          - cc
+          - to
+          - contents
+          - subject
+          - useremail
+          - created_at
+          - updated_at
+          - bodyshopid
+          - id
+          - jobid
+          - noteid
+        filter:
+          bodyshop:
+            associations:
+              _and:
+                - user:
+                    authid:
+                      _eq: X-Hasura-User-Id
+                - active:
+                    _eq: true
+        check: null
 - table:
     schema: public
     name: employee_vacation
@@ -2726,6 +2820,13 @@
           table:
             schema: public
             name: documents
+    - name: email_audit_trails
+      using:
+        foreign_key_constraint_on:
+          column: jobid
+          table:
+            schema: public
+            name: email_audit_trail
     - name: exportlogs
       using:
         foreign_key_constraint_on:
@@ -4976,6 +5077,13 @@
           table:
             schema: public
             name: audit_trail
+    - name: email_audit_trails
+      using:
+        foreign_key_constraint_on:
+          column: useremail
+          table:
+            schema: public
+            name: email_audit_trail
     - name: exportlogs
       using:
         foreign_key_constraint_on:
diff --git a/hasura/migrations/1661191155179_create_table_public_email_audit_trail/down.sql b/hasura/migrations/1661191155179_create_table_public_email_audit_trail/down.sql
new file mode 100644
index 000000000..750528c2e
--- /dev/null
+++ b/hasura/migrations/1661191155179_create_table_public_email_audit_trail/down.sql
@@ -0,0 +1 @@
+DROP TABLE "public"."email_audit_trail";
diff --git a/hasura/migrations/1661191155179_create_table_public_email_audit_trail/up.sql b/hasura/migrations/1661191155179_create_table_public_email_audit_trail/up.sql
new file mode 100644
index 000000000..26a2169ce
--- /dev/null
+++ b/hasura/migrations/1661191155179_create_table_public_email_audit_trail/up.sql
@@ -0,0 +1,18 @@
+CREATE TABLE "public"."email_audit_trail" ("id" uuid NOT NULL DEFAULT gen_random_uuid(), "created_at" timestamptz NOT NULL DEFAULT now(), "updated_at" timestamptz NOT NULL DEFAULT now(), "bodyshopid" uuid NOT NULL, "jobid" uuid, "noteid" uuid, "to" jsonb NOT NULL DEFAULT jsonb_build_array(), "cc" jsonb NOT NULL DEFAULT jsonb_build_array(), "subject" text, "contents" text, "useremail" text NOT NULL, PRIMARY KEY ("id") );
+CREATE OR REPLACE FUNCTION "public"."set_current_timestamp_updated_at"()
+RETURNS TRIGGER AS $$
+DECLARE
+  _new record;
+BEGIN
+  _new := NEW;
+  _new."updated_at" = NOW();
+  RETURN _new;
+END;
+$$ LANGUAGE plpgsql;
+CREATE TRIGGER "set_public_email_audit_trail_updated_at"
+BEFORE UPDATE ON "public"."email_audit_trail"
+FOR EACH ROW
+EXECUTE PROCEDURE "public"."set_current_timestamp_updated_at"();
+COMMENT ON TRIGGER "set_public_email_audit_trail_updated_at" ON "public"."email_audit_trail" 
+IS 'trigger to set value of column "updated_at" to current timestamp on row update';
+CREATE EXTENSION IF NOT EXISTS pgcrypto;
diff --git a/hasura/migrations/1661193068342_create_table_public_email_audit_trail/down.sql b/hasura/migrations/1661193068342_create_table_public_email_audit_trail/down.sql
new file mode 100644
index 000000000..750528c2e
--- /dev/null
+++ b/hasura/migrations/1661193068342_create_table_public_email_audit_trail/down.sql
@@ -0,0 +1 @@
+DROP TABLE "public"."email_audit_trail";
diff --git a/hasura/migrations/1661193068342_create_table_public_email_audit_trail/up.sql b/hasura/migrations/1661193068342_create_table_public_email_audit_trail/up.sql
new file mode 100644
index 000000000..26a2169ce
--- /dev/null
+++ b/hasura/migrations/1661193068342_create_table_public_email_audit_trail/up.sql
@@ -0,0 +1,18 @@
+CREATE TABLE "public"."email_audit_trail" ("id" uuid NOT NULL DEFAULT gen_random_uuid(), "created_at" timestamptz NOT NULL DEFAULT now(), "updated_at" timestamptz NOT NULL DEFAULT now(), "bodyshopid" uuid NOT NULL, "jobid" uuid, "noteid" uuid, "to" jsonb NOT NULL DEFAULT jsonb_build_array(), "cc" jsonb NOT NULL DEFAULT jsonb_build_array(), "subject" text, "contents" text, "useremail" text NOT NULL, PRIMARY KEY ("id") );
+CREATE OR REPLACE FUNCTION "public"."set_current_timestamp_updated_at"()
+RETURNS TRIGGER AS $$
+DECLARE
+  _new record;
+BEGIN
+  _new := NEW;
+  _new."updated_at" = NOW();
+  RETURN _new;
+END;
+$$ LANGUAGE plpgsql;
+CREATE TRIGGER "set_public_email_audit_trail_updated_at"
+BEFORE UPDATE ON "public"."email_audit_trail"
+FOR EACH ROW
+EXECUTE PROCEDURE "public"."set_current_timestamp_updated_at"();
+COMMENT ON TRIGGER "set_public_email_audit_trail_updated_at" ON "public"."email_audit_trail" 
+IS 'trigger to set value of column "updated_at" to current timestamp on row update';
+CREATE EXTENSION IF NOT EXISTS pgcrypto;
diff --git a/hasura/migrations/1661193112109_set_fk_public_email_audit_trail_bodyshopid/down.sql b/hasura/migrations/1661193112109_set_fk_public_email_audit_trail_bodyshopid/down.sql
new file mode 100644
index 000000000..71b66014e
--- /dev/null
+++ b/hasura/migrations/1661193112109_set_fk_public_email_audit_trail_bodyshopid/down.sql
@@ -0,0 +1 @@
+alter table "public"."email_audit_trail" drop constraint "email_audit_trail_bodyshopid_fkey";
diff --git a/hasura/migrations/1661193112109_set_fk_public_email_audit_trail_bodyshopid/up.sql b/hasura/migrations/1661193112109_set_fk_public_email_audit_trail_bodyshopid/up.sql
new file mode 100644
index 000000000..72e834b8d
--- /dev/null
+++ b/hasura/migrations/1661193112109_set_fk_public_email_audit_trail_bodyshopid/up.sql
@@ -0,0 +1,5 @@
+alter table "public"."email_audit_trail"
+  add constraint "email_audit_trail_bodyshopid_fkey"
+  foreign key ("bodyshopid")
+  references "public"."bodyshops"
+  ("id") on update cascade on delete cascade;
diff --git a/hasura/migrations/1661193135139_set_fk_public_email_audit_trail_jobid/down.sql b/hasura/migrations/1661193135139_set_fk_public_email_audit_trail_jobid/down.sql
new file mode 100644
index 000000000..1132718be
--- /dev/null
+++ b/hasura/migrations/1661193135139_set_fk_public_email_audit_trail_jobid/down.sql
@@ -0,0 +1 @@
+alter table "public"."email_audit_trail" drop constraint "email_audit_trail_jobid_fkey";
diff --git a/hasura/migrations/1661193135139_set_fk_public_email_audit_trail_jobid/up.sql b/hasura/migrations/1661193135139_set_fk_public_email_audit_trail_jobid/up.sql
new file mode 100644
index 000000000..daf253b64
--- /dev/null
+++ b/hasura/migrations/1661193135139_set_fk_public_email_audit_trail_jobid/up.sql
@@ -0,0 +1,5 @@
+alter table "public"."email_audit_trail"
+  add constraint "email_audit_trail_jobid_fkey"
+  foreign key ("jobid")
+  references "public"."jobs"
+  ("id") on update cascade on delete cascade;
diff --git a/hasura/migrations/1661193154564_set_fk_public_email_audit_trail_useremail/down.sql b/hasura/migrations/1661193154564_set_fk_public_email_audit_trail_useremail/down.sql
new file mode 100644
index 000000000..c64613215
--- /dev/null
+++ b/hasura/migrations/1661193154564_set_fk_public_email_audit_trail_useremail/down.sql
@@ -0,0 +1 @@
+alter table "public"."email_audit_trail" drop constraint "email_audit_trail_useremail_fkey";
diff --git a/hasura/migrations/1661193154564_set_fk_public_email_audit_trail_useremail/up.sql b/hasura/migrations/1661193154564_set_fk_public_email_audit_trail_useremail/up.sql
new file mode 100644
index 000000000..0979129e2
--- /dev/null
+++ b/hasura/migrations/1661193154564_set_fk_public_email_audit_trail_useremail/up.sql
@@ -0,0 +1,5 @@
+alter table "public"."email_audit_trail"
+  add constraint "email_audit_trail_useremail_fkey"
+  foreign key ("useremail")
+  references "public"."users"
+  ("email") on update cascade on delete cascade;
diff --git a/server/email/sendemail.js b/server/email/sendemail.js
index fd6bfae1a..f913911e0 100644
--- a/server/email/sendemail.js
+++ b/server/email/sendemail.js
@@ -9,6 +9,9 @@ const axios = require("axios");
 let nodemailer = require("nodemailer");
 let aws = require("aws-sdk");
 const logger = require("../utils/logger");
+const client = require("../graphql-client/graphql-client").client;
+const queries = require("../graphql-client/queries");
+
 const ses = new aws.SES({
   apiVersion: "latest",
 
@@ -141,7 +144,11 @@ exports.sendEmail = async (req, res) => {
           subject: req.body.subject,
           // info,
         });
-
+        logEmail(req, {
+          to: req.body.to,
+          cc: req.body.cc,
+          subject: req.body.subject,
+        });
         res.json({
           success: true, //response: info
         });
@@ -154,7 +161,12 @@ exports.sendEmail = async (req, res) => {
           subject: req.body.subject,
           error: err,
         });
-
+        logEmail(req, {
+          to: req.body.to,
+          cc: req.body.cc,
+          subject: req.body.subject,
+          bodyshopid: req.body.bodyshopid,
+        });
         res.status(500).json({ success: false, error: err });
       }
     }
@@ -166,3 +178,17 @@ async function getImage(imageUrl) {
   let raw = Buffer.from(image.data).toString("base64");
   return "data:" + image.headers["content-type"] + ";base64," + raw;
 }
+
+async function logEmail(req, email) {
+  await client.request(queries.INSERT_EMAIL_AUDIT, {
+    email: {
+      to: email.to,
+      cc: email.cc,
+      subject: email.subject,
+      bodyshopid: req.body.bodyshopid,
+      useremail: req.user.email,
+      contents: req.body.html,
+      jobid: req.body.jobid,
+    },
+  });
+}
diff --git a/server/graphql-client/queries.js b/server/graphql-client/queries.js
index 8494a4702..0aff88b91 100644
--- a/server/graphql-client/queries.js
+++ b/server/graphql-client/queries.js
@@ -1603,3 +1603,10 @@ exports.INSERT_EXPORT_LOG = `
     }
   }
 `;
+
+exports.INSERT_EMAIL_AUDIT = `mutation INSERT_EMAIL_AUDIT($email: email_audit_trail_insert_input!) {
+  insert_email_audit_trail_one(object: $email) {
+    id
+  }
+}
+`;