Merged in feature/IO-1828-Front-End-Package-Updates (pull request #1225)

Feature/IO-1828 Front End Package Updates

client/src/components/job-lifecycle/job-lifecycle.component.jsx

@@ -0,0 +1,246 @@
+import React, {useCallback, useEffect, useState} from 'react';
+import day from '../../utils/day';
+import axios from 'axios';
+import {Badge, Card, Space, Table, Tag} from 'antd';
+import {gql, useQuery} from "@apollo/client";
+import {DateTimeFormatterFunction} from "../../utils/DateFormatter";
+import {isEmpty} from "lodash";
+import {useTranslation} from "react-i18next";
+
+require('./job-lifecycle.styles.scss');
+
+// show text on bar if text can fit
+export function JobLifecycleComponent({job, statuses, ...rest}) {
+    const [loading, setLoading] = useState(true);
+    const [lifecycleData, setLifecycleData] = useState(null);
+    const {t} = useTranslation();    // Used for tracking external state changes.
+
+    const {data} = useQuery(gql`
+        query get_job_test($id: uuid!){
+            jobs_by_pk(id:$id){
+                id
+                status
+            }
+        }
+    `, {
+        variables: {
+            id: job.id
+        },
+        fetchPolicy: 'cache-only'
+    });
+
+    /**
+     * Gets the lifecycle data for the job.
+     * @returns {Promise<void>}
+     */
+    const getLifecycleData = useCallback(async () => {
+        if (job && job.id && statuses && statuses.statuses) {
+            try {
+                setLoading(true);
+                const response = await axios.post("/job/lifecycle", {
+                    jobids: job.id,
+                    statuses: statuses.statuses
+                });
+                const data = response.data.transition[job.id];
+                setLifecycleData(data);
+            } catch (err) {
+                console.error(`${t('job_lifecycle.errors.fetch')}: ${err.message}`);
+            } finally {
+                setLoading(false);
+            }
+        }
+    }, [job, statuses, t]);
+
+    useEffect(() => {
+        if (!data) return;
+        setTimeout(() => {
+            getLifecycleData().catch(err => console.error(`${t('job_lifecycle.errors.fetch')}: ${err.message}`));
+        }, 500);
+    }, [data, getLifecycleData, t]);
+
+    const columns = [
+        {
+            title: t('job_lifecycle.columns.value'),
+            dataIndex: 'value',
+            key: 'value',
+        },
+        {
+            title: t('job_lifecycle.columns.start'),
+            dataIndex: 'start',
+            key: 'start',
+            render: (text) => DateTimeFormatterFunction(text),
+            sorter: (a, b) => day(a.start).unix() - day(b.start).unix(),
+        },
+        {
+            title: t('job_lifecycle.columns.relative_start'),
+            dataIndex: 'start_readable',
+            key: 'start_readable',
+        },
+        {
+            title: t('job_lifecycle.columns.end'),
+            dataIndex: 'end',
+            key: 'end',
+            sorter: (a, b) => {
+                if (isEmpty(a.end) || isEmpty(b.end)) {
+                    if (isEmpty(a.end) && isEmpty(b.end)) {
+                        return 0;
+                    }
+                    return isEmpty(a.end) ? 1 : -1;
+                }
+                return day(a.end).unix() - day(b.end).unix();
+            },
+            render: (text) => isEmpty(text) ? t('job_lifecycle.content.not_available') : DateTimeFormatterFunction(text)
+        },
+        {
+            title: t('job_lifecycle.columns.relative_end'),
+            dataIndex: 'end_readable',
+            key: 'end_readable',
+        },
+        {
+            title: t('job_lifecycle.columns.duration'),
+            dataIndex: 'duration_readable',
+            key: 'duration_readable',
+            sorter: (a, b) => a.duration - b.duration,
+        },
+    ];
+
+    return (
+        <Card loading={loading} title={t('job_lifecycle.content.title')}>
+            {!loading ? (
+                lifecycleData && lifecycleData.lifecycle && lifecycleData.durations ? (
+                    <Space direction='vertical' style={{width: '100%'}}>
+                        <Card
+                            type='inner'
+                            title={(
+                                <Space direction='horizontal' size='small'>
+                                    <Badge status='processing' count={lifecycleData.durations.totalStatuses}/>
+                                    {t('job_lifecycle.content.title_durations')}
+                                </Space>
+
+                            )}
+                            style={{width: '100%'}}
+                        >
+                            <div id="bar-container" style={{
+                                display: 'flex',
+                                width: '100%',
+                                height: '100px',
+                                textAlign: 'center',
+                                borderRadius: '5px',
+                                borderWidth: '5px',
+                                borderStyle: 'solid',
+                                borderColor: '#f0f2f5',
+                                margin: 0,
+                                padding: 0
+                            }}>
+                                {lifecycleData.durations.summations.map((key, index, array) => {
+                                    const isFirst = index === 0;
+                                    const isLast = index === array.length - 1;
+                                    return (
+                                        <div key={key.status} style={{
+                                            overflow: 'hidden',
+                                            display: 'flex',
+                                            flexDirection: 'column',
+                                            justifyContent: 'center',
+                                            alignItems: 'center',
+                                            margin: 0,
+                                            padding: 0,
+
+                                            borderTop: '1px solid #f0f2f5',
+                                            borderBottom: '1px solid #f0f2f5',
+                                            borderLeft: isFirst ? '1px solid #f0f2f5' : undefined,
+                                            borderRight: isLast ? '1px solid #f0f2f5' : undefined,
+
+                                            backgroundColor: key.color,
+                                            width: `${key.percentage}%`
+                                        }}
+                                             aria-label={`${key.status} | ${key.roundedPercentage} | ${key.humanReadable}`}
+                                             title={`${key.status} | ${key.roundedPercentage} | ${key.humanReadable}`}
+                                        >
+
+                                            {key.percentage > 15 ?
+                                                <>
+                                                    <div>{key.roundedPercentage}</div>
+                                                    <div style={{
+                                                        backgroundColor: '#f0f2f5',
+                                                        borderRadius: '5px',
+                                                        paddingRight: '2px',
+                                                        paddingLeft: '2px',
+                                                        fontSize: '0.8rem',
+                                                    }}>
+                                                        {key.status}
+                                                    </div>
+                                                </>
+                                                : null}
+                                        </div>
+                                    );
+                                })}
+                            </div>
+                            <Card type='inner' title={t('job_lifecycle.content.legend_title')}
+                                  style={{marginTop: '10px'}}>
+                                <div>
+                                    {lifecycleData.durations.summations.map((key) => (
+                                        <Tag key={key.status} color={key.color} style={{width: '13vh', padding: '4px', margin: '4px'}}>
+                                            <div
+                                                aria-label={`${key.status} | ${key.roundedPercentage} | ${key.humanReadable}`}
+                                                title={`${key.status} | ${key.roundedPercentage} | ${key.humanReadable}`}
+                                                style={{
+                                                    backgroundColor: '#f0f2f5',
+                                                    color: '#000',
+                                                    padding: '4px',
+                                                    textAlign: 'center'
+                                                }}>
+                                                {key.status} ({key.roundedPercentage})
+                                            </div>
+                                        </Tag>
+                                    ))}
+                                </div>
+                            </Card>
+                            {(lifecycleData?.durations?.humanReadableTotal) ||
+                            (lifecycleData.lifecycle[0] && lifecycleData.lifecycle[0].value && lifecycleData?.durations?.totalCurrentStatusDuration?.humanReadable) ?
+                                <Card style={{marginTop: '10px'}}>
+                                    <ul>
+                                        {lifecycleData.durations && lifecycleData.durations.humanReadableTotal &&
+                                            <li>
+                                                <span
+                                                    style={{fontWeight: 'bold'}}>{t('job_lifecycle.content.previous_status_accumulated_time')}:</span> {lifecycleData.durations.humanReadableTotal}
+                                            </li>
+                                        }
+                                        {lifecycleData.lifecycle[0] && lifecycleData.lifecycle[0].value && lifecycleData?.durations?.totalCurrentStatusDuration?.humanReadable &&
+                                            <li>
+                                                <span
+                                                    style={{fontWeight: 'bold'}}>{t('job_lifecycle.content.current_status_accumulated_time')} ({lifecycleData.lifecycle[0].value}):</span> {lifecycleData.durations.totalCurrentStatusDuration.humanReadable}
+                                            </li>
+                                        }
+                                    </ul>
+                                </Card>
+                                : null}
+                        </Card>
+                        <Card type='inner' title={(
+                            <>
+                                <Space direction="horizontal" size="small">
+                                    <Badge status='processing' count={lifecycleData.lifecycle.length}/>
+                                    {t('job_lifecycle.content.title_transitions')}
+                                </Space>
+                            </>
+                        )}>
+                            <Table style={{
+                                overflow: 'auto',
+                                width: '100%',
+                            }} columns={columns} dataSource={lifecycleData.lifecycle}/>
+                        </Card>
+                    </Space>
+                ) : (
+                    <Card type='inner' style={{textAlign: 'center'}}>
+                        {t('job_lifecycle.content.data_unavailable')}
+                    </Card>
+                )
+            ) : (
+                <Card type='inner' title={t('job_lifecycle.content.title_loading')}>
+                    {t('job_lifecycle.content.loading')}
+                </Card>
+            )}
+        </Card>
+    );
+}
+
+export default JobLifecycleComponent;

client/src/components/jobs-admin-delete-intake/jobs-admin-delete-intake.component.jsx

@@ -52,7 +52,7 @@ export default function JobAdminDeleteIntake({ job }) {
 
   return (
     <>
-      <Space>
+      <Space wrap>
         <Button
           loading={loading}
           onClick={handleDelete}

client/src/components/jobs-admin-mark-reexport/jobs-admin-mark-reexport.component.jsx

@@ -137,7 +137,7 @@ export function JobAdminMarkReexport({
 
   return (
     <>
-      <Space>
+      <Space wrap>
         <Button
           loading={loading}
           disabled={!job.date_exported}

client/src/pages/jobs-detail/jobs-detail.page.component.jsx

@@ -55,6 +55,7 @@ import { selectBodyshop } from "../../redux/user/user.selectors";
 import AuditTrailMapping from "../../utils/AuditTrailMappings";
 import UndefinedToNull from "../../utils/undefinedtonull";
 import { DateTimeFormat } from "./../../utils/DateFormatter";
+import JobLifecycleComponent from "../../components/job-lifecycle/job-lifecycle.component";
 
 const mapStateToProps = createStructuredSelector({
   bodyshop: selectBodyshop,
@@ -305,6 +306,12 @@ export function JobsDetailPage({
                       label: t("menus.jobsdetail.labor"),
                       children: <JobsDetailLaborContainer job={job} jobId={job.id} />,
                   },
+                  {
+                    key: 'lifecycle',
+                    icon: <BarsOutlined />,
+                    label: t('menus.jobsdetail.lifecycle'),
+                    children: <JobLifecycleComponent job={job} statuses={bodyshop.md_ro_statuses} />,
+                  },
                   {
                       key: "dates",
                       icon: <CalendarFilled />,

client/src/translations/en_us/common.json

@@ -113,11 +113,11 @@
 				"jobassignmentchange": "Employee {{name}} assigned to {{operation}}",
 				"jobassignmentremoved": "Employee assignment removed for {{operation}}",
 				"jobchecklist": "Checklist type \"{{type}}\" completed.  In production set to {{inproduction}}.  Status set to {{status}}.",
-				"jobinvoiced": "Job has been invoiced.",
 				"jobconverted": "Job converted and assigned number {{ro_number}}.",
 				"jobfieldchanged": "Job field $t(jobs.fields.{{field}}) changed to {{value}}.",
 				"jobimported": "Job imported.",
 				"jobinproductionchange": "Job production status set to {{inproduction}}",
+				"jobinvoiced": "Job has been invoiced.",
 				"jobioucreated": "IOU Created.",
 				"jobmodifylbradj": "Labor adjustments modified {{mod_lbr_ty}} / {{hours}}.",
 				"jobnoteadded": "Note added to Job.",
@@ -255,7 +255,6 @@
 				"saving": "Error encountered while saving. {{message}}"
 			},
 			"fields": {
-				"ReceivableCustomField": "QBO Receivable Custom Field {{number}}",
 				"address1": "Address 1",
 				"address2": "Address 2",
 				"appt_alt_transport": "Appointment Alternative Transportation Options",
@@ -332,6 +331,9 @@
 				"md_ded_notes": "Deductible Notes",
 				"md_email_cc": "Auto Email CC: $t(printcenter.subjects.jobs.{{template}})",
 				"md_from_emails": "Additional From Emails",
+				"md_functionality_toggles": {
+					"parts_queue_toggle": "Auto Add Imported/Supplemented Jobs to Parts Queue"
+				},
 				"md_hour_split": {
 					"paint": "Paint Hour Split",
 					"prep": "Prep Hour Split"
@@ -354,9 +356,6 @@
 				},
 				"md_payment_types": "Payment Types",
 				"md_referral_sources": "Referral Sources",
-				"md_functionality_toggles":  {
-					"parts_queue_toggle": "Auto Add Imported/Supplemented Jobs to Parts Queue"
-				},
 				"md_tasks_presets": {
 					"hourstype": "",
 					"memo": "",
@@ -474,6 +473,7 @@
 						"editaccess": "Users -> Edit access"
 					}
 				},
+				"ReceivableCustomField": "QBO Receivable Custom Field {{number}}",
 				"responsibilitycenter": "Responsibility Center",
 				"responsibilitycenter_accountdesc": "Account Description",
 				"responsibilitycenter_accountitem": "Item",
@@ -815,6 +815,10 @@
 				"usage": "Usage",
 				"vehicle": "Vehicle Description"
 			},
+			"readiness": {
+				"notready": "Not Ready",
+				"ready": "Ready"
+			},
 			"status": {
 				"in": "Available",
 				"inservice": "In Service",
@@ -824,10 +828,6 @@
 			},
 			"successes": {
 				"saved": "Courtesy Car saved successfully."
-			},
-			"readiness": {
-				"notready": "Not Ready",
-				"ready": "Ready"
 			}
 		},
 		"csi": {
@@ -1249,6 +1249,31 @@
 				"updated": "Inventory line updated."
 			}
 		},
+		"job_lifecycle": {
+			"columns": {
+				"duration": "Duration",
+				"end": "End",
+				"relative_end": "Relative End",
+				"relative_start": "Relative Start",
+				"start": "Start",
+				"value": "Value"
+			},
+			"content": {
+				"current_status_accumulated_time": "Current Status Accumulated Time",
+				"data_unavailable": " There is currently no Lifecycle data for this Job.",
+				"legend_title": "Legend",
+				"loading": "Loading Job Timelines....",
+				"not_available": "N/A",
+				"previous_status_accumulated_time": "Previous Status Accumulated Time",
+				"title": "Job Lifecycle Component",
+				"title_durations": "Historical Status Durations",
+				"title_loading": "Loading",
+				"title_transitions": "Transitions"
+			},
+			"errors": {
+				"fetch": "Error getting Job Lifecycle Data"
+			}
+		},
 		"job_payments": {
 			"buttons": {
 				"goback": "Go Back",
@@ -2049,6 +2074,7 @@
 				"general": "General",
 				"insurance": "Insurance Information",
 				"labor": "Labor",
+				"lifecycle": "Lifecycle",
 				"partssublet": "Parts & Bills",
 				"rates": "Rates",
 				"repairdata": "Repair Data",
@@ -2957,8 +2983,8 @@
 			"shop-templates": "Shop Templates | $t(titles.app)",
 			"shop_vendors": "Vendors | $t(titles.app)",
 			"techconsole": "Technician Console | $t(titles.app)",
-			"techjoblookup": "Technician Job Lookup | $t(titles.app)",
 			"techjobclock": "Technician Job Clock | $t(titles.app)",
+			"techjoblookup": "Technician Job Lookup | $t(titles.app)",
 			"techshiftclock": "Technician Shift Clock | $t(titles.app)",
 			"temporarydocs": "Temporary Documents | $t(titles.app)",
 			"timetickets": "Time Tickets | $t(titles.app)",

client/src/translations/es/common.json

@@ -113,11 +113,11 @@
 				"jobassignmentchange": "",
 				"jobassignmentremoved": "",
 				"jobchecklist": "",
-				"jobinvoiced": "",
 				"jobconverted": "",
 				"jobfieldchanged": "",
 				"jobimported": "",
 				"jobinproductionchange": "",
+				"jobinvoiced": "",
 				"jobioucreated": "",
 				"jobmodifylbradj": "",
 				"jobnoteadded": "",
@@ -255,13 +255,9 @@
 				"saving": ""
 			},
 			"fields": {
-				"ReceivableCustomField": "",
 				"address1": "",
 				"address2": "",
 				"appt_alt_transport": "",
-				"md_functionality_toggles":  {
-					"parts_queue_toggle": ""
-				},
 				"appt_colors": {
 					"color": "",
 					"label": ""
@@ -335,6 +331,9 @@
 				"md_ded_notes": "",
 				"md_email_cc": "",
 				"md_from_emails": "",
+				"md_functionality_toggles": {
+					"parts_queue_toggle": ""
+				},
 				"md_hour_split": {
 					"paint": "",
 					"prep": ""
@@ -474,6 +473,7 @@
 						"editaccess": ""
 					}
 				},
+				"ReceivableCustomField": "",
 				"responsibilitycenter": "",
 				"responsibilitycenter_accountdesc": "",
 				"responsibilitycenter_accountitem": "",
@@ -815,6 +815,10 @@
 				"usage": "",
 				"vehicle": ""
 			},
+			"readiness": {
+				"notready": "",
+				"ready": ""
+			},
 			"status": {
 				"in": "",
 				"inservice": "",
@@ -824,10 +828,6 @@
 			},
 			"successes": {
 				"saved": ""
-			},
-			"readiness": {
-				"notready": "",
-				"ready": ""
 			}
 		},
 		"csi": {
@@ -1249,6 +1249,31 @@
 				"updated": ""
 			}
 		},
+		"job_lifecycle": {
+			"columns": {
+				"duration": "",
+				"end": "",
+				"relative_end": "",
+				"relative_start": "",
+				"start": "",
+				"value": ""
+			},
+			"content": {
+				"current_status_accumulated_time": "",
+				"data_unavailable": "",
+				"legend_title": "",
+				"loading": "",
+				"not_available": "",
+				"previous_status_accumulated_time": "",
+				"title": "",
+				"title_durations": "",
+				"title_loading": "",
+				"title_transitions": ""
+			},
+			"errors": {
+				"fetch": "Error al obtener los datos del ciclo de vida del trabajo"
+			}
+		},
 		"job_payments": {
 			"buttons": {
 				"goback": "",
@@ -2049,6 +2074,7 @@
 				"general": "",
 				"insurance": "",
 				"labor": "Labor",
+				"lifecycle": "",
 				"partssublet": "Piezas / Subarrendamiento",
 				"rates": "",
 				"repairdata": "Datos de reparación",
@@ -2957,8 +2983,8 @@
 			"shop-templates": "",
 			"shop_vendors": "Vendedores | $t(titles.app)",
 			"techconsole": "$t(titles.app)",
-			"techjoblookup": "$t(titles.app)",
 			"techjobclock": "$t(titles.app)",
+			"techjoblookup": "$t(titles.app)",
 			"techshiftclock": "$t(titles.app)",
 			"temporarydocs": "",
 			"timetickets": "",

client/src/translations/fr/common.json

@@ -113,11 +113,11 @@
 				"jobassignmentchange": "",
 				"jobassignmentremoved": "",
 				"jobchecklist": "",
-				"jobinvoiced": "",
 				"jobconverted": "",
 				"jobfieldchanged": "",
 				"jobimported": "",
 				"jobinproductionchange": "",
+				"jobinvoiced": "",
 				"jobioucreated": "",
 				"jobmodifylbradj": "",
 				"jobnoteadded": "",
@@ -255,7 +255,6 @@
 				"saving": ""
 			},
 			"fields": {
-				"ReceivableCustomField": "",
 				"address1": "",
 				"address2": "",
 				"appt_alt_transport": "",
@@ -332,13 +331,13 @@
 				"md_ded_notes": "",
 				"md_email_cc": "",
 				"md_from_emails": "",
+				"md_functionality_toggles": {
+					"parts_queue_toggle": ""
+				},
 				"md_hour_split": {
 					"paint": "",
 					"prep": ""
 				},
-				"md_functionality_toggles":  {
-					"parts_queue_toggle": ""
-				},
 				"md_ins_co": {
 					"city": "",
 					"name": "",
@@ -474,6 +473,7 @@
 						"editaccess": ""
 					}
 				},
+				"ReceivableCustomField": "",
 				"responsibilitycenter": "",
 				"responsibilitycenter_accountdesc": "",
 				"responsibilitycenter_accountitem": "",
@@ -815,6 +815,10 @@
 				"usage": "",
 				"vehicle": ""
 			},
+			"readiness": {
+				"notready": "",
+				"ready": ""
+			},
 			"status": {
 				"in": "",
 				"inservice": "",
@@ -824,10 +828,6 @@
 			},
 			"successes": {
 				"saved": ""
-			},
-			"readiness": {
-				"notready": "",
-				"ready": ""
 			}
 		},
 		"csi": {
@@ -1249,6 +1249,31 @@
 				"updated": ""
 			}
 		},
+		"job_lifecycle": {
+			"columns": {
+				"duration": "",
+				"end": "",
+				"relative_end": "",
+				"relative_start": "",
+				"start": "",
+				"value": ""
+			},
+			"content": {
+				"current_status_accumulated_time": "",
+				"data_unavailable": "",
+				"legend_title": "",
+				"loading": "",
+				"not_available": "",
+				"previous_status_accumulated_time": "",
+				"title": "",
+				"title_durations": "",
+				"title_loading": "",
+				"title_transitions": ""
+			},
+			"errors": {
+				"fetch": "Erreur lors de l'obtention des données du cycle de vie des tâches"
+			}
+		},
 		"job_payments": {
 			"buttons": {
 				"goback": "",
@@ -2049,6 +2074,7 @@
 				"general": "",
 				"insurance": "",
 				"labor": "La main d'oeuvre",
+				"lifecycle": "",
 				"partssublet": "Pièces / Sous-location",
 				"rates": "",
 				"repairdata": "Données de réparation",
@@ -2957,8 +2983,8 @@
 			"shop-templates": "",
 			"shop_vendors": "Vendeurs | $t(titles.app)",
 			"techconsole": "$t(titles.app)",
-			"techjoblookup": "$t(titles.app)",
 			"techjobclock": "$t(titles.app)",
+			"techjoblookup": "$t(titles.app)",
 			"techshiftclock": "$t(titles.app)",
 			"temporarydocs": "",
 			"timetickets": "",

client/src/utils/DateFormatter.jsx

@@ -17,6 +17,9 @@ export function DateTimeFormatter(props) {
       )
     : null;
 }
+export function DateTimeFormatterFunction(date) {
+    return dayjs(date).format("MM/DD/YYYY hh:mm a");
+}
 export function TimeFormatter(props) {
   return props.children
     ? dayjs(props.children).format(props.format ? props.format : "hh:mm a")

package.json

@@ -8,6 +8,7 @@
   },
   "scripts": {
     "setup": "rm -rf node_modules && npm i && cd client && rm -rf node_modules && npm i",
+    "setup:win": "rimraf node_modules && npm i && cd client && rimraf node_modules && npm i",
     "admin": "cd admin && npm start",
     "client": "cd client && npm start",
     "server": "nodemon server.js",
@@ -47,8 +48,9 @@
     "node-mailjet": "^6.0.5",
     "node-persist": "^4.0.1",
     "node-quickbooks": "^2.0.43",
-    "nodemailer": "^6.9.8",
+    "nodemailer": "^6.9.7",
-    "phone": "^3.1.42",
+    "phone": "^3.1.41",
+    "rimraf": "^5.0.5",
     "soap": "^1.0.0",
     "socket.io": "^4.7.4",
     "ssh2-sftp-client": "^9.1.0",

server.js

@@ -1,299 +1,94 @@
+// Import core modules
 const express = require("express");
 const cors = require("cors");
 const bodyParser = require("body-parser");
 const path = require("path");
 const compression = require("compression");
-const twilio = require("twilio");
-const logger = require("./server/utils/logger");
-const fb = require("./server/firebase/firebase-handler");
 const cookieParser = require("cookie-parser");
-const multer = require("multer");
+const http = require("http");
-const upload = multer();
+const {Server} = require("socket.io");
-//var enforce = require("express-sslify");
 
+// Load environment variables
 require("dotenv").config({
-  path: path.resolve(
+    path: path.resolve(process.cwd(), `.env.${process.env.NODE_ENV || "development"}`)
-    process.cwd(),
-    `.env.${process.env.NODE_ENV || "development"}`
-  ),
 });
 
+// Import custom utilities and handlers
+const logger = require("./server/utils/logger");
+
+// Express app and server setup
 const app = express();
 const port = process.env.PORT || 5000;
-//const port = 5000;
-
-const http = require("http");
 const server = http.createServer(app);
-const { Server } = require("socket.io");
 const io = new Server(server, {
-  path: "/ws",
+    path: "/ws",
-  cors: {
+    cors: {
-    origin: [
+        origin: [
-      "https://test.imex.online",
+            "https://test.imex.online",
-      "https://www.test.imex.online",
+            "https://www.test.imex.online",
-      "http://localhost:3000",
+            "http://localhost:3000",
-      "https://imex.online",
+            "https://imex.online",
-      "https://www.imex.online",
+            "https://www.imex.online",
-      "https://beta.test.imex.online",
+            "https://beta.test.imex.online",
-      "https://www.beta.test.imex.online",
+            "https://www.beta.test.imex.online",
-      "https://beta.imex.online",
+            "https://beta.imex.online",
-      "https://www.beta.imex.online",
+            "https://www.beta.imex.online",
-    ],
+        ],
-    methods: ["GET", "POST"],
+        methods: ["GET", "POST"],
-    credentials: true,
+        credentials: true,
-    exposedHeaders: ["set-cookie"],
+        exposedHeaders: ["set-cookie"],
-  },
+    },
 });
 exports.io = io;
+
 require("./server/web-sockets/web-socket");
-// app.set('trust proxy', true)
+
-// app.use(fb.validateFirebaseIdToken);
+
+// Middleware
 app.use(compression());
 app.use(cookieParser());
-app.use(bodyParser.json({ limit: "50mb" }));
+app.use(bodyParser.json({limit: "50mb"}));
-app.use(bodyParser.urlencoded({ limit: "50mb", extended: true }));
+app.use(bodyParser.urlencoded({limit: "50mb", extended: true}));
-// app.use(enforce.HTTPS({ trustProtoHeader: true }));
+app.use(cors({credentials: true, exposedHeaders: ["set-cookie"]}));
-app.use(
-  cors({ credentials: true, exposedHeaders: ["set-cookie"] })
-  // cors({
-  //   credentials: true,
-  //   origin: [
-  //     "https://test.imex.online",
-  //     "http://localhost:3000",
-  //     "https://imex.online",
-  //   ],
-  // })
-);
 
-//Email Based Paths.
+// Helper middleware
-var sendEmail = require("./server/email/sendemail.js");
+app.use((req, res, next) => {
-app.post("/sendemail", fb.validateFirebaseIdToken, sendEmail.sendEmail);
+    req.logger = logger;
-app.post("/emailbounce", bodyParser.text(), sendEmail.emailBounce);
+    next();
-
-//Test route to ensure Express is responding.
-app.get("/test", async function (req, res) {
-  const commit = require("child_process").execSync(
-    "git rev-parse --short HEAD"
-  );
-  // console.log(app.get('trust proxy'));
-  // console.log("remoteAddress", req.socket.remoteAddress);
-  // console.log("X-Forwarded-For", req.header('x-forwarded-for'));
-  logger.log("test-api-status", "DEBUG", "api", { commit });
-  // sendEmail.sendServerEmail({
-  //   subject: `API Check - ${process.env.NODE_ENV}`,
-  //   text: `Server API check has come in. Remote IP: ${req.socket.remoteAddress}, X-Forwarded-For: ${req.header('x-forwarded-for')}`,
-  // });
-  sendEmail.sendServerEmail({
-    subject: `API Check - ${process.env.NODE_ENV}`,
-    text: `Server API check has come in.`,
-  });
-  res.status(200).send(`OK - ${commit}`);
 });
 
-//Accounting Qbxml
+// Route groupings
-const accountQbxml = require("./server/accounting/qbxml/qbxml");
+app.use('/', require("./server/routes/miscellaneousRoutes"));
-app.post(
+app.use("/notifications", require("./server/routes/notificationsRoutes"));
-  "/accounting/qbxml/receivables",
+app.use("/render", require("./server/routes/renderRoutes"));
-  fb.validateFirebaseIdToken,
+app.use('/mixdata', require("./server/routes/mixDataRoutes"));
-  accountQbxml.receivables
+app.use('/accounting', require("./server/routes/accountingRoutes"));
-);
+app.use('/qbo', require("./server/routes/qboRoutes"));
-app.post(
+app.use('/media', require("./server/routes/mediaRoutes"));
-  "/accounting/qbxml/payables",
+app.use('/sms', require("./server/routes/smsRoutes"));
-  fb.validateFirebaseIdToken,
+app.use('/job', require("./server/routes/jobRoutes"));
-  accountQbxml.payables
+app.use('/scheduling', require("./server/routes/schedulingRoutes"));
-);
+app.use('/utils', require("./server/routes/utilRoutes"));
-app.post(
+app.use('/data', require("./server/routes/dataRoutes"));
-  "/accounting/qbxml/payments",
+app.use('/adm', require("./server/routes/adminRoutes"));
-  fb.validateFirebaseIdToken,
+app.use('/tech', require("./server/routes/techRoutes"));
-  accountQbxml.payments
+app.use('/intellipay', require("./server/routes/intellipayRoutes"));
-);
+app.use('/cdk', require("./server/routes/cdkRoutes"));
 
-//Cloudinary Media Paths
+// Default route for forbidden access
-var media = require("./server/media/media");
+app.get("/", (req, res) => {
-app.post(
+    res.status(200).send("Access Forbidden.");
-  "/media/sign",
-  fb.validateFirebaseIdToken,
-  media.createSignedUploadURL
-);
-app.post("/media/download", fb.validateFirebaseIdToken, media.downloadFiles);
-app.post("/media/rename", fb.validateFirebaseIdToken, media.renameKeys);
-app.post("/media/delete", fb.validateFirebaseIdToken, media.deleteFiles);
-
-//SMS/Twilio Paths
-var smsReceive = require("./server/sms/receive");
-app.post(
-  "/sms/receive",
-  twilio.webhook({ validate: process.env.NODE_ENV === "PRODUCTION" }),
-  smsReceive.receive
-);
-var smsSend = require("./server/sms/send");
-app.post("/sms/send", fb.validateFirebaseIdToken, smsSend.send);
-var smsStatus = require("./server/sms/status");
-app.post(
-  "/sms/status",
-  twilio.webhook({ validate: process.env.NODE_ENV === "PRODUCTION" }),
-  smsStatus.status
-);
-app.post(
-  "/sms/markConversationRead",
-  fb.validateFirebaseIdToken,
-  smsStatus.markConversationRead
-);
-
-var job = require("./server/job/job");
-app.post("/job/totals", fb.validateFirebaseIdToken, job.totals);
-app.post(
-  "/job/statustransition",
-  // fb.validateFirebaseIdToken,
-  job.statustransition
-);
-app.post("/job/totalsssu", fb.validateFirebaseIdToken, job.totalsSsu);
-app.post("/job/costing", fb.validateFirebaseIdToken, job.costing);
-app.post("/job/costingmulti", fb.validateFirebaseIdToken, job.costingmulti);
-var partsScan = require("./server/parts-scan/parts-scan");
-app.post("/job/partsscan", fb.validateFirebaseIdToken, partsScan.partsScan);
-//Scheduling
-var scheduling = require("./server/scheduling/scheduling-job");
-app.post("/scheduling/job", fb.validateFirebaseIdToken, scheduling.job);
-
-//Handlebars Paths for Email/Report Rendering
-// var renderHandlebars = require("./server/render/renderHandlebars");
-// app.post("/render", fb.validateFirebaseIdToken, renderHandlebars.render);
-var inlineCss = require("./server/render/inlinecss");
-app.post("/render/inlinecss", fb.validateFirebaseIdToken, inlineCss.inlinecss);
-
-// app.post(
-//   "/notifications/send",
-
-//   fb.sendNotification
-// );
-app.post("/notifications/subscribe", fb.validateFirebaseIdToken, fb.subscribe);
-app.post(
-  "/notifications/unsubscribe",
-  fb.validateFirebaseIdToken,
-  fb.unsubscribe
-);
-app.post("/adm/updateuser", fb.validateFirebaseIdToken, fb.updateUser);
-app.post("/adm/getuser", fb.validateFirebaseIdToken, fb.getUser);
-app.post("/adm/createuser", fb.validateFirebaseIdToken, fb.createUser);
-const adm = require("./server/admin/adminops");
-app.post(
-  "/adm/createassociation",
-  fb.validateFirebaseIdToken,
-  fb.validateAdmin,
-  adm.createAssociation
-);
-app.post(
-  "/adm/createshop",
-  fb.validateFirebaseIdToken,
-  fb.validateAdmin,
-  adm.createShop
-);
-app.post(
-  "/adm/updateshop",
-  fb.validateFirebaseIdToken,
-  fb.validateAdmin,
-  adm.updateShop
-);
-app.post(
-  "/adm/updatecounter",
-  fb.validateFirebaseIdToken,
-  fb.validateAdmin,
-  adm.updateCounter
-);
-
-//Stripe Processing
-// var stripe = require("./server/stripe/payment");
-// app.post("/stripe/payment", fb.validateFirebaseIdToken, stripe.payment);
-// app.post(
-//   "/stripe/mobilepayment",
-//   fb.validateFirebaseIdToken,
-//   stripe.mobile_payment
-// );
-
-//Tech Console
-var tech = require("./server/tech/tech");
-app.post("/tech/login", fb.validateFirebaseIdToken, tech.techLogin);
-
-var utils = require("./server/utils/utils");
-app.post("/utils/time", utils.servertime);
-app.post("/utils/jsr", fb.validateFirebaseIdToken, utils.jsrAuth);
-var qbo = require("./server/accounting/qbo/qbo");
-app.post("/qbo/authorize", fb.validateFirebaseIdToken, qbo.authorize);
-app.get("/qbo/callback", qbo.callback);
-app.post("/qbo/receivables", fb.validateFirebaseIdToken, qbo.receivables);
-app.post("/qbo/payables", fb.validateFirebaseIdToken, qbo.payables);
-app.post("/qbo/payments", fb.validateFirebaseIdToken, qbo.payments);
-
-var data = require("./server/data/data");
-app.post("/data/ah", data.autohouse);
-app.post("/data/cc", data.claimscorp);
-app.post("/data/kaizen", data.kaizen);
-app.post("/record-handler/arms", data.arms);
-
-var taskHandler = require("./server/tasks/tasks");
-app.post("/taskHandler", fb.validateFirebaseIdToken, taskHandler.taskHandler);
-
-var mixdataUpload = require("./server/mixdata/mixdata");
-
-app.post(
-  "/mixdata/upload",
-  fb.validateFirebaseIdToken,
-  upload.any(),
-  mixdataUpload.mixdataUpload
-);
-
-var intellipay = require("./server/intellipay/intellipay");
-app.post(
-  "/intellipay/lightbox_credentials",
-  fb.validateFirebaseIdToken,
-  intellipay.lightbox_credentials
-);
-
-app.post(
-  "/intellipay/payment_refund",
-  fb.validateFirebaseIdToken,
-  intellipay.payment_refund
-);
-
-app.post(
-  "/intellipay/generate_payment_url",
-  fb.validateFirebaseIdToken,
-  intellipay.generate_payment_url
-);
-
-app.post(
-  "/intellipay/postback",
-  // fb.validateFirebaseIdToken,
-  intellipay.postback
-);
-
-var ioevent = require("./server/ioevent/ioevent");
-app.post("/ioevent", ioevent.default);
-// app.post("/newlog", (req, res) => {
-//   const { message, type, user, record, object } = req.body;
-//   logger.log(message, type, user, record, object);
-// });
-
-var os = require("./server/opensearch/os-handler");
-app.post(
-  "/opensearch", //fb.validateFirebaseIdToken,
-  os.handler
-);
-app.post("/search", fb.validateFirebaseIdToken, os.search);
-
-var cdkGetMake = require("./server/cdk/cdk-get-makes");
-app.post("/cdk/getvehicles", fb.validateFirebaseIdToken, cdkGetMake.default);
-
-app.get("/", async function (req, res) {
-  res.status(200).send("Access Forbidden.");
 });
 
-server.listen(port, (error) => {
+const main = async () => {
-  if (error) throw error;
+    await server.listen(port);
-  logger.log(
+}
-    `[${process.env.NODE_ENV || "DEVELOPMENT"}] Server running on port ${port}`,
+
-    "INFO",
+// Start server
-    "api"
+main()
-  );
+    .then(() => {
-});
+        logger.log(`[${process.env.NODE_ENV || "DEVELOPMENT"}] Server started on port ${port}`, "INFO", "api");
+    })
+    .catch((error) => {
+        logger.log(`[${process.env.NODE_ENV || "DEVELOPMENT"}] Server failed to start on port ${port}`, "ERROR", "api", error);
+    });

server/accounting/pbs/pbs-job-export.js

@@ -166,7 +166,7 @@ async function CheckForErrors(socket, response) {
     CdkBase.createLogEvent(
       socket,
       "DEBUG",
-      `Succesful response from DMS. ${response.Message || ""}`
+      `Successful response from DMS. ${response.Message || ""}`
     );
   } else {
     CdkBase.createLogEvent(

server/accounting/qbo/qbo-payables.js

@@ -18,10 +18,10 @@ const {
 } = require("./qbo-callback");
 const OAuthClient = require("intuit-oauth");
 const moment = require("moment-timezone");
-const GraphQLClient = require("graphql-request").GraphQLClient;
 const findTaxCode = require("../qb-receivables-lines").findTaxCode;
 
 exports.default = async (req, res) => {
+
   const oauthClient = new OAuthClient({
     clientId: process.env.QBO_CLIENT_ID,
     clientSecret: process.env.QBO_SECRET,
@@ -30,29 +30,31 @@ exports.default = async (req, res) => {
     redirectUri: process.env.QBO_REDIRECT_URI,
     logging: true,
   });
+
   try {
     //Fetch the API Access Tokens & Set them for the session.
     const response = await apiGqlClient.request(queries.GET_QBO_AUTH, {
       email: req.user.email,
     });
+
     const { qbo_realmId } = response.associations[0];
 
     oauthClient.setToken(response.associations[0].qbo_auth);
+
     if (!qbo_realmId) {
       res.status(401).json({ error: "No company associated." });
       return;
     }
+
     await refreshOauthToken(oauthClient, req);
 
-    const BearerToken = req.headers.authorization;
     const { bills: billsToQuery, elgen } = req.body;
-    //Query Job Info
+
-    const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+    const BearerToken = req.BearerToken;
-      headers: {
+    const client = req.userGraphQLClient;
-        Authorization: BearerToken,
+
-      },
-    });
     logger.log("qbo-payable-create", "DEBUG", req.user.email, billsToQuery);
+
     const result = await client
       .setHeaders({ Authorization: BearerToken })
       .request(queries.QUERY_BILLS_FOR_PAYABLES_EXPORT, {

server/accounting/qbo/qbo-payments.js

@@ -51,15 +51,13 @@ exports.default = async (req, res) => {
     }
     await refreshOauthToken(oauthClient, req);
 
-    const BearerToken = req.headers.authorization;
     const { payments: paymentsToQuery, elgen } = req.body;
-    //Query Job Info
+
-    const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+    const BearerToken = req.BearerToken;
-      headers: {
+    const client = req.userGraphQLClient;
-        Authorization: BearerToken,
+
-      },
-    });
     logger.log("qbo-payment-create", "DEBUG", req.user.email, paymentsToQuery);
+
     const result = await client
       .setHeaders({ Authorization: BearerToken })
       .request(queries.QUERY_PAYMENTS_FOR_EXPORT, {

server/accounting/qbo/qbo-receivables.js

@@ -18,8 +18,6 @@ const {
 const OAuthClient = require("intuit-oauth");
 const CreateInvoiceLines = require("../qb-receivables-lines").default;
 const moment = require("moment-timezone");
-
-const GraphQLClient = require("graphql-request").GraphQLClient;
 const { generateOwnerTier } = require("../qbxml/qbxml-utils");
 const { createMultiQbPayerLines } = require("../qb-receivables-lines");
 
@@ -46,15 +44,14 @@ exports.default = async (req, res) => {
 
     await refreshOauthToken(oauthClient, req);
 
-    const BearerToken = req.headers.authorization;
     const { jobIds, elgen } = req.body;
     //Query Job Info
-    const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+
-      headers: {
+    const BearerToken = req.BearerToken;
-        Authorization: BearerToken,
+    const client = req.userGraphQLClient;
-      },
+
-    });
     logger.log("qbo-receivable-create", "DEBUG", req.user.email, jobIds);
+
     const result = await client
       .setHeaders({ Authorization: BearerToken })
       .request(queries.QUERY_JOBS_FOR_RECEIVABLES_EXPORT, {

server/accounting/qbxml/qbxml-payables.js

@@ -3,10 +3,11 @@ const path = require("path");
 const DineroQbFormat = require("../accounting-constants").DineroQbFormat;
 const queries = require("../../graphql-client/queries");
 const Dinero = require("dinero.js");
-var builder = require("xmlbuilder2");
+const builder = require("xmlbuilder2");
 const QbXmlUtils = require("./qbxml-utils");
 const moment = require("moment-timezone");
-const logger = require("../../utils/logger");
+const logger = require('../../utils/logger');
+
 require("dotenv").config({
   path: path.resolve(
     process.cwd(),
@@ -15,14 +16,10 @@ require("dotenv").config({
 });
 
 exports.default = async (req, res) => {
-  const BearerToken = req.headers.authorization;
   const { bills: billsToQuery } = req.body;
 
-  const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+  const BearerToken = req.BearerToken;
-    headers: {
+  const client = req.userGraphQLClient;
-      Authorization: BearerToken,
-    },
-  });
 
   try {
     logger.log(

server/accounting/qbxml/qbxml-payments.js

@@ -1,13 +1,12 @@
-const GraphQLClient = require("graphql-request").GraphQLClient;
 const path = require("path");
 const DineroQbFormat = require("../accounting-constants").DineroQbFormat;
 const queries = require("../../graphql-client/queries");
 const Dinero = require("dinero.js");
-var builder = require("xmlbuilder2");
+const builder = require("xmlbuilder2");
 const moment = require("moment-timezone");
 const QbXmlUtils = require("./qbxml-utils");
 const QbxmlReceivables = require("./qbxml-receivables");
-const logger = require("../../utils/logger");
+const logger = require('../../utils/logger');
 
 require("dotenv").config({
   path: path.resolve(
@@ -19,14 +18,10 @@ require("dotenv").config({
 const { generateJobTier, generateOwnerTier, generateSourceTier } = QbXmlUtils;
 
 exports.default = async (req, res) => {
-  const BearerToken = req.headers.authorization;
   const { payments: paymentsToQuery } = req.body;
 
-  const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+  const BearerToken = req.BearerToken;
-    headers: {
+  const client = req.userGraphQLClient;
-      Authorization: BearerToken,
-    },
-  });
 
   try {
     logger.log(

server/accounting/qbxml/qbxml-receivables.js

@@ -1,13 +1,12 @@
-const GraphQLClient = require("graphql-request").GraphQLClient;
 const path = require("path");
 const DineroQbFormat = require("../accounting-constants").DineroQbFormat;
 const queries = require("../../graphql-client/queries");
 const Dinero = require("dinero.js");
 const moment = require("moment-timezone");
-var builder = require("xmlbuilder2");
+const builder = require("xmlbuilder2");
 const QbXmlUtils = require("./qbxml-utils");
-const logger = require("../../utils/logger");
 const CreateInvoiceLines = require("../qb-receivables-lines").default;
+const logger = require('../../utils/logger');
 
 require("dotenv").config({
   path: path.resolve(
@@ -20,14 +19,10 @@ Dinero.globalRoundingMode = "HALF_EVEN";
 const { generateJobTier, generateOwnerTier, generateSourceTier } = QbXmlUtils;
 
 exports.default = async (req, res) => {
-  const BearerToken = req.headers.authorization;
   const { jobIds } = req.body;
 
-  const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+  const BearerToken = req.BearerToken;
-    headers: {
+  const client = req.userGraphQLClient;
-      Authorization: BearerToken,
-    },
-  });
 
   try {
     logger.log(

server/cdk/cdk-get-makes.js

@@ -5,7 +5,6 @@ require("dotenv").config({
     `.env.${process.env.NODE_ENV || "development"}`
   ),
 });
-const GraphQLClient = require("graphql-request").GraphQLClient;
 const soap = require("soap");
 const queries = require("../graphql-client/queries");
 
@@ -34,16 +33,11 @@ const { CDK_CREDENTIALS, CheckCdkResponseForError } = require("./cdk-wsdl");
 exports.default = async function ReloadCdkMakes(req, res) {
   const { bodyshopid, cdk_dealerid } = req.body;
   try {
-    const BearerToken = req.headers.authorization;
     //Query all CDK Models
     const newList = await GetCdkMakes(req, cdk_dealerid);
 
-    //Clear out the existing records
+    const BearerToken = req.BearerToken;
-    const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+    const client = req.userGraphQLClient;
-      headers: {
-        Authorization: BearerToken,
-      },
-    });
 
     const deleteResult = await client
       .setHeaders({ Authorization: BearerToken })

server/email/sendemail.js

@@ -1,269 +1,269 @@
 const path = require("path");
 require("dotenv").config({
-  path: path.resolve(
+    path: path.resolve(
-    process.cwd(),
+        process.cwd(),
-    `.env.${process.env.NODE_ENV || "development"}`
+        `.env.${process.env.NODE_ENV || "development"}`
-  ),
+    ),
 });
 const axios = require("axios");
 let nodemailer = require("nodemailer");
 let aws = require("@aws-sdk/client-ses");
-let { defaultProvider } = require("@aws-sdk/credential-provider-node");
+let {defaultProvider} = require("@aws-sdk/credential-provider-node");
 
 const logger = require("../utils/logger");
 const client = require("../graphql-client/graphql-client").client;
 const queries = require("../graphql-client/queries");
 
 const ses = new aws.SES({
-  // The key apiVersion is no longer supported in v3, and can be removed.
+    // The key apiVersion is no longer supported in v3, and can be removed.
-  // @deprecated The client uses the "latest" apiVersion.
+    // @deprecated The client uses the "latest" apiVersion.
-  apiVersion: "latest",
+    apiVersion: "latest",
-  region: "ca-central-1",
+    region: "ca-central-1",
-  defaultProvider
+    defaultProvider
 });
 
 let transporter = nodemailer.createTransport({
-  SES: { ses, aws },
+    SES: {ses, aws},
 });
 
-exports.sendServerEmail = async function ({ subject, text }) {
+exports.sendServerEmail = async function ({subject, text}) {
-  if (process.env.NODE_ENV === undefined) return;
+    if (process.env.NODE_ENV === undefined) return;
-  try {
+    try {
-    transporter.sendMail(
+        transporter.sendMail(
-      {
-        from: `ImEX Online API - ${process.env.NODE_ENV} <noreply@imex.online>`,
-        to: ["patrick@imexsystems.ca", "support@thinkimex.com"],
-        subject: subject,
-        text: text,
-        ses: {
-          // optional extra arguments for SendRawEmail
-          Tags: [
             {
-              Name: "tag_name",
+                from: `ImEX Online API - ${process.env.NODE_ENV} <noreply@imex.online>`,
-              Value: "tag_value",
+                to: ["patrick@imexsystems.ca", "support@thinkimex.com"],
+                subject: subject,
+                text: text,
+                ses: {
+                    // optional extra arguments for SendRawEmail
+                    Tags: [
+                        {
+                            Name: "tag_name",
+                            Value: "tag_value",
+                        },
+                    ],
+                },
             },
-          ],
+            (err, info) => {
-        },
+                console.log(err || info);
-      },
+            }
-      (err, info) => {
+        );
-        console.log(err || info);
+    } catch (error) {
-      }
+        console.log(error);
-    );
+        logger.log("server-email-failure", "error", null, null, error);
-  } catch (error) {
+    }
-    console.log(error);
-    logger.log("server-email-failure", "error", null, null, error);
-  }
 };
-exports.sendTaskEmail = async function ({ to, subject, text, attachments }) {
+exports.sendTaskEmail = async function ({to, subject, text, attachments}) {
-  try {
+    try {
-    transporter.sendMail(
+        transporter.sendMail(
-      {
+            {
-        from: `ImEX Online <noreply@imex.online>`,
+                from: `ImEX Online <noreply@imex.online>`,
-        to: to,
+                to: to,
-        subject: subject,
+                subject: subject,
-        text: text,
+                text: text,
-        attachments: attachments || null,
+                attachments: attachments || null,
-      },
+            },
-      (err, info) => {
+            (err, info) => {
-        console.log(err || info);
+                console.log(err || info);
-      }
+            }
-    );
+        );
-  } catch (error) {
+    } catch (error) {
-    console.log(error);
+        console.log(error);
-    logger.log("server-email-failure", "error", null, null, error);
+        logger.log("server-email-failure", "error", null, null, error);
-  }
+    }
 };
 
 exports.sendEmail = async (req, res) => {
-  logger.log("send-email", "DEBUG", req.user.email, null, {
+    logger.log("send-email", "DEBUG", req.user.email, null, {
-    from: `${req.body.from.name} <${req.body.from.address}>`,
+        from: `${req.body.from.name} <${req.body.from.address}>`,
-    replyTo: req.body.ReplyTo.Email,
+        replyTo: req.body.ReplyTo.Email,
-    to: req.body.to,
+        to: req.body.to,
-    cc: req.body.cc,
+        cc: req.body.cc,
-    subject: req.body.subject,
+        subject: req.body.subject,
-  });
+    });
 
-  let downloadedMedia = [];
+    let downloadedMedia = [];
-  if (req.body.media && req.body.media.length > 0) {
+    if (req.body.media && req.body.media.length > 0) {
-    downloadedMedia = await Promise.all(
+        downloadedMedia = await Promise.all(
-      req.body.media.map((m) => {
+            req.body.media.map((m) => {
-        try {
+                try {
-          return getImage(m);
+                    return getImage(m);
-        } catch (error) {
+                } catch (error) {
-          logger.log("send-email-error", "ERROR", req.user.email, null, {
+                    logger.log("send-email-error", "ERROR", req.user.email, null, {
+                        from: `${req.body.from.name} <${req.body.from.address}>`,
+                        replyTo: req.body.ReplyTo.Email,
+                        to: req.body.to,
+                        cc: req.body.cc,
+                        subject: req.body.subject,
+                        error,
+                    });
+                }
+            })
+        );
+    }
+
+    transporter.sendMail(
+        {
             from: `${req.body.from.name} <${req.body.from.address}>`,
             replyTo: req.body.ReplyTo.Email,
             to: req.body.to,
             cc: req.body.cc,
             subject: req.body.subject,
-            error,
+            attachments:
-          });
+                [
+                    ...((req.body.attachments &&
+                            req.body.attachments.map((a) => {
+                                return {
+                                    filename: a.filename,
+                                    path: a.path,
+                                };
+                            })) ||
+                        []),
+                    ...downloadedMedia.map((a) => {
+                        return {
+                            path: a,
+                        };
+                    }),
+                ] || null,
+            html: req.body.html,
+            ses: {
+                // optional extra arguments for SendRawEmail
+                Tags: [
+                    {
+                        Name: "tag_name",
+                        Value: "tag_value",
+                    },
+                ],
+            },
+        },
+        (err, info) => {
+            console.log(err || info);
+            if (info) {
+                logger.log("send-email-success", "DEBUG", req.user.email, null, {
+                    from: `${req.body.from.name} <${req.body.from.address}>`,
+                    replyTo: req.body.ReplyTo.Email,
+                    to: req.body.to,
+                    cc: req.body.cc,
+                    subject: req.body.subject,
+                    // info,
+                });
+                logEmail(req, {
+                    to: req.body.to,
+                    cc: req.body.cc,
+                    subject: req.body.subject,
+                    messageId: info.response,
+                });
+                res.json({
+                    success: true, //response: info
+                });
+            } else {
+                logger.log("send-email-failure", "ERROR", req.user.email, null, {
+                    from: `${req.body.from.name} <${req.body.from.address}>`,
+                    replyTo: req.body.ReplyTo.Email,
+                    to: req.body.to,
+                    cc: req.body.cc,
+                    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});
+            }
         }
-      })
     );
-  }
-
-  transporter.sendMail(
-    {
-      from: `${req.body.from.name} <${req.body.from.address}>`,
-      replyTo: req.body.ReplyTo.Email,
-      to: req.body.to,
-      cc: req.body.cc,
-      subject: req.body.subject,
-      attachments:
-        [
-          ...((req.body.attachments &&
-            req.body.attachments.map((a) => {
-              return {
-                filename: a.filename,
-                path: a.path,
-              };
-            })) ||
-            []),
-          ...downloadedMedia.map((a) => {
-            return {
-              path: a,
-            };
-          }),
-        ] || null,
-      html: req.body.html,
-      ses: {
-        // optional extra arguments for SendRawEmail
-        Tags: [
-          {
-            Name: "tag_name",
-            Value: "tag_value",
-          },
-        ],
-      },
-    },
-    (err, info) => {
-      console.log(err || info);
-      if (info) {
-        logger.log("send-email-success", "DEBUG", req.user.email, null, {
-          from: `${req.body.from.name} <${req.body.from.address}>`,
-          replyTo: req.body.ReplyTo.Email,
-          to: req.body.to,
-          cc: req.body.cc,
-          subject: req.body.subject,
-          // info,
-        });
-        logEmail(req, {
-          to: req.body.to,
-          cc: req.body.cc,
-          subject: req.body.subject,
-          messageId: info.response,
-        });
-        res.json({
-          success: true, //response: info
-        });
-      } else {
-        logger.log("send-email-failure", "ERROR", req.user.email, null, {
-          from: `${req.body.from.name} <${req.body.from.address}>`,
-          replyTo: req.body.ReplyTo.Email,
-          to: req.body.to,
-          cc: req.body.cc,
-          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 });
-      }
-    }
-  );
 };
 
 async function getImage(imageUrl) {
-  let image = await axios.get(imageUrl, { responseType: "arraybuffer" });
+    let image = await axios.get(imageUrl, {responseType: "arraybuffer"});
-  let raw = Buffer.from(image.data).toString("base64");
+    let raw = Buffer.from(image.data).toString("base64");
-  return "data:" + image.headers["content-type"] + ";base64," + raw;
+    return "data:" + image.headers["content-type"] + ";base64," + raw;
 }
 
 async function logEmail(req, email) {
-  try {
+    try {
-    const insertresult = await client.request(queries.INSERT_EMAIL_AUDIT, {
+        const insertresult = await client.request(queries.INSERT_EMAIL_AUDIT, {
-      email: {
+            email: {
-        to: email.to,
+                to: email.to,
-        cc: email.cc,
+                cc: email.cc,
-        subject: email.subject,
+                subject: email.subject,
-        bodyshopid: req.body.bodyshopid,
+                bodyshopid: req.body.bodyshopid,
-        useremail: req.user.email,
+                useremail: req.user.email,
-        contents: req.body.html,
+                contents: req.body.html,
-        jobid: req.body.jobid,
+                jobid: req.body.jobid,
-        sesmessageid: email.messageId,
+                sesmessageid: email.messageId,
-        status: "Sent",
+                status: "Sent",
-      },
+            },
-    });
+        });
-    console.log(insertresult);
+        console.log(insertresult);
-  } catch (error) {
+    } catch (error) {
-    logger.log("email-log-error", "error", req.user.email, null, {
+        logger.log("email-log-error", "error", req.user.email, null, {
-      from: `${req.body.from.name} <${req.body.from.address}>`,
+            from: `${req.body.from.name} <${req.body.from.address}>`,
-      to: req.body.to,
+            to: req.body.to,
-      cc: req.body.cc,
+            cc: req.body.cc,
-      subject: req.body.subject,
+            subject: req.body.subject,
-      // info,
+            // info,
-    });
+        });
-  }
+    }
 }
 
-exports.emailBounce = async function (req, res, next) {
+exports.emailBounce = async function (req, res) {
-  try {
+    try {
-    const body = JSON.parse(req.body);
+        const body = JSON.parse(req.body);
-    if (body.Type === "SubscriptionConfirmation") {
+        if (body.Type === "SubscriptionConfirmation") {
-      logger.log("SNS-message", "DEBUG", "api", null, {
+            logger.log("SNS-message", "DEBUG", "api", null, {
-        body: req.body,
+                body: req.body,
-      });
+            });
-    }
-    const message = JSON.parse(body.Message);
-    if (message.notificationType === "Bounce") {
-      let replyTo, subject, messageId;
-      message.mail.headers.forEach((header) => {
-        if (header.name === "Reply-To") {
-          replyTo = header.value;
-        } else if (header.name === "Subject") {
-          subject = header.value;
         }
-      });
+        const message = JSON.parse(body.Message);
-      messageId = message.mail.messageId;
+        if (message.notificationType === "Bounce") {
-      if (replyTo === "noreply@imex.online") {
+            let replyTo, subject, messageId;
-        res.sendStatus(200);
+            message.mail.headers.forEach((header) => {
-        return;
+                if (header.name === "Reply-To") {
-      }
+                    replyTo = header.value;
-      //If it's bounced, log it as bounced in audit log. Send an email to the user.
+                } else if (header.name === "Subject") {
-      const result = await client.request(queries.UPDATE_EMAIL_AUDIT, {
+                    subject = header.value;
-        sesid: messageId,
+                }
-        status: "Bounced",
+            });
-        context: message.bounce?.bouncedRecipients,
+            messageId = message.mail.messageId;
-      });
+            if (replyTo === "noreply@imex.online") {
-      transporter.sendMail(
+                res.sendStatus(200);
-        {
+                return;
-          from: `ImEX Online <noreply@imex.online>`,
+            }
-          to: replyTo,
+            //If it's bounced, log it as bounced in audit log. Send an email to the user.
-          //bcc: "patrick@snapt.ca",
+            const result = await client.request(queries.UPDATE_EMAIL_AUDIT, {
-          subject: `ImEX Online Bounced Email - RE: ${subject}`,
+                sesid: messageId,
-          text: `ImEX Online has tried to deliver an email with the subject: ${subject} to the intended recipients but encountered an error.
+                status: "Bounced",
+                context: message.bounce?.bouncedRecipients,
+            });
+            transporter.sendMail(
+                {
+                    from: `ImEX Online <noreply@imex.online>`,
+                    to: replyTo,
+                    //bcc: "patrick@snapt.ca",
+                    subject: `ImEX Online Bounced Email - RE: ${subject}`,
+                    text: `ImEX Online has tried to deliver an email with the subject: ${subject} to the intended recipients but encountered an error.
 
 ${body.bounce?.bouncedRecipients.map(
-  (r) =>
+                        (r) =>
-    `Recipient: ${r.emailAddress} | Status: ${r.action} | Code: ${r.diagnosticCode}
+                            `Recipient: ${r.emailAddress} | Status: ${r.action} | Code: ${r.diagnosticCode}
             `
-)}
+                    )}
         `,
-        },
+                },
-        (err, info) => {
+                (err, info) => {
-          console.log("***", err || info);
+                    console.log("***", err || info);
+                }
+            );
         }
-      );
+    } catch (error) {
+        logger.log("sns-error", "ERROR", "api", null, {
+            error: JSON.stringify(error),
+        });
     }
-  } catch (error) {
+    res.sendStatus(200);
-    logger.log("sns-error", "ERROR", "api", null, {
-      error: JSON.stringify(error),
-    });
-  }
-  res.sendStatus(200);
 };

server/firebase/firebase-handler.js

@@ -1,287 +1,215 @@
-var admin = require("firebase-admin");
+const admin = require("firebase-admin");
 const logger = require("../utils/logger");
 const path = require("path");
-const { auth } = require("firebase-admin");
+const {auth} = require("firebase-admin");
+
 require("dotenv").config({
-  path: path.resolve(
+    path: path.resolve(
-    process.cwd(),
+        process.cwd(),
-    `.env.${process.env.NODE_ENV || "development"}`
+        `.env.${process.env.NODE_ENV || "development"}`
-  ),
+    ),
 });
 const client = require("../graphql-client/graphql-client").client;
-var serviceAccount = require(process.env.FIREBASE_ADMINSDK_JSON);
+
+const serviceAccount = require(process.env.FIREBASE_ADMINSDK_JSON);
+const adminEmail = require("../utils/adminEmail");
 
 admin.initializeApp({
-  credential: admin.credential.cert(serviceAccount),
+    credential: admin.credential.cert(serviceAccount),
-  databaseURL: process.env.FIREBASE_DATABASE_URL,
+    databaseURL: process.env.FIREBASE_DATABASE_URL,
 });
 
 exports.admin = admin;
 
-const adminEmail = [
-  "patrick@imex.dev",
-  //"patrick@imex.test",
-  "patrick@imex.prod",
-  "patrick@imexsystems.ca",
-  "patrick@thinkimex.com",
-];
-
 exports.createUser = async (req, res) => {
-  logger.log("admin-create-user", "ADMIN", req.user.email, null, {
+    logger.log("admin-create-user", "ADMIN", req.user.email, null, {
-    request: req.body,
+        request: req.body,
-    ioadmin: true,
+        ioadmin: true,
-  });
+    });
 
-  const { email, displayName, password, shopid, authlevel } = req.body;
+    const {email, displayName, password, shopid, authlevel} = req.body;
-  try {
+    try {
-    const userRecord = await admin
+        const userRecord = await admin
-      .auth()
+            .auth()
-      .createUser({ email, displayName, password });
+            .createUser({email, displayName, password});
 
-    // See the UserRecord reference doc for the contents of userRecord.
+        // See the UserRecord reference doc for the contents of userRecord.
 
-    const result = await client.request(
+        const result = await client.request(
-      `
+            `
         mutation INSERT_USER($user: users_insert_input!) {
           insert_users_one(object: $user) {
             email
           }
         }
       `,
-      {
+            {
-        user: {
+                user: {
-          email: email.toLowerCase(),
+                    email: email.toLowerCase(),
-          authid: userRecord.uid,
+                    authid: userRecord.uid,
-          associations: {
+                    associations: {
-            data: [{ shopid, authlevel, active: true }],
+                        data: [{shopid, authlevel, active: true}],
-          },
+                    },
-        },
+                },
-      }
+            }
-    );
+        );
 
-    res.json({ userRecord, result });
+        res.json({userRecord, result});
-  } catch (error) {
+    } catch (error) {
-    logger.log("admin-update-user-error", "ERROR", req.user.email, null, {
+        logger.log("admin-update-user-error", "ERROR", req.user.email, null, {
-      error,
+            error,
-    });
+        });
-    res.status(500).json(error);
+        res.status(500).json(error);
-  }
+    }
 };
 
 exports.updateUser = (req, res) => {
-  logger.log("admin-update-user", "ADMIN", req.user.email, null, {
+    logger.log("admin-update-user", "ADMIN", req.user.email, null, {
-    request: req.body,
-    ioadmin: true,
-  });
-
-  if (!adminEmail.includes(req.user.email) && !req.user.ioadmin) {
-    logger.log(
-      "admin-update-user-unauthorized",
-      "ERROR",
-      req.user.email,
-      null,
-      {
         request: req.body,
-        user: req.user,
-      }
-    );
-    res.sendStatus(404);
-    return;
-  }
-
-  admin
-    .auth()
-    .updateUser(
-      req.body.uid,
-      req.body.user
-      // {
-      // email: "modifiedUser@example.com",
-      // phoneNumber: "+11234567890",
-      // emailVerified: true,
-      // password: "newPassword",
-      // displayName: "Jane Doe",
-      // photoURL: "http://www.example.com/12345678/photo.png",
-      // disabled: true,
-      // }
-    )
-    .then((userRecord) => {
-      // See the UserRecord reference doc for the contents of userRecord.
-
-      logger.log("admin-update-user-success", "ADMIN", req.user.email, null, {
-        userRecord,
         ioadmin: true,
-      });
-      res.json(userRecord);
-    })
-    .catch((error) => {
-      logger.log("admin-update-user-error", "ERROR", req.user.email, null, {
-        error,
-      });
-      res.status(500).json(error);
     });
+
+    if (!adminEmail.includes(req.user.email) && !req.user.ioadmin) {
+        logger.log(
+            "admin-update-user-unauthorized",
+            "ERROR",
+            req.user.email,
+            null,
+            {
+                request: req.body,
+                user: req.user,
+            }
+        );
+        res.sendStatus(404);
+        return;
+    }
+
+    admin
+        .auth()
+        .updateUser(
+            req.body.uid,
+            req.body.user
+            // {
+            // email: "modifiedUser@example.com",
+            // phoneNumber: "+11234567890",
+            // emailVerified: true,
+            // password: "newPassword",
+            // displayName: "Jane Doe",
+            // photoURL: "http://www.example.com/12345678/photo.png",
+            // disabled: true,
+            // }
+        )
+        .then((userRecord) => {
+            // See the UserRecord reference doc for the contents of userRecord.
+
+            logger.log("admin-update-user-success", "ADMIN", req.user.email, null, {
+                userRecord,
+                ioadmin: true,
+            });
+            res.json(userRecord);
+        })
+        .catch((error) => {
+            logger.log("admin-update-user-error", "ERROR", req.user.email, null, {
+                error,
+            });
+            res.status(500).json(error);
+        });
 };
 
 exports.getUser = (req, res) => {
-  logger.log("admin-get-user", "ADMIN", req.user.email, null, {
+    logger.log("admin-get-user", "ADMIN", req.user.email, null, {
-    request: req.body,
-    ioadmin: true,
-  });
-
-  if (!adminEmail.includes(req.user.email) && !req.user.ioadmin) {
-    logger.log(
-      "admin-update-user-unauthorized",
-      "ERROR",
-      req.user.email,
-      null,
-      {
         request: req.body,
-        user: req.user,
+        ioadmin: true,
-      }
-    );
-    res.sendStatus(404);
-    return;
-  }
-
-  admin
-    .auth()
-    .getUser(req.body.uid)
-    .then((userRecord) => {
-      res.json(userRecord);
-    })
-    .catch((error) => {
-      logger.log("admin-get-user-error", "ERROR", req.user.email, null, {
-        error,
-      });
-      res.status(500).json(error);
     });
+
+    if (!adminEmail.includes(req.user.email) && !req.user.ioadmin) {
+        logger.log(
+            "admin-update-user-unauthorized",
+            "ERROR",
+            req.user.email,
+            null,
+            {
+                request: req.body,
+                user: req.user,
+            }
+        );
+        res.sendStatus(404);
+        return;
+    }
+
+    admin
+        .auth()
+        .getUser(req.body.uid)
+        .then((userRecord) => {
+            res.json(userRecord);
+        })
+        .catch((error) => {
+            logger.log("admin-get-user-error", "ERROR", req.user.email, null, {
+                error,
+            });
+            res.status(500).json(error);
+        });
 };
 
 exports.sendNotification = async (req, res) => {
-  setTimeout(() => {
+    setTimeout(() => {
-    // Send a message to the device corresponding to the provided
+        // Send a message to the device corresponding to the provided
-    // registration token.
+        // registration token.
-    admin
+        admin
-      .messaging()
+            .messaging()
-      .send({
+            .send({
-        topic: "PRD_PATRICK-messaging",
+                topic: "PRD_PATRICK-messaging",
-        notification: {
+                notification: {
-          title: `ImEX Online Message - +16049992002`,
+                    title: `ImEX Online Message - +16049992002`,
-          body: "Test Noti.",
+                    body: "Test Noti.",
-          //imageUrl: "https://thinkimex.com/img/io-fcm.png",
+                    //imageUrl: "https://thinkimex.com/img/io-fcm.png",
-        },
+                },
-        data: {
+                data: {
-          type: "messaging-inbound",
+                    type: "messaging-inbound",
-          conversationid: "e0eb17c3-3a78-4e3f-b932-55ef35aa2297",
+                    conversationid: "e0eb17c3-3a78-4e3f-b932-55ef35aa2297",
-          text: "Hello. ",
+                    text: "Hello. ",
-          image_path: "",
+                    image_path: "",
-          phone_num: "+16049992002",
+                    phone_num: "+16049992002",
-        },
+                },
-      })
+            })
-      .then((response) => {
+            .then((response) => {
-        // Response is a message ID string.
+                // Response is a message ID string.
-        console.log("Successfully sent message:", response);
+                console.log("Successfully sent message:", response);
-      })
+            })
-      .catch((error) => {
+            .catch((error) => {
-        console.log("Error sending message:", error);
+                console.log("Error sending message:", error);
-      });
+            });
 
-    res.sendStatus(200);
+        res.sendStatus(200);
-  }, 500);
+    }, 500);
 };
 
 exports.subscribe = async (req, res) => {
-  const result = await admin
+    const result = await admin
-    .messaging()
+        .messaging()
-    .subscribeToTopic(
+        .subscribeToTopic(
-      req.body.fcm_tokens,
+            req.body.fcm_tokens,
-      `${req.body.imexshopid}-${req.body.type}`
+            `${req.body.imexshopid}-${req.body.type}`
-    );
+        );
 
-  res.json(result);
+    res.json(result);
 };
 
 exports.unsubscribe = async (req, res) => {
-  try {
+    try {
-    const result = await admin
+        const result = await admin
-      .messaging()
+            .messaging()
-      .unsubscribeFromTopic(
+            .unsubscribeFromTopic(
-        req.body.fcm_tokens,
+                req.body.fcm_tokens,
-        `${req.body.imexshopid}-${req.body.type}`
+                `${req.body.imexshopid}-${req.body.type}`
-      );
+            );
 
-    res.json(result);
+        res.json(result);
-  } catch (error) {
+    } catch (error) {
-    res.sendStatus(500);
+        res.sendStatus(500);
-  }
+    }
 };
 
-exports.validateFirebaseIdToken = async (req, res, next) => {
-  if (
-    (!req.headers.authorization ||
-      !req.headers.authorization.startsWith("Bearer ")) &&
-    !(req.cookies && req.cookies.__session)
-  ) {
-    console.error("Unauthorized attempt. No authorization provided.");
-    res.status(403).send("Unauthorized");
-    return;
-  }
-
-  let idToken;
-  if (
-    req.headers.authorization &&
-    req.headers.authorization.startsWith("Bearer ")
-  ) {
-    // console.log('Found "Authorization" header');
-    // Read the ID Token from the Authorization header.
-    idToken = req.headers.authorization.split("Bearer ")[1];
-  } else if (req.cookies) {
-    //console.log('Found "__session" cookie');
-    // Read the ID Token from cookie.
-    idToken = req.cookies.__session;
-  } else {
-    // No cookie
-    console.error("Unauthorized attempt. No cookie provided.");
-    logger.log("api-unauthorized-call", "WARN", null, null, {
-      req,
-      type: "no-cookie",
-    });
-    res.status(403).send("Unauthorized");
-    return;
-  }
-
-  try {
-    const decodedIdToken = await admin.auth().verifyIdToken(idToken);
-    //console.log("ID Token correctly decoded", decodedIdToken);
-    req.user = decodedIdToken;
-    next();
-    return;
-  } catch (error) {
-    logger.log("api-unauthorized-call", "WARN", null, null, {
-      path: req.path,
-      body: req.body,
-
-      type: "unauthroized",
-      ...error,
-    });
-
-    res.status(401).send("Unauthorized");
-    return;
-  }
-};
-
-exports.validateAdmin = async (req, res, next) => {
-  if (!adminEmail.includes(req.user.email) && !req.user.ioadmin) {
-    logger.log("admin-validation-failed", "ERROR", req.user.email, null, {
-      request: req.body,
-      user: req.user,
-    });
-    res.sendStatus(404);
-    return;
-  } else {
-    next();
-    return;
-  }
-};
 
 //Admin claims code.
 // const uid = "JEqqYlsadwPEXIiyRBR55fflfko1";

server/graphql-client/queries.js

@@ -518,6 +518,21 @@ exports.QUERY_PAYMENTS_FOR_EXPORT = `
     }
   }`;
 
+exports.QUERY_TRANSITIONS_BY_JOBID = `query QUERY_TRANSITIONS_BY_JOBID($jobids: [uuid!]!) {
+  transitions(where: {jobid: {_in: $jobids}}, order_by: {end: desc}) {
+    start
+    end
+    value
+    prev_value
+    next_value
+    duration
+    type
+    created_at
+    updated_at
+    jobid
+  }
+}`;
+
 exports.QUERY_UPCOMING_APPOINTMENTS = `query QUERY_UPCOMING_APPOINTMENTS($now: timestamptz!, $jobId: uuid!) {
   jobs_by_pk(id: $jobId) {
     bodyshop {

server/job/job-lifecycle.js

@@ -0,0 +1,68 @@
+const _ = require("lodash");
+const queries = require("../graphql-client/queries");
+const moment = require("moment");
+const durationToHumanReadable = require("../utils/durationToHumanReadable");
+const calculateStatusDuration = require("../utils/calculateStatusDuration");
+
+const jobLifecycle = async (req, res) => {
+    // Grab the jobids and statuses from the request body
+    const {
+        jobids,
+        statuses
+    } = req.body;
+
+    if (!jobids) {
+        return res.status(400).json({
+            error: "Missing jobids"
+        });
+    }
+
+    const jobIDs = _.isArray(jobids) ? jobids : [jobids];
+    const client = req.userGraphQLClient;
+    const resp = await client.request(queries.QUERY_TRANSITIONS_BY_JOBID, {jobids: jobIDs,});
+
+    const transitions = resp.transitions;
+
+    if (!transitions) {
+        return res.status(200).json({
+            jobIDs,
+            transitions: []
+        });
+
+    }
+
+    const transitionsByJobId = _.groupBy(resp.transitions, 'jobid');
+
+    const groupedTransitions = {};
+
+    for (let jobId in transitionsByJobId) {
+        let lifecycle = transitionsByJobId[jobId].map(transition => {
+            transition.start_readable = transition.start ? moment(transition.start).fromNow() : 'N/A';
+            transition.end_readable = transition.end ? moment(transition.end).fromNow() : 'N/A';
+
+            if (transition.duration) {
+                transition.duration_seconds = Math.round(transition.duration / 1000);
+                transition.duration_minutes = Math.round(transition.duration_seconds / 60);
+                let duration = moment.duration(transition.duration);
+                transition.duration_readable = durationToHumanReadable(duration);
+            } else {
+                transition.duration_seconds = 0;
+                transition.duration_minutes = 0;
+                transition.duration_readable = 'N/A';
+            }
+            return transition;
+        });
+
+        groupedTransitions[jobId] = {
+            lifecycle: lifecycle,
+            durations: calculateStatusDuration(lifecycle, statuses),
+        };
+    }
+
+    return res.status(200).json({
+        jobIDs,
+        transition: groupedTransitions,
+    });
+}
+
+module.exports = jobLifecycle;

server/job/job-status-transition.js

@@ -9,83 +9,84 @@ const logger = require("../utils/logger");
 Dinero.globalRoundingMode = "HALF_EVEN";
 const path = require("path");
 const client = require("../graphql-client/graphql-client").client;
+
 require("dotenv").config({
-  path: path.resolve(
+    path: path.resolve(
-    process.cwd(),
+        process.cwd(),
-    `.env.${process.env.NODE_ENV || "development"}`
+        `.env.${process.env.NODE_ENV || "development"}`
-  ),
+    ),
 });
+
 async function StatusTransition(req, res) {
-  if (req.headers["event-secret"] !== process.env.EVENT_SECRET) {
+    const {
-    res.status(401).send("Unauthorized");
+        id: jobid,
-    return;
+        status: value,
-  }
+        shopid: bodyshopid,
-  res.sendStatus(200);
+    } = req.body.event.data.new;
-  return;
-  const {
-    id: jobid,
-    status: value,
-    shopid: bodyshopid,
-  } = req.body.event.data.new;
-  try {
-    const { update_transitions } = await client.request(
-      queries.UPDATE_OLD_TRANSITION,
-      {
-        jobid: jobid,
-        existingTransition: {
-          end: new Date(),
-          next_value: value,
 
-          //duration
+    // Create record OPEN on new item, enter state
-        },
+    // If change to SCHEDULE, update the last record and create a new record (update status and end time on old record, create a new record saying we came from previous status going to previous status
-      }
+    // (Timeline)
-    );
+    // Final status is exported, there is no end date as there is no further transition (has no end date)
+    try {
+        const {update_transitions} = await client.request(
+            queries.UPDATE_OLD_TRANSITION,
+            {
+                jobid: jobid,
+                existingTransition: {
+                    end: new Date(),
+                    next_value: value,
 
-    let duration =
+                    //duration
-      update_transitions.affected_rows === 0
+                },
-        ? 0
+            }
-        : new Date(update_transitions.returning[0].end) -
+        );
-          new Date(update_transitions.returning[0].start);
 
-    const resp2 = await client.request(queries.INSERT_NEW_TRANSITION, {
+        let duration =
-      oldTransitionId:
+            update_transitions.affected_rows === 0
-        update_transitions.affected_rows === 0
+                ? 0
-          ? null
+                : new Date(update_transitions.returning[0].end) -
-          : update_transitions.returning[0].id,
+                new Date(update_transitions.returning[0].start);
-      duration,
-      newTransition: {
-        bodyshopid: bodyshopid,
-        jobid: jobid,
-        start:
-          update_transitions.affected_rows === 0
-            ? new Date()
-            : update_transitions.returning[0].end,
-        prev_value:
-          update_transitions.affected_rows === 0
-            ? null
-            : update_transitions.returning[0].value,
-        value: value,
-        type: "status",
-      },
-    });
 
-    //Check to see if there is an existing status transition record.
+        const resp2 = await client.request(queries.INSERT_NEW_TRANSITION, {
-    //Query using Job ID, start is not null, end is null.
+            oldTransitionId:
+                update_transitions.affected_rows === 0
+                    ? null
+                    : update_transitions.returning[0].id,
+            duration,
+            newTransition: {
+                bodyshopid: bodyshopid,
+                jobid: jobid,
+                start:
+                    update_transitions.affected_rows === 0
+                        ? new Date()
+                        : update_transitions.returning[0].end,
+                prev_value:
+                    update_transitions.affected_rows === 0
+                        ? null
+                        : update_transitions.returning[0].value,
+                value: value,
+                type: "status",
+            },
+        });
 
-    //If there is no existing record, this is the start of the transition life cycle.
+        //Check to see if there is an existing status transition record.
-    // Create the initial transition record.
+        //Query using Job ID, start is not null, end is null.
 
-    //If there is a current status transition record, update it with the end date, duration, and next value.
+        //If there is no existing record, this is the start of the transition life cycle.
+        // Create the initial transition record.
 
-    res.sendStatus(200); //.json(ret);
+        //If there is a current status transition record, update it with the end date, duration, and next value.
-  } catch (error) {
-    logger.log("job-status-transition-error", "ERROR", req.user?.email, jobid, {
-      message: error.message,
-      stack: error.stack,
-    });
 
-    res.status(400).send(JSON.stringify(error));
+        res.sendStatus(200); //.json(ret);
-  }
+    } catch (error) {
+        logger.log("job-status-transition-error", "ERROR", req.user?.email, jobid, {
+            message: error.message,
+            stack: error.stack,
+        });
+
+        res.status(400).send(JSON.stringify(error));
+    }
 }
 
 exports.statustransition = StatusTransition;

server/job/job-totals.js

@@ -1,20 +1,18 @@
 const Dinero = require("dinero.js");
 const queries = require("../graphql-client/queries");
-const GraphQLClient = require("graphql-request").GraphQLClient;
+const logger = require('../utils/logger');
-const logger = require("../utils/logger");
+
 // Dinero.defaultCurrency = "USD";
 // Dinero.globalLocale = "en-CA";
 Dinero.globalRoundingMode = "HALF_EVEN";
 
 exports.totalsSsu = async function (req, res) {
-  const BearerToken = req.headers.authorization;
   const { id } = req.body;
+
+  const BearerToken = req.BearerToken;
+  const client = req.userGraphQLClient;
+
   logger.log("job-totals-ssu", "DEBUG", req.user.email, id, null);
-  const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
-    headers: {
-      Authorization: BearerToken,
-    },
-  });
 
   try {
     const job = await client
@@ -75,21 +73,19 @@ async function TotalsServerSide(req, res) {
 }
 
 async function Totals(req, res) {
-  const { job } = req.body;
+  const { job, id } = req.body;
+
+  const logger = req.logger;
+  const client = req.userGraphQLClient;
+
   logger.log("job-totals", "DEBUG", req.user.email, job.id, {
     jobid: job.id,
   });
 
-  const BearerToken = req.headers.authorization;
-  const { id } = req.body;
   logger.log("job-totals-ssu", "DEBUG", req.user.email, id, null);
-  const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
-    headers: {
-      Authorization: BearerToken,
-    },
-  });
 
   await AutoAddAtsIfRequired({ job, client });
+
   try {
     let ret = {
       parts: CalculatePartsTotals(job.joblines),

server/job/job.js

@@ -3,3 +3,4 @@ exports.totalsSsu = require("./job-totals").totalsSsu;
 exports.costing = require("./job-costing").JobCosting;
 exports.costingmulti = require("./job-costing").JobCostingMulti;
 exports.statustransition = require("./job-status-transition").statustransition;
+exports.lifecycle = require('./job-lifecycle');

server/middleware/eventAuthorizationMIddleware.js

@@ -0,0 +1,20 @@
+const path = require("path");
+
+/**
+ * Checks if the event secret is correct
+ * It adds the following properties to the request object:
+ * - req.isEventAuthorized - Returns true if the event secret is correct
+ * @param req
+ * @param res
+ * @param next
+ */
+function eventAuthorizationMiddleware(req, res, next) {
+    if (req.headers["event-secret"] !== process.env.EVENT_SECRET) {
+        return res.status(401).send("Unauthorized");
+    }
+
+    req.isEventAuthorized = true;
+    next();
+}
+
+module.exports = eventAuthorizationMiddleware;

server/middleware/validateAdminMiddleware.js

@@ -0,0 +1,26 @@
+const logger = require("../utils/logger");
+const adminEmail = require("../utils/adminEmail");
+
+/**
+ * Validate admin middleware
+ * It adds the following properties to the request object:
+ * - req.isAdmin - returns true if the user passed an admin check
+ * @param req
+ * @param res
+ * @param next
+ * @returns {*}
+ */
+const validateAdminMiddleware = (req, res, next) => {
+    if (!adminEmail.includes(req.user.email) && !req.user.ioadmin) {
+        logger.log("admin-validation-failed", "ERROR", req.user.email, null, {
+            request: req.body,
+            user: req.user,
+        });
+        return res.sendStatus(404);
+    }
+
+    req.isAdmin = true;
+    next();
+};
+
+module.exports = validateAdminMiddleware;

server/middleware/validateFirebaseIdTokenMiddleware.js

@@ -0,0 +1,69 @@
+const logger = require("../utils/logger");
+const admin = require("firebase-admin");
+
+/**
+ *  Middleware to validate Firebase ID Tokens.
+ *  This middleware is used to protect API endpoints from unauthorized access.
+ *  It adds the following properties to the request object:
+ *  - req.user - the decoded Firebase ID Token
+ * @param req
+ * @param res
+ * @param next
+ * @returns {Promise<void>}
+ */
+const validateFirebaseIdTokenMiddleware = async (req, res, next) => {
+    if (
+        (
+            !req.headers.authorization ||
+            !req.headers.authorization.startsWith("Bearer ")) &&
+            !(req.cookies && req.cookies.__session
+        )
+    ) {
+        console.error("Unauthorized attempt. No authorization provided.");
+        return res.status(403).send("Unauthorized");
+    }
+
+    let idToken;
+
+    if (
+        req.headers.authorization &&
+        req.headers.authorization.startsWith("Bearer ")
+    ) {
+        // console.log('Found "Authorization" header');
+        // Read the ID Token from the Authorization header.
+        idToken = req.headers.authorization.split("Bearer ")[1];
+    } else if (req.cookies) {
+        //console.log('Found "__session" cookie');
+        // Read the ID Token from cookie.
+        idToken = req.cookies.__session;
+    } else {
+        // No cookie
+        console.error("Unauthorized attempt. No cookie provided.");
+        logger.log("api-unauthorized-call", "WARN", null, null, {
+            req,
+            type: "no-cookie",
+        });
+
+        return res.status(403).send("Unauthorized");
+    }
+
+    try {
+        const decodedIdToken = await admin.auth().verifyIdToken(idToken);
+        //console.log("ID Token correctly decoded", decodedIdToken);
+        req.user = decodedIdToken;
+        next();
+
+    } catch (error) {
+        logger.log("api-unauthorized-call", "WARN", null, null, {
+            path: req.path,
+            body: req.body,
+
+            type: "unauthroized",
+            ...error,
+        });
+
+        return res.status(401).send("Unauthorized");
+    }
+};
+
+module.exports = validateFirebaseIdTokenMiddleware;

server/middleware/withUserGraphQLClientMiddleware.js

@@ -0,0 +1,24 @@
+const {GraphQLClient} = require("graphql-request");
+
+/**
+ * Middleware to add a GraphQL Client to the request object
+ * Adds the following to the request object:
+ * req.userGraphQLClient - GraphQL Client with user Bearer Token
+ * req.BearerToken - Bearer Token
+ * @param req
+ * @param res
+ * @param next
+ */
+const withUserGraphQLClientMiddleware = (req, res, next) => {
+    const BearerToken = req.headers.authorization;
+    req.userGraphQLClient = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+        headers: {
+            Authorization: BearerToken,
+        },
+    });
+    req.BearerToken = BearerToken;
+
+    next();
+};
+
+module.exports = withUserGraphQLClientMiddleware;

server/mixdata/mixdata.js

@@ -1,9 +1,8 @@
 const path = require("path");
 const _ = require("lodash");
-const logger = require("../utils/logger");
 const xml2js = require("xml2js");
-const GraphQLClient = require("graphql-request").GraphQLClient;
 const queries = require("../graphql-client/queries");
+const logger = require('../utils/logger');
 
 require("dotenv").config({
   path: path.resolve(
@@ -15,13 +14,10 @@ require("dotenv").config({
 exports.mixdataUpload = async (req, res) => {
   const { bodyshopid } = req.body;
 
-  const BearerToken = req.headers.authorization;
+  const client = req.userGraphQLClient;
+
   logger.log("job-mixdata-upload", "DEBUG", req.user.email, null, null);
-  const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+
-    headers: {
-      Authorization: BearerToken,
-    },
-  });
 
   try {
     for (const element of req.files) {

server/opensearch/os-handler.js

@@ -5,7 +5,6 @@ require("dotenv").config({
     ),
 });
 
-const GraphQLClient = require("graphql-request").GraphQLClient;
 //const client = require("../graphql-client/graphql-client").client;
 const logger = require("../utils/logger");
 const queries = require("../graphql-client/queries");
@@ -15,10 +14,6 @@ const {getClient} = require('../../libs/awsUtils');
 
 
 async function OpenSearchUpdateHandler(req, res) {
-    if (req.headers["event-secret"] !== process.env.EVENT_SECRET) {
-        res.status(401).send("Unauthorized");
-        return;
-    }
     try {
 
         const osClient = await getClient();
@@ -186,12 +181,8 @@ async function OpenSearchSearchHandler(req, res) {
             search,
         });
 
-        const BearerToken = req.headers.authorization;
+        const BearerToken = req.BearerToken;
-        const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
+        const client = req.userGraphQLClient;
-            headers: {
-                Authorization: BearerToken,
-            },
-        });
 
         const assocs = await client
             .setHeaders({Authorization: BearerToken})

server/parts-scan/parts-scan.js

@@ -1,21 +1,19 @@
 const Dinero = require("dinero.js");
 const queries = require("../graphql-client/queries");
+const logger = require('../utils/logger');
 const { job } = require("../scheduling/scheduling-job");
-const GraphQLClient = require("graphql-request").GraphQLClient;
-const logger = require("../utils/logger");
 const _ = require("lodash");
+
 // Dinero.defaultCurrency = "USD";
 // Dinero.globalLocale = "en-CA";
 
 exports.partsScan = async function (req, res) {
-  const BearerToken = req.headers.authorization;
   const { jobid } = req.body;
+
+  const BearerToken = req.BearerToken;
+  const client = req.userGraphQLClient;
+
   logger.log("job-parts-scan", "DEBUG", req.user?.email, jobid, null);
-  const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
-    headers: {
-      Authorization: BearerToken,
-    },
-  });
 
   try {
     //Query all jobline data using the user's authorization.

server/routes/accountingRoutes.js

@@ -0,0 +1,13 @@
+const express = require('express');
+const router = express.Router();
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const {payments, payables, receivables} = require("../accounting/qbxml/qbxml");
+const withUserGraphQLClientMiddleware = require("../middleware/withUserGraphQLClientMiddleware");
+
+router.use(validateFirebaseIdTokenMiddleware);
+
+router.post('/qbxml/receivables', withUserGraphQLClientMiddleware, receivables);
+router.post('/qbxml/payables', withUserGraphQLClientMiddleware, payables);
+router.post('/qbxml/payments', withUserGraphQLClientMiddleware, payments);
+
+module.exports = router;

server/routes/adminRoutes.js

@@ -0,0 +1,18 @@
+const express = require('express');
+const router = express.Router();
+const fb = require('../firebase/firebase-handler');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const {createAssociation, createShop, updateShop, updateCounter} = require("../admin/adminops");
+const validateAdminMiddleware = require("../middleware/validateAdminMiddleware");
+
+router.use(validateFirebaseIdTokenMiddleware);
+
+router.post('/createassociation', validateAdminMiddleware, createAssociation);
+router.post('/createshop', validateAdminMiddleware, createShop);
+router.post('/updateshop', validateAdminMiddleware, updateShop);
+router.post('/updatecounter', validateAdminMiddleware, updateCounter);
+router.post('/updateuser', fb.updateUser);
+router.post('/getuser', fb.getUser);
+router.post('/createuser', fb.createUser);
+
+module.exports = router;

server/routes/cdkRoutes.js

@@ -0,0 +1,11 @@
+const express = require('express');
+const router = express.Router();
+const cdkGetMake = require('../cdk/cdk-get-makes');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const withUserGraphQLClientMiddleware = require("../middleware/withUserGraphQLClientMiddleware");
+
+router.use(validateFirebaseIdTokenMiddleware);
+
+router.post('/getvehicles', withUserGraphQLClientMiddleware, cdkGetMake.default);
+
+module.exports = router;

server/routes/dataRoutes.js

@@ -0,0 +1,9 @@
+const express = require('express');
+const router = express.Router();
+const {autohouse, claimscorp, kaizen} = require('../data/data');
+
+router.post('/ah', autohouse);
+router.post('/cc', claimscorp);
+router.post('/kaizen', kaizen);
+
+module.exports = router;

server/routes/intellipayRoutes.js

@@ -0,0 +1,11 @@
+const express = require('express');
+const router = express.Router();
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const {lightbox_credentials, payment_refund, generate_payment_url, postback} = require("../intellipay/intellipay");
+
+router.post('/lightbox_credentials', validateFirebaseIdTokenMiddleware, lightbox_credentials);
+router.post('/payment_refund', validateFirebaseIdTokenMiddleware, payment_refund);
+router.post('/generate_payment_url', validateFirebaseIdTokenMiddleware, generate_payment_url);
+router.post('/postback', postback);
+
+module.exports = router;

server/routes/jobRoutes.js

@@ -0,0 +1,18 @@
+const express = require('express');
+const router = express.Router();
+const job = require('../job/job');
+const {partsScan} = require('../parts-scan/parts-scan');
+const eventAuthorizationMiddleware = require('../middleware/eventAuthorizationMIddleware');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const {totals, statustransition, totalsSsu, costing, lifecycle, costingmulti} = require("../job/job");
+const withUserGraphQLClientMiddleware = require("../middleware/withUserGraphQLClientMiddleware");
+
+router.post('/totals', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, totals);
+router.post('/statustransition', eventAuthorizationMiddleware, statustransition);
+router.post('/totalsssu', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware,totalsSsu);
+router.post('/costing', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware,costing);
+router.post('/lifecycle', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, lifecycle);
+router.post('/costingmulti', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, costingmulti);
+router.post('/partsscan', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, partsScan);
+
+module.exports = router;

server/routes/mediaRoutes.js

@@ -0,0 +1,13 @@
+const express = require('express');
+const router = express.Router();
+const {createSignedUploadURL, downloadFiles, renameKeys, deleteFiles} = require('../media/media');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+
+router.use(validateFirebaseIdTokenMiddleware);
+
+router.post('/sign', createSignedUploadURL);
+router.post('/download', downloadFiles);
+router.post('/rename', renameKeys);
+router.post('/delete', deleteFiles);
+
+module.exports = router;

server/routes/miscellaneousRoutes.js

@@ -0,0 +1,51 @@
+const express = require('express');
+const router = express.Router();
+const logger = require("../../server/utils/logger");
+const sendEmail = require("../email/sendemail");
+const data = require("../data/data");
+const bodyParser = require("body-parser");
+const ioevent = require("../ioevent/ioevent");
+const taskHandler = require("../tasks/tasks");
+const os = require("../opensearch/os-handler");
+const eventAuthorizationMiddleware = require("../middleware/eventAuthorizationMIddleware");
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const withUserGraphQLClientMiddleware = require("../middleware/withUserGraphQLClientMiddleware");
+
+//Test route to ensure Express is responding.
+router.get("/test", async function (req, res) {
+    const commit = require("child_process").execSync(
+        "git rev-parse --short HEAD"
+    );
+    // console.log(app.get('trust proxy'));
+    // console.log("remoteAddress", req.socket.remoteAddress);
+    // console.log("X-Forwarded-For", req.header('x-forwarded-for'));
+    logger.log("test-api-status", "DEBUG", "api", {commit});
+    // sendEmail.sendServerEmail({
+    //   subject: `API Check - ${process.env.NODE_ENV}`,
+    //   text: `Server API check has come in. Remote IP: ${req.socket.remoteAddress}, X-Forwarded-For: ${req.header('x-forwarded-for')}`,
+    // });
+    sendEmail.sendServerEmail({
+        subject: `API Check - ${process.env.NODE_ENV}`,
+        text: `Server API check has come in.`,
+    });
+    res.status(200).send(`OK - ${commit}`);
+});
+
+// Search
+router.post("/search", validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, os.search);
+router.post("/opensearch", eventAuthorizationMiddleware, os.handler);
+
+
+// IO Events
+router.post('/ioevent', ioevent.default);
+
+// Email
+router.post('/sendemail', validateFirebaseIdTokenMiddleware, sendEmail.sendEmail);
+router.post('/emailbounce', bodyParser.text(), sendEmail.emailBounce);
+
+// Handlers
+router.post('/record-handler/arms', data.arms);
+router.post("/taskHandler", validateFirebaseIdTokenMiddleware, taskHandler.taskHandler);
+
+
+module.exports = router;

server/routes/mixDataRoutes.js

@@ -0,0 +1,11 @@
+const express = require('express');
+const router = express.Router();
+const multer = require('multer');
+const upload = multer();
+const {mixdataUpload} = require('../mixdata/mixdata');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const withUserGraphQLClientMiddleware = require("../middleware/withUserGraphQLClientMiddleware");
+
+router.post('/upload', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, upload.any(), mixdataUpload);
+
+module.exports = router;

server/routes/notificationsRoutes.js

@@ -0,0 +1,11 @@
+const express = require('express');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const {subscribe, unsubscribe} = require("../firebase/firebase-handler");
+const router = express.Router();
+
+router.use(validateFirebaseIdTokenMiddleware);
+
+router.post('/subscribe', subscribe);
+router.post('/unsubscribe', unsubscribe);
+
+module.exports = router;

server/routes/qboRoutes.js

@@ -0,0 +1,14 @@
+const express = require('express');
+const router = express.Router();
+const {authorize, callback, receivables, payables, payments} = require('../accounting/qbo/qbo');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const withUserGraphQLClientMiddleware = require("../middleware/withUserGraphQLClientMiddleware"); // Assuming you have a qbo module for handling QuickBooks Online related functionalities
+
+// Define the routes for QuickBooks Online
+router.post('/authorize', validateFirebaseIdTokenMiddleware, authorize);
+router.get('/callback', callback);
+router.post('/receivables', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, receivables);
+router.post('/payables', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, payables);
+router.post('/payments', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, payments);
+
+module.exports = router;

server/routes/renderRoutes.js

@@ -0,0 +1,9 @@
+const express = require('express');
+const router = express.Router();
+const {inlinecss} = require('../render/inlinecss');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+
+// Define the route for inline CSS rendering
+router.post('/inlinecss', validateFirebaseIdTokenMiddleware, inlinecss);
+
+module.exports = router;

server/routes/schedulingRoutes.js

@@ -0,0 +1,9 @@
+const express = require('express');
+const router = express.Router();
+const {job} = require('../scheduling/scheduling-job');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+const withUserGraphQLClientMiddleware = require("../middleware/withUserGraphQLClientMiddleware");
+
+router.post('/job', validateFirebaseIdTokenMiddleware, withUserGraphQLClientMiddleware, job);
+
+module.exports = router;

server/routes/smsRoutes.js

@@ -0,0 +1,17 @@
+const express = require('express');
+const router = express.Router();
+const twilio = require('twilio');
+const {receive} = require('../sms/receive');
+const {send} = require('../sms/send');
+const {status, markConversationRead} = require('../sms/status');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+
+// Twilio Webhook Middleware for production
+const twilioWebhookMiddleware = twilio.webhook({ validate: process.env.NODE_ENV === "PRODUCTION" });
+
+router.post('/receive', twilioWebhookMiddleware, receive);
+router.post('/send', validateFirebaseIdTokenMiddleware, send);
+router.post('/status', twilioWebhookMiddleware, status);
+router.post('/markConversationRead', validateFirebaseIdTokenMiddleware, markConversationRead);
+
+module.exports = router;

server/routes/techRoutes.js

@@ -0,0 +1,8 @@
+const express = require('express');
+const router = express.Router();
+const {techLogin} = require('../tech/tech');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+
+router.post('/login', validateFirebaseIdTokenMiddleware, techLogin);
+
+module.exports = router;

server/routes/utilRoutes.js

@@ -0,0 +1,9 @@
+const express = require('express');
+const router = express.Router();
+const {servertime, jsrAuth} = require('../utils/utils');
+const validateFirebaseIdTokenMiddleware = require("../middleware/validateFirebaseIdTokenMiddleware");
+
+router.post('/time', servertime);
+router.post('/jsr', validateFirebaseIdTokenMiddleware, jsrAuth);
+
+module.exports = router;

server/scheduling/scheduling-job.js

@@ -1,4 +1,3 @@
-const GraphQLClient = require("graphql-request").GraphQLClient;
 const path = require("path");
 const queries = require("../graphql-client/queries");
 const Dinero = require("dinero.js");
@@ -14,17 +13,14 @@ require("dotenv").config({
 });
 
 exports.job = async (req, res) => {
-  const BearerToken = req.headers.authorization;
   const { jobId } = req.body;
+
+  const BearerToken = req.BearerToken;
+  const client = req.userGraphQLClient;
+
   try {
     logger.log("smart-scheduling-start", "DEBUG", req.user.email, jobId, null);
 
-    const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {
-      headers: {
-        Authorization: BearerToken,
-      },
-    });
-
     const result = await client
       .setHeaders({ Authorization: BearerToken })
       .request(queries.QUERY_UPCOMING_APPOINTMENTS, {

server/utils/adminEmail.js

@@ -0,0 +1,13 @@
+/**
+ * List of admin email addresses
+ * @type {string[]}
+ */
+const adminEmail = [
+    "patrick@imex.dev",
+    //"patrick@imex.test",
+    "patrick@imex.prod",
+    "patrick@imexsystems.ca",
+    "patrick@thinkimex.com",
+];
+
+module.exports = adminEmail;

server/utils/calculateStatusDuration.js

@@ -0,0 +1,100 @@
+const durationToHumanReadable = require("./durationToHumanReadable");
+const moment = require("moment");
+const _ = require("lodash");
+const crypto = require('crypto');
+
+const getColor = (key) => {
+    const hash = crypto.createHash('sha256');
+    hash.update(key);
+    const hashedKey = hash.digest('hex');
+    const num = parseInt(hashedKey, 16);
+    return '#' + (num % 16777215).toString(16).padStart(6, '0');
+};
+
+const calculateStatusDuration = (transitions, statuses) => {
+    let statusDuration = {};
+    let totalDuration = 0;
+    let totalCurrentStatusDuration = null;
+    let summations = [];
+
+    transitions.forEach((transition, index) => {
+        let duration = transition.duration;
+        totalDuration += duration;
+        if (transition.start && !transition.end) {
+            const startMoment = moment(transition.start);
+            const nowMoment = moment();
+            const duration = moment.duration(nowMoment.diff(startMoment));
+            totalCurrentStatusDuration = {
+                value: duration.asMilliseconds(),
+                humanReadable: durationToHumanReadable(duration)
+            };
+        }
+
+        if (!transition.prev_value) {
+            statusDuration[transition.value] = {
+                value: duration,
+                humanReadable: transition.duration_readable
+            };
+        } else if (!transition.next_value) {
+            if (statusDuration[transition.value]) {
+                statusDuration[transition.value].value += duration;
+                statusDuration[transition.value].humanReadable = transition.duration_readable;
+            } else {
+                statusDuration[transition.value] = {
+                    value: duration,
+                    humanReadable: transition.duration_readable
+                };
+            }
+        } else {
+            if (statusDuration[transition.value]) {
+                statusDuration[transition.value].value += duration;
+                statusDuration[transition.value].humanReadable = transition.duration_readable;
+            } else {
+                statusDuration[transition.value] = {
+                    value: duration,
+                    humanReadable: transition.duration_readable
+                };
+            }
+        }
+    });
+
+    // Calculate the percentage for each status
+// Calculate the percentage for each status
+    let totalPercentage = 0;
+    const statusKeys = Object.keys(statusDuration);
+    statusKeys.forEach((status, index) => {
+        if (index !== statusKeys.length - 1) {
+            const percentage = (statusDuration[status].value / totalDuration) * 100;
+            totalPercentage += percentage;
+            statusDuration[status].percentage = percentage;
+        } else {
+            statusDuration[status].percentage = 100 - totalPercentage;
+        }
+    });
+
+    for (let [status, {value, humanReadable}] of Object.entries(statusDuration)) {
+        if (status !== 'total') {
+            summations.push({
+                status,
+                value,
+                humanReadable,
+                percentage: statusDuration[status].percentage,
+                color: getColor(status),
+                roundedPercentage: `${Math.round(statusDuration[status].percentage)}%`
+            });
+        }
+    }
+
+    const humanReadableTotal = durationToHumanReadable(moment.duration(totalDuration));
+
+    return {
+        summations: _.isArray(statuses) && !_.isEmpty(statuses) ? summations.sort((a, b) => {
+            return statuses.indexOf(a.status) - statuses.indexOf(b.status);
+        }) : summations,
+        totalStatuses: summations.length,
+        total: totalDuration,
+        totalCurrentStatusDuration,
+        humanReadableTotal
+    };
+}
+module.exports = calculateStatusDuration;

server/utils/durationToHumanReadable.js

@@ -0,0 +1,22 @@
+const durationToHumanReadable = (duration) => {
+    if (!duration) return 'N/A';
+
+    let parts = [];
+
+    let years = duration.years();
+    let months = duration.months();
+    let days = duration.days();
+    let hours = duration.hours();
+    let minutes = duration.minutes();
+    let seconds = duration.seconds();
+
+    if (years) parts.push(years + ' year' + (years > 1 ? 's' : ''));
+    if (months) parts.push(months + ' month' + (months > 1 ? 's' : ''));
+    if (days) parts.push(days + ' day' + (days > 1 ? 's' : ''));
+    if (hours) parts.push(hours + ' hour' + (hours > 1 ? 's' : ''));
+    if (minutes) parts.push(minutes + ' minute' + (minutes > 1 ? 's' : ''));
+    if (seconds) parts.push(seconds + ' second' + (seconds > 1 ? 's' : ''));
+
+    return parts.join(', ');
+}
+module.exports = durationToHumanReadable;