Add job reconciliation & autohouse filtering.

release/2022-06-17

Approved-by: Patrick Fic

bodyshop_translations.babel

@@ -1,4 +1,4 @@
-<babeledit_project be_version="2.7.1" version="1.2">
+<babeledit_project version="1.2" be_version="2.7.1">
     <!--
 
     BabelEdit project file
@@ -15374,6 +15374,27 @@
                                             </translation>
                                         </translations>
                                     </concept_node>
+                                    <concept_node>
+                                        <name>sizelimit</name>
+                                        <definition_loaded>false</definition_loaded>
+                                        <description></description>
+                                        <comment></comment>
+                                        <default_text></default_text>
+                                        <translations>
+                                            <translation>
+                                                <language>en-US</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>es-MX</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>fr-CA</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                        </translations>
+                                    </concept_node>
                                 </children>
                             </folder_node>
                             <folder_node>
@@ -40025,6 +40046,27 @@
                                             </translation>
                                         </translations>
                                     </concept_node>
+                                    <concept_node>
+                                        <name>jobs_reconcile</name>
+                                        <definition_loaded>false</definition_loaded>
+                                        <description></description>
+                                        <comment></comment>
+                                        <default_text></default_text>
+                                        <translations>
+                                            <translation>
+                                                <language>en-US</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>es-MX</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                            <translation>
+                                                <language>fr-CA</language>
+                                                <approved>false</approved>
+                                            </translation>
+                                        </translations>
+                                    </concept_node>
                                     <concept_node>
                                         <name>lag_time</name>
                                         <definition_loaded>false</definition_loaded>
@@ -44929,6 +44971,27 @@
                                     <folder_node>
                                         <name>signinerror</name>
                                         <children>
+                                            <concept_node>
+                                                <name>auth/user-disabled</name>
+                                                <definition_loaded>false</definition_loaded>
+                                                <description></description>
+                                                <comment></comment>
+                                                <default_text></default_text>
+                                                <translations>
+                                                    <translation>
+                                                        <language>en-US</language>
+                                                        <approved>false</approved>
+                                                    </translation>
+                                                    <translation>
+                                                        <language>es-MX</language>
+                                                        <approved>false</approved>
+                                                    </translation>
+                                                    <translation>
+                                                        <language>fr-CA</language>
+                                                        <approved>false</approved>
+                                                    </translation>
+                                                </translations>
+                                            </concept_node>
                                             <concept_node>
                                                 <name>auth/user-not-found</name>
                                                 <definition_loaded>false</definition_loaded>

client/src/components/bill-cm-returns-table/bill-cm-returns-table.component.jsx

@@ -5,7 +5,6 @@ import ReadOnlyFormItemComponent from "../form-items-formatted/read-only-form-it
 import "./bill-cm-returns-table.styles.scss";
 export default function BillCmdReturnsTableComponent({
   form,
-  loadOutstandingReturns,
   returnLoading,
   returnData,
 }) {

client/src/components/bill-form/bill-form.component.jsx

@@ -58,6 +58,7 @@ export function BillFormComponent({
     {},
     bodyshop.imexshopid
   );
+
   const handleVendorSelect = (props, opt) => {
     setDiscount(opt.discount);
 
@@ -140,13 +141,14 @@ export function BillFormComponent({
             onBlur={() => {
               if (form.getFieldValue("jobid") !== null) {
                 loadLines({ variables: { id: form.getFieldValue("jobid") } });
-                if (form.getFieldValue("vendorid") !== null)
+                if (form.getFieldValue("vendorid") !== null) {
                   loadOutstandingReturns({
                     variables: {
                       jobId: form.getFieldValue("jobid"),
                       vendorId: form.getFieldValue("vendorid"),
                     },
                   });
+                }
               }
             }}
           />
@@ -273,12 +275,13 @@ export function BillFormComponent({
                   getFieldValue("jobid") &&
                   getFieldValue("vendorid")
                 ) {
-                  loadOutstandingReturns({
-                    variables: {
-                      jobId: form.getFieldValue("jobid"),
-                      vendorId: form.getFieldValue("vendorid"),
-                    },
-                  });
+                  //Removed as this would cause an additional reload when validating the form on submit and clear the values.
+                  // loadOutstandingReturns({
+                  //   variables: {
+                  //     jobId: form.getFieldValue("jobid"),
+                  //     vendorId: form.getFieldValue("vendorid"),
+                  //   },
+                  // });
                 }
 
                 if (

client/src/components/bill-form/bill-form.container.jsx

@@ -63,7 +63,6 @@ export function BillFormContainer({
       {!billEdit && (
         <BillCmdReturnsTableComponent
           form={form}
-          loadOutstandingReturns={loadOutstandingReturns}
           returnLoading={returnLoading}
           returnData={returnData}
         />

client/src/components/documents-upload/documents-upload.utility.js

@@ -54,7 +54,7 @@ export const uploadToCloudinary = async (
   //Set variables for getting the signed URL.
   let timestamp = Math.floor(Date.now() / 1000);
   let public_id = key;
-  let tags = `${bodyshop.textid},${
+  let tags = `${bodyshop.imexshopid},${
     tagsArray ? tagsArray.map((tag) => `${tag},`) : ""
   }`;
   //  let eager = process.env.REACT_APP_CLOUDINARY_THUMB_TRANSFORMATIONS;

client/src/components/email-documents/email-documents.component.jsx

@@ -38,6 +38,12 @@ export function EmailDocumentsComponent({
     nextFetchPolicy: "network-only",
   });
 
+  console.log(
+    selectedMedia &&
+      selectedMedia
+        .filter((s) => s.isSelected)
+        .reduce((acc, val) => (acc = acc + val.size), 0)
+  );
   return (
     <div>
       {loading && <LoadingSpinner />}
@@ -45,6 +51,12 @@ export function EmailDocumentsComponent({
       {selectedMedia.filter((s) => s.isSelected).length >= 10 ? (
         <div style={{ color: "red" }}>{t("messaging.labels.maxtenimages")}</div>
       ) : null}
+      {selectedMedia &&
+      selectedMedia
+        .filter((s) => s.isSelected)
+        .reduce((acc, val) => (acc = acc + val.size), 0) >= 9961472 ? (
+        <div style={{ color: "red" }}>{t("general.errors.sizelimit")}</div>
+      ) : null}
       {data && (
         <JobDocumentsGalleryExternal
           data={data ? data.documents : []}

client/src/components/email-overlay/email-overlay.component.jsx

@@ -180,6 +180,23 @@ export function EmailOverlayComponent({
               }
               return e && e.fileList;
             }}
+            rules={[
+              ({ getFieldValue }) => ({
+                validator(rule, value) {
+                  const totalSize = value.reduce(
+                    (acc, val) => (acc = acc + val.size),
+                    0
+                  );
+
+                  const limit = 9961472;
+
+                  if (totalSize > limit) {
+                    return Promise.reject(t("general.errors.sizelimit"));
+                  }
+                  return Promise.resolve();
+                },
+              }),
+            ]}
           >
             <Upload.Dragger
               beforeUpload={Upload.LIST_IGNORE}

client/src/components/error-boundary/error-boundary.component.jsx

@@ -30,6 +30,7 @@ class ErrorBoundary extends React.Component {
 
   static getDerivedStateFromError(error) {
     console.log("ErrorBoundary -> getDerivedStateFromError -> error", error);
+
     return { hasErrored: true, error: error };
   }
 

client/src/components/jobs-documents-gallery/jobs-documents-gallery.external.component.jsx

@@ -25,6 +25,7 @@ function JobsDocumentGalleryExternal({
           id: value.id,
           type: value.type,
           tags: [{ value: value.type, title: value.type }],
+          size: value.size,
         });
       }
 

client/src/components/owner-find-modal/owner-find-modal.container.jsx

@@ -31,7 +31,7 @@ export default function OwnerFindModalContainer({
 
   useEffect(() => {
     if (modalProps.visible && owner) {
-      const s = OwnerNameDisplayFunction(owner);
+      const s = OwnerNameDisplayFunction(owner, true);
 
       setSearchText(s.trim());
       callSearchowners({ variables: { search: s.trim() } });

client/src/components/owner-name-display/owner-name-display.component.jsx

@@ -27,7 +27,7 @@ export function OwnerNameDisplay({ bodyshop, ownerObject }) {
   }`.trim();
 }
 
-export function OwnerNameDisplayFunction(ownerObject) {
+export function OwnerNameDisplayFunction(ownerObject, forceFirstLast = false) {
   const emptyTest =
     ownerObject.ownr_fn + ownerObject.ownr_ln + ownerObject.ownr_co_nm;
 
@@ -36,7 +36,7 @@ export function OwnerNameDisplayFunction(ownerObject) {
 
   const rdxStore = store.getState();
 
-  if (rdxStore.user.bodyshop.last_name_first)
+  if (rdxStore.user.bodyshop.last_name_first && !forceFirstLast)
     return `${ownerObject.ownr_ln || ""}, ${ownerObject.ownr_fn || ""} ${
       ownerObject.ownr_co_nm || ""
     }`.trim();

client/src/components/time-tickets-summary-employees/time-tickets-summary-employees.component.jsx

@@ -146,7 +146,8 @@ const JobRelatedTicketsTable = ({
       title: t("employees.labels.name"),
       dataIndex: "empname",
       key: "empname",
-      sorter: (a, b) => alphaSort(a.empname, b.empname),
+      sorter: (a, b) =>
+        alphaSort(a.item.employee.last_name, b.item.employee.last_name),
       sortOrder:
         state.sortedInfo.columnKey === "empname" && state.sortedInfo.order,
       render: (text, record) =>
@@ -172,7 +173,9 @@ const JobRelatedTicketsTable = ({
       title: t("timetickets.fields.efficiency"),
       dataIndex: "total",
       key: "total",
-      sorter: (a, b) => a.total - b.total,
+      sorter: (a, b) =>
+        (a.actHrs === 0 || !a.actHrs ? 0 : (a.prodHrs / a.actHrs) * 100) -
+        (b.actHrs === 0 || !b.actHrs ? 0 : (b.prodHrs / b.actHrs) * 100),
       sortOrder:
         state.sortedInfo.columnKey === "total" && state.sortedInfo.order,
       render: (text, record) =>

client/src/pages/manage/manage.page.component.jsx

@@ -24,6 +24,8 @@ import {
   selectBodyshop,
   selectInstanceConflict,
 } from "../../redux/user/user.selectors";
+import * as Sentry from "@sentry/react";
+
 import "./manage.page.styles.scss";
 
 const ManageRootPage = lazy(() =>
@@ -407,7 +409,10 @@ export function Manage({ match, conflict, bodyshop }) {
 
         <Content className="content-container">
           <PartnerPingComponent />
-          <ErrorBoundary>{PageContent}</ErrorBoundary>
+          <Sentry.ErrorBoundary fallback={<ErrorBoundary />} showDialog>
+            {PageContent}
+          </Sentry.ErrorBoundary>
+
           <BackTop />
           <Footer>
             <div

client/src/translations/en_us/common.json

@@ -961,7 +961,8 @@
 			},
 			"errors": {
 				"fcm": "You must allow notification permissions to have real time messaging.  Click to try again.",
-				"notfound": "No record was found."
+				"notfound": "No record was found.",
+				"sizelimit": "The selected items exceed the size limit."
 			},
 			"itemtypes": {
 				"contract": "CC Contract",
@@ -2379,6 +2380,7 @@
 				"job_costing_ro_date_summary": "Job Costing by RO - Summary",
 				"job_costing_ro_estimator": "Job Costing by Estimator",
 				"job_costing_ro_ins_co": "Job Costing by RO Source",
+				"jobs_reconcile": "Parts/Sublet/Labor Reconciliation",
 				"lag_time": "Lag Time",
 				"open_orders": "Open Orders by Date",
 				"open_orders_csr": "Open Orders by CSR",
@@ -2668,6 +2670,7 @@
 		"users": {
 			"errors": {
 				"signinerror": {
+					"auth/user-disabled": "User account disabled. ",
 					"auth/user-not-found": "A user with this email does not exist.",
 					"auth/wrong-password": "The email and password combination you provided is incorrect."
 				}

client/src/translations/es/common.json

@@ -961,7 +961,8 @@
 			},
 			"errors": {
 				"fcm": "",
-				"notfound": ""
+				"notfound": "",
+				"sizelimit": ""
 			},
 			"itemtypes": {
 				"contract": "",
@@ -2379,6 +2380,7 @@
 				"job_costing_ro_date_summary": "",
 				"job_costing_ro_estimator": "",
 				"job_costing_ro_ins_co": "",
+				"jobs_reconcile": "",
 				"lag_time": "",
 				"open_orders": "",
 				"open_orders_csr": "",
@@ -2668,6 +2670,7 @@
 		"users": {
 			"errors": {
 				"signinerror": {
+					"auth/user-disabled": "",
 					"auth/user-not-found": "",
 					"auth/wrong-password": ""
 				}

client/src/translations/fr/common.json

@@ -961,7 +961,8 @@
 			},
 			"errors": {
 				"fcm": "",
-				"notfound": ""
+				"notfound": "",
+				"sizelimit": ""
 			},
 			"itemtypes": {
 				"contract": "",
@@ -2379,6 +2380,7 @@
 				"job_costing_ro_date_summary": "",
 				"job_costing_ro_estimator": "",
 				"job_costing_ro_ins_co": "",
+				"jobs_reconcile": "",
 				"lag_time": "",
 				"open_orders": "",
 				"open_orders_csr": "",
@@ -2668,6 +2670,7 @@
 		"users": {
 			"errors": {
 				"signinerror": {
+					"auth/user-disabled": "",
 					"auth/user-not-found": "",
 					"auth/wrong-password": ""
 				}

client/src/utils/RenderTemplate.js

@@ -103,7 +103,7 @@ export default async function RenderTemplate(
             }),
           },
         };
-        console.log("PDFREQ", pdfRequest);
+
         const pdfRender = await jsreport.renderAsync(pdfRequest);
         pdf = pdfRender.toDataURI();
       }

client/src/utils/TemplateConstants.js

@@ -1534,6 +1534,18 @@ export const TemplateList = (type, context) => {
             },
             group: "purchases",
           },
+          jobs_reconcile: {
+            title: i18n.t("reportcenter.templates.jobs_reconcile"),
+            subject: i18n.t("reportcenter.templates.jobs_reconcile"),
+            key: "jobs_reconcile",
+            //idtype: "vendor",
+            disabled: false,
+            rangeFilter: {
+              object: i18n.t("reportcenter.labels.objects.jobs"),
+              field: i18n.t("jobs.fields.date_invoiced"),
+            },
+            group: "jobs",
+          },
         }
       : {}),
     ...(!type || type === "courtesycarcontract"

firebase/readme.md

@@ -1,3 +1,3 @@
 Must set the environment variables using:
 
-firebase functions:config:set auth.graphql_endpoint="https://bodyshop-dev-db.herokuapp.com/v1/graphql" auth.hasura_secret_admin_key="Dev-BodyShopApp!"
+firebase functions:config:set auth.graphql_endpoint="https://db.development.bodyshop.app/v1/graphql" auth.hasura_secret_admin_key="Dev-BodyShopApp!"

hasura/config.yaml

@@ -1,5 +1,5 @@
 version: 2
-endpoint: https://bodyshop-dev-db.herokuapp.com
+endpoint: https://db.development.bodyshop.app
 admin_secret: Dev-BodyShopApp!
 metadata_directory: metadata
 actions:

server.js

@@ -157,7 +157,21 @@ app.post(
   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
+);
 
 //Stripe Processing
 var stripe = require("./server/stripe/payment");
@@ -216,7 +230,7 @@ server.listen(port, (error) => {
   if (error) throw error;
   logger.log(
     `[${process.env.NODE_ENV || "DEVELOPMENT"}] Server running on port ${port}`,
-    "DEBUG",
+    "INFO",
     "api"
   );
 });

server/accounting/qbo/qbo-payments.js

@@ -179,7 +179,6 @@ exports.default = async (req, res) => {
         ret.push({ paymentid: payment.id, success: true });
       } catch (error) {
         logger.log("qbo-payment-create-error", "ERROR", req.user.email, {
-          
           error:
             (error && error.authResponse && error.authResponse.body) ||
             (error && error.message),
@@ -217,7 +216,10 @@ exports.default = async (req, res) => {
     res.status(200).json(ret);
   } catch (error) {
     console.log(error);
-    logger.log("qbo-payment-create-error", "ERROR", req.user.email,  { error: error.message, stack: error.stack });
+    logger.log("qbo-payment-create-error", "ERROR", req.user.email, {
+      error: error.message,
+      stack: error.stack,
+    });
     res.status(400).json(error);
   }
 };
@@ -240,7 +242,7 @@ async function InsertPayment(
 
   if (invoices && invoices.length !== 1) {
     throw new Error(
-      `More than 1 invoice with DocNumber ${payment.ro_number} found.`
+      `More than 1 invoice with DocNumber ${payment.job.ro_number} found.`
     );
   }
 

server/admin/adminops.js

@@ -0,0 +1,68 @@
+const path = require("path");
+
+const _ = require("lodash");
+const logger = require("../utils/logger");
+require("dotenv").config({
+  path: path.resolve(
+    process.cwd(),
+    `.env.${process.env.NODE_ENV || "development"}`
+  ),
+});
+
+const client = require("../graphql-client/graphql-client").client;
+
+exports.createAssociation = async (req, res) => {
+  logger.log("admin-create-association", "ADMIN", req.user.email, null, {
+    request: req.body,
+    ioadmin: true,
+  });
+  const { shopid, authlevel, useremail } = req.body;
+
+  const result = await client.request(
+    `mutation INSERT_ASSOCIATION($assoc: associations_insert_input!){
+  insert_associations_one(object:$assoc){
+    id
+    authlevel
+    useremail
+    active
+  }
+}`,
+    {
+      assoc: { shopid, authlevel, useremail, active: false },
+    }
+  );
+  res.json(result);
+};
+exports.createShop = async (req, res) => {
+  logger.log("admin-create-shop", "ADMIN", req.user.email, null, {
+    request: req.body,
+    ioadmin: true,
+  });
+  const { bodyshop, ronum } = req.body;
+
+  try {
+    const result = await client.request(
+      `mutation INSERT_BODYSHOPS($bs: bodyshops_insert_input!){
+  insert_bodyshops_one(object:$bs){
+    id
+   
+  }
+}`,
+      {
+        bs: {
+          ...bodyshop,
+          counters: {
+            data: [
+              { countertype: "ronum", count: ronum },
+              { countertype: "ihbnum", count: 1 },
+              { countertype: "paymentnum", count: 1 },
+            ],
+          },
+        },
+      }
+    );
+    res.json(result);
+  } catch (error) {
+    res.status(500).json(error);
+  }
+};

server/data/autohouse.js

@@ -665,6 +665,7 @@ const CreateRepairOrderTag = (job, errorCallback) => {
 const CreateCosts = (job) => {
   //Create a mapping based on AH Requirements
 
+  //For DMS, the keys in the object below are the CIECA part types.
   const billTotalsByCostCenters = job.bills.reduce((bill_acc, bill_val) => {
     //At the bill level.
     bill_val.billlines.map((line_val) => {
@@ -731,7 +732,7 @@ const CreateCosts = (job) => {
       }).multiply(job.job_totals.rates.mash.hours)
     );
   }
-
+  //Uses CIECA Labor types.
   const ticketTotalsByCostCenter = job.timetickets.reduce(
     (ticket_acc, ticket_val) => {
       //At the invoice level.
@@ -750,7 +751,43 @@ const CreateCosts = (job) => {
     },
     {}
   );
-  const defaultCosts = job.bodyshop.md_responsibility_centers.defaults.costs;
+  //CIECA STANDARD MAPPING OBJECT.
+
+  const ciecaObj = {
+    ATS: "ATS",
+    LA1: "LA1",
+    LA2: "LA2",
+    LA3: "LA3",
+    LA4: "LA4",
+    LAA: "LAA",
+    LAB: "LAB",
+    LAD: "LAD",
+    LAE: "LAE",
+    LAF: "LAF",
+    LAG: "LAG",
+    LAM: "LAM",
+    LAR: "LAR",
+    LAS: "LAS",
+    LAU: "LAU",
+    PAA: "PAA",
+    PAC: "PAC",
+    PAG: "PAG",
+    PAL: "PAL",
+    PAM: "PAM",
+    PAN: "PAN",
+    PAO: "PAO",
+    PAP: "PAP",
+    PAR: "PAR",
+    PAS: "PAS",
+    TOW: "TOW",
+    MAPA: "MAPA",
+    MASH: "MASH",
+    PASL: "PASL",
+  };
+  const defaultCosts =
+    job.bodyshop.cdk_dealerid || job.bodyshop.pbs_serialnumber
+      ? ciecaObj
+      : job.bodyshop.md_responsibility_centers.defaults.costs;
 
   return {
     PartsTotalCost: Object.keys(billTotalsByCostCenters).reduce((acc, key) => {
@@ -852,7 +889,7 @@ const GenerateDetailLines = (job, line, statuses) => {
     OriginalCost: null,
     OriginalInvoiceNumber: null,
     PriceEach: line.act_price || 0,
-    PartNumber: _.escape(line.oem_partno),
+    PartNumber: _.escape(line.oem_partno.replace(/[^\x00-\x7F]/g, "")),
     ProfitPercent: null,
     PurchaseOrderNumber: null,
     Qty: line.part_qty || 0,

server/email/sendemail.js

@@ -10,7 +10,8 @@ let nodemailer = require("nodemailer");
 let aws = require("aws-sdk");
 const logger = require("../utils/logger");
 const ses = new aws.SES({
-  apiVersion: "2010-12-01",
+  apiVersion: "latest",
+
   region: "ca-central-1",
 });
 
@@ -43,6 +44,7 @@ exports.sendServerEmail = async function ({ subject, text }) {
   } catch (error) {
     console.log(error);
     logger.log("server-email-failure", "error", null, null, error);
+    res.status(500).json(error);
   }
 };
 exports.sendTaskEmail = async function ({ to, subject, text, attachments }) {
@@ -153,7 +155,7 @@ exports.sendEmail = async (req, res) => {
           error: err,
         });
 
-        res.json({ success: false, error: err });
+        res.status(500).json({ success: false, error: err });
       }
     }
   );

server/firebase/firebase-handler.js

@@ -1,13 +1,14 @@
 var admin = require("firebase-admin");
 const logger = require("../utils/logger");
 const path = require("path");
+const { auth } = require("firebase-admin");
 require("dotenv").config({
   path: path.resolve(
     process.cwd(),
     `.env.${process.env.NODE_ENV || "development"}`
   ),
 });
-
+const client = require("../graphql-client/graphql-client").client;
 var serviceAccount = require(process.env.FIREBASE_ADMINSDK_JSON);
 
 admin.initializeApp({
@@ -19,54 +20,61 @@ exports.admin = admin;
 
 const adminEmail = [
   "patrick@imex.dev",
-  "patrick@imex.text",
+  //"patrick@imex.test",
   "patrick@imex.prod",
   "patrick@imexsystems.ca",
   "patrick@thinkimex.com",
 ];
 
-exports.createUser = (req, res) => {
-  logger.log("admin-create-user", "WARN", req.user.email, null, {
+exports.createUser = async (req, res) => {
+  logger.log("admin-create-user", "ADMIN", req.user.email, null, {
     request: req.body,
+    ioadmin: true,
   });
-  if (!adminEmail.includes(req.user.email)) {
-    logger.log(
-      "admin-create-user-unauthorized",
-      "ERROR",
-      req.user.email,
-      null,
+
+  const { email, displayName, password, shopid, authlevel } = req.body;
+  try {
+    const userRecord = await admin
+      .auth()
+      .createUser({ email, displayName, password });
+
+    // See the UserRecord reference doc for the contents of userRecord.
+
+    const result = await client.request(
+      `
+        mutation INSERT_USER($user: users_insert_input!) {
+          insert_users_one(object: $user) {
+            email
+          }
+        }
+      `,
       {
-        request: req.body,
-        user: req.user,
+        user: {
+          email,
+          authid: userRecord.uid,
+          associations: {
+            data: [{ shopid, authlevel, active: true }],
+          },
+        },
       }
     );
-    res.sendStatus(404);
-  }
-  const { email, displayName, password } = req.body;
-  admin
-    .auth()
-    .createUser({ email, displayName, password })
-    .then((userRecord) => {
-      // See the UserRecord reference doc for the contents of userRecord.
 
-      logger.log("admin-update-user-success", "DEBUG", req.user.email, null, {
-        userRecord,
-      });
-      res.json(userRecord);
-    })
-    .catch((error) => {
-      logger.log("admin-update-user-error", "ERROR", req.user.email, null, {
-        error,
-      });
-      res.status(500).json(error);
+    res.json({ userRecord, result });
+  } catch (error) {
+    logger.log("admin-update-user-error", "ERROR", req.user.email, null, {
+      error,
     });
+    res.status(500).json(error);
+  }
 };
 
 exports.updateUser = (req, res) => {
-  logger.log("admin-update-user", "WARN", 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)) {
+
+  if (!adminEmail.includes(req.user.email) && !req.user.ioadmin) {
     logger.log(
       "admin-update-user-unauthorized",
       "ERROR",
@@ -78,6 +86,7 @@ exports.updateUser = (req, res) => {
       }
     );
     res.sendStatus(404);
+    return;
   }
 
   admin
@@ -98,8 +107,9 @@ exports.updateUser = (req, res) => {
     .then((userRecord) => {
       // See the UserRecord reference doc for the contents of userRecord.
 
-      logger.log("admin-update-user-success", "DEBUG", req.user.email, null, {
+      logger.log("admin-update-user-success", "ADMIN", req.user.email, null, {
         userRecord,
+        ioadmin: true,
       });
       res.json(userRecord);
     })
@@ -111,6 +121,41 @@ exports.updateUser = (req, res) => {
     });
 };
 
+exports.getUser = (req, res) => {
+  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,
+      }
+    );
+    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(() => {
     // Send a message to the device corresponding to the provided
@@ -221,3 +266,35 @@ exports.validateFirebaseIdToken = async (req, res, next) => {
     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";
+
+// admin
+//   .auth()
+//   .getUser(uid)
+//   .then((user) => {
+//     console.log(user);
+//     admin.auth().setCustomUserClaims(uid, {
+//       ioadmin: true,
+//       "https://hasura.io/jwt/claims": {
+//         "x-hasura-default-role": "admin",
+//         "x-hasura-allowed-roles": ["admin"],
+//         "x-hasura-user-id": uid,
+//       },
+//     });
+//   });

server/graphql-client/queries.js

@@ -611,6 +611,8 @@ exports.AUTOHOUSE_QUERY = `query AUTOHOUSE_EXPORT($start: timestamptz, $bodyshop
       autohouseid
       md_responsibility_centers
       jc_hourly_rates
+      cdk_dealerid
+      pbs_serialnumber
     timezone
   }
   jobs(where: {_and: [{converted: {_eq: true}}, {updated_at: {_gt: $start}}, {updated_at: {_lte: $end}}, {shopid: {_eq: $bodyshopid}}]}) {

server/utils/logger.js

@@ -5,7 +5,7 @@ const logger = new graylog2.graylog({
 });
 
 function log(message, type, user, record, object) {
-  if (type !== "ioevent")
+  if (type !== "ioevent" && type !== "DEBUG")
     console.log(message, {
       type,
       env: process.env.NODE_ENV || "development",
@@ -13,7 +13,7 @@ function log(message, type, user, record, object) {
       record,
       ...object,
     });
-  logger.log(message, {
+  logger.log(message, message, {
     type,
     env: process.env.NODE_ENV || "development",
     user,

setadmin.js

@@ -0,0 +1,23 @@
+var { admin } = require("./server/firebase/firebase-handler");
+
+const uidToMakeAdmin = "yTvpfkcNnGckLd1JnoXC7bTdvtu1";
+
+admin
+  .auth()
+  .getUser(uidToMakeAdmin)
+  .then((user) => {
+    admin
+      .auth()
+      .setCustomUserClaims(uidToMakeAdmin, {
+        ...user.customClaims,
+        "https://hasura.io/jwt/claims": {
+          "x-hasura-default-role": "admin",
+          "x-hasura-allowed-roles": ["admin"],
+          "x-hasura-user-id": uidToMakeAdmin,
+        },
+        ioadmin: true,
+      })
+      .then(() => console.log("Success."))
+      .catch((error) => console.log("Error updating claims.", error));
+  })
+  .catch((error) => console.log("Error fetching user.", error));