feature/IO-2979-DST - Finish DST Stuff

Signed-off-by: Dave Richer <dave@imexsystems.ca>
Merge remote-tracking branch 'origin/release/2024-11-01' into feature/IO-2979-DST
2024-10-28 14:04:14 -07:00 · 2024-10-28 13:10:08 -07:00 · 2024-10-28 13:06:47 -07:00 · 2024-10-28 12:24:40 -07:00 · 2024-10-28 12:03:48 -07:00 · 2024-10-28 11:55:13 -07:00
57 changed files with 1537 additions and 127 deletions
--- a/.platform/nginx/conf.d/proxy.conf
+++ b/.platform/nginx/conf.d/proxy.conf
@@ -1 +1,2 @@
-client_max_body_size 50M;
+client_max_body_size 50M;
+client_body_buffer_size 5M;
--- a/_reference/Documents/DeploymentChecklist.md
+++ b/_reference/Documents/DeploymentChecklist.md
--- a/_reference/Documents/JSReportSetup.md
+++ b/_reference/Documents/JSReportSetup.md
--- a/_reference/Documents/Jest
+++ b/_reference/Documents/Jest
--- a/_reference/Documents/New
+++ b/_reference/Documents/New
--- a/_reference/Documents/Responsibility
+++ b/_reference/Documents/Responsibility
--- a/_reference/Documents/SampleMetadata.md
+++ b/_reference/Documents/SampleMetadata.md
--- a/_reference/Documents/TeamsSlackInvestigationFinalVersion.md
+++ b/_reference/Documents/TeamsSlackInvestigationFinalVersion.md
--- a/_reference/Documents/dockerreadme.md
+++ b/_reference/Documents/dockerreadme.md
--- a/_reference/Documents/dropletSetup.md
+++ b/_reference/Documents/dropletSetup.md
--- a/_reference/Documents/firebase.md
+++ b/_reference/Documents/firebase.md
--- a/_reference/Documents/productionBoardNotes.md
+++ b/_reference/Documents/productionBoardNotes.md
--- a/_reference/Documents/reportFiltersAndSorters.md
+++ b/_reference/Documents/reportFiltersAndSorters.md
--- a/_reference/Documents/test
+++ b/_reference/Documents/test
--- a/_reference/JSON/BodyshopFeatures.json
+++ b/_reference/JSON/BodyshopFeatures.json
--- a/_reference/JSON/CiecaOpCodesReference.json
+++ b/_reference/JSON/CiecaOpCodesReference.json
--- a/_reference/JSON/Test_CDK_Acct
+++ b/_reference/JSON/Test_CDK_Acct
--- a/_reference/SQL/AuditTriggerFunctions.sql
+++ b/_reference/SQL/AuditTriggerFunctions.sql
--- a/_reference/localEmailViewer/.gitignore
+++ b/_reference/localEmailViewer/.gitignore
@@ -0,0 +1 @@
+node_modules
--- a/_reference/localEmailViewer/README.md
+++ b/_reference/localEmailViewer/README.md
@@ -0,0 +1,7 @@
+This will connect to your dockers local stack session and render the email in HTML.
+
+```shell
+node index.js
+```
+
+http://localhost:3334
--- a/_reference/localEmailViewer/index.js
+++ b/_reference/localEmailViewer/index.js
@@ -0,0 +1,116 @@
+// index.js
+
+import express from 'express';
+import fetch from 'node-fetch';
+import {simpleParser} from 'mailparser';
+
+const app = express();
+const PORT = 3334;
+
+app.get('/', async (req, res) => {
+    try {
+        const response = await fetch('http://localhost:4566/_aws/ses');
+        if (!response.ok) {
+            throw new Error('Network response was not ok');
+        }
+        const data = await response.json();
+        const messagesHtml = await parseMessages(data.messages);
+        res.send(renderHtml(messagesHtml));
+    } catch (error) {
+        console.error('Error fetching messages:', error);
+        res.status(500).send('Error fetching messages');
+    }
+});
+
+async function parseMessages(messages) {
+    const parsedMessages = await Promise.all(
+        messages.map(async (message, index) => {
+            try {
+                const parsed = await simpleParser(message.RawData);
+                return `
+                    <div class="shadow-md rounded-lg p-4 mb-6" style="background-color: lightgray">
+                     <div class="shadow-md rounded-lg p-4 mb-6" style="background-color: white">
+                        <div class="mb-2">
+                            <span class="font-bold text-lg">Message ${index + 1}</span>
+                        </div>
+                        <div class="mb-2">
+                            <span class="font-semibold">From:</span> ${message.Source}
+                        </div>
+                        <div class="mb-2">
+                            <span class="font-semibold">Region:</span> ${message.Region}
+                        </div>
+                        <div class="mb-2">
+                            <span class="font-semibold">Timestamp:</span> ${message.Timestamp}
+                        </div>
+                     </div>
+                        <div class="prose">
+                            ${parsed.html || parsed.textAsHtml || 'No HTML content available'}
+                        </div>
+                    </div>
+                `;
+            } catch (error) {
+                console.error('Error parsing email:', error);
+                return `
+                    <div class="bg-white shadow-md rounded-lg p-4 mb-6">
+                        <div class="mb-2">
+                            <span class="font-bold text-lg">Message ${index + 1}</span>
+                        </div>
+                        <div class="mb-2">
+                            <span class="font-semibold">From:</span> ${message.Source}
+                        </div>
+                        <div class="mb-2">
+                            <span class="font-semibold">Region:</span> ${message.Region}
+                        </div>
+                        <div class="mb-2">
+                            <span class="font-semibold">Timestamp:</span> ${message.Timestamp}
+                        </div>
+                        <div class="text-red-500">
+                            Error parsing email content
+                        </div>
+                    </div>
+                `;
+            }
+        })
+    );
+    return parsedMessages.join('');
+}
+
+function renderHtml(messagesHtml) {
+    return `
+        <!DOCTYPE html>
+        <html lang="en">
+        <head>
+            <meta charset="UTF-8">
+            <meta name="viewport" content="width=device-width, initial-scale=1.0">
+            <title>Email Messages Viewer</title>
+            <script src="https://cdn.tailwindcss.com"></script>
+            <style>
+                body {
+                    background-color: #f3f4f6;
+                    font-family: Arial, sans-serif;
+                }
+                .container {
+                    max-width: 800px;
+                    margin: 50px auto;
+                    padding: 20px;
+                }
+                .prose {
+                    line-height: 1.6;
+                }
+            </style>
+        </head>
+        <body>
+            <div class="container bg-white shadow-lg rounded-lg p-6">
+                <h1 class="text-2xl font-bold text-center mb-6">Email Messages Viewer</h1>
+                <div id="messages-container">
+                    ${messagesHtml}
+                </div>
+            </div>
+        </body>
+        </html>
+    `;
+}
+
+app.listen(PORT, () => {
+    console.log(`Server is running on http://localhost:${PORT}`);
+});
--- a/_reference/localEmailViewer/package-lock.json
+++ b/_reference/localEmailViewer/package-lock.json
--- a/_reference/localEmailViewer/package.json
+++ b/_reference/localEmailViewer/package.json
@@ -0,0 +1,18 @@
+{
+  "name": "localemailviewer",
+  "version": "1.0.0",
+  "main": "index.js",
+  "type": "module",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "description": "",
+  "dependencies": {
+    "express": "^4.21.1",
+    "mailparser": "^3.7.1",
+    "node-fetch": "^3.3.2"
+  }
+}
--- a/_reference/prHelper/index.html
+++ b/_reference/prHelper/index.html
--- a/client/src/App/App.container.jsx
+++ b/client/src/App/App.container.jsx
@@ -2,8 +2,6 @@ import { ApolloProvider } from "@apollo/client";
 import { SplitFactoryProvider, SplitSdk } from "@splitsoftware/splitio-react";
 import { ConfigProvider } from "antd";
 import enLocale from "antd/es/locale/en_US";
-import dayjs from "../utils/day";
-import "dayjs/locale/en";
 import React from "react";
 import { useTranslation } from "react-i18next";
 import GlobalLoadingBar from "../components/global-loading-bar/global-loading-bar.component";
@@ -19,8 +17,6 @@ if (import.meta.env.DEV) {
  Userpilot.initialize("NX-69145f08");
 }

-dayjs.locale("en");
-
 const config = {
  core: {
    authorizationKey: import.meta.env.VITE_APP_SPLIT_API,
--- a/client/src/components/dms-log-events/dms-log-events.component.jsx
+++ b/client/src/components/dms-log-events/dms-log-events.component.jsx
@@ -40,8 +40,6 @@ export function DmsLogEvents({ socket, logs, bodyshop }) {

 function LogLevelHierarchy(level) {
  switch (level) {
-    case "TRACE":
-      return "pink";
    case "DEBUG":
      return "orange";
    case "INFO":
--- a/client/src/components/eula/eula.component.jsx
+++ b/client/src/components/eula/eula.component.jsx
@@ -8,7 +8,7 @@ import { INSERT_EULA_ACCEPTANCE } from "../../graphql/user.queries";
 import { useMutation } from "@apollo/client";
 import { acceptEula } from "../../redux/user/user.actions";
 import { useTranslation } from "react-i18next";
-import day from "../../utils/day";
+import dayjs from "../../utils/day";

 import "./eula.styles.scss";
 import DateTimePicker from "../form-date-time-picker/form-date-time-picker.component.jsx";
@@ -208,7 +208,7 @@ const EulaFormComponent = ({ form, handleChange, onFinish, t }) => (
              {
                required: true,
                validator: (_, value) => {
-                  if (day(value).isSame(day(), "day")) {
+                  if (dayjs(value).isSame(dayjs(), "day")) {
                    return Promise.resolve();
                  }
                  return Promise.reject(new Error(t("eula.messages.date_accepted")));
--- a/client/src/components/form-date-time-picker/form-date-time-picker.component.jsx
+++ b/client/src/components/form-date-time-picker/form-date-time-picker.component.jsx
@@ -4,19 +4,37 @@ import React, { useCallback, useState } from "react";
 import { useTranslation } from "react-i18next";
 import dayjs from "../../utils/day";
 import { fuzzyMatchDate } from "./formats.js";
+import { createStructuredSelector } from "reselect";
+import { selectBodyshop } from "../../redux/user/user.selectors.js";
+import { connect } from "react-redux";

-const DateTimePicker = ({ value, onChange, onBlur, id, onlyFuture, onlyToday, isDateOnly = false, ...restProps }) => {
+const mapStateToProps = createStructuredSelector({
+  bodyshop: selectBodyshop
+});
+
+const DateTimePicker = ({
+  value,
+  onChange,
+  onBlur,
+  id,
+  onlyFuture,
+  onlyToday,
+  isDateOnly = false,
+  bodyshop,
+  ...restProps
+}) => {
  const [isManualInput, setIsManualInput] = useState(false);
  const { t } = useTranslation();

  const handleChange = useCallback(
    (newDate) => {
+      if (!newDate) return;
      if (onChange) {
-        onChange(newDate || null);
+        onChange(bodyshop?.timezone ? dayjs(newDate).tz(bodyshop.timezone, true) : newDate);
      }
      setIsManualInput(false);
    },
-    [onChange]
+    [onChange, bodyshop?.timezone]
  );

  const handleBlur = useCallback(
@@ -102,4 +120,4 @@ DateTimePicker.propTypes = {
  isDateOnly: PropTypes.bool
 };

-export default React.memo(DateTimePicker);
+export default connect(mapStateToProps, null)(DateTimePicker);
--- a/client/src/components/job-at-change/schedule-event.component.jsx
+++ b/client/src/components/job-at-change/schedule-event.component.jsx
@@ -23,6 +23,7 @@ import ScheduleEventColor from "./schedule-event.color.component";
 import ScheduleEventNote from "./schedule-event.note.component";
 import { useMutation } from "@apollo/client";
 import { UPDATE_APPOINTMENT } from "../../graphql/appointments.queries";
+import ProductionListColumnComment from "../production-list-columns/production-list-columns.comment.component";

 const mapStateToProps = createStructuredSelector({
  bodyshop: selectBodyshop
@@ -127,6 +128,9 @@ export function ScheduleEventComponent({
            {(event.job && event.job.alt_transport) || ""}
            <ScheduleAtChange job={event && event.job} />
          </DataLabel>
+          <DataLabel label={t("jobs.fields.comment")} valueStyle={{ overflow: "hidden", textOverflow: "ellipsis" }}>
+            <ProductionListColumnComment record={event && event.job} />
+          </DataLabel>
          <ScheduleEventNote event={event} />
        </div>
      ) : (
@@ -316,6 +320,7 @@ export function ScheduleEventComponent({
      })`}

      {event.job && event.job.alt_transport && <div style={{ margin: ".1rem" }}>{event.job.alt_transport}</div>}
+      {event?.job?.comment && `C: ${event.job.comment}`}
    </Space>
  ) : (
    <div
--- a/client/src/components/job-lifecycle/job-lifecycle.component.jsx
+++ b/client/src/components/job-lifecycle/job-lifecycle.component.jsx
@@ -1,5 +1,5 @@
 import React, { useCallback, useEffect, useState } from "react";
-import day from "../../utils/day";
+import dayjs from "../../utils/day";
 import axios from "axios";
 import { Badge, Card, Space, Table, Tag } from "antd";
 import { gql, useQuery } from "@apollo/client";
@@ -72,7 +72,7 @@ export function JobLifecycleComponent({ job, statuses, ...rest }) {
      dataIndex: "start",
      key: "start",
      render: (text) => DateTimeFormatterFunction(text),
-      sorter: (a, b) => day(a.start).unix() - day(b.start).unix()
+      sorter: (a, b) => dayjs(a.start).unix() - dayjs(b.start).unix()
    },
    {
      title: t("job_lifecycle.columns.relative_start"),
@@ -90,7 +90,7 @@ export function JobLifecycleComponent({ job, statuses, ...rest }) {
          }
          return isEmpty(a.end) ? 1 : -1;
        }
-        return day(a.end).unix() - day(b.end).unix();
+        return dayjs(a.end).unix() - dayjs(b.end).unix();
      },
      render: (text) => (isEmpty(text) ? t("job_lifecycle.content.not_available") : DateTimeFormatterFunction(text))
    },
--- a/client/src/components/job-line-dispatch-button/job-line-dispatch-button.component.jsx
+++ b/client/src/components/job-line-dispatch-button/job-line-dispatch-button.component.jsx
@@ -2,7 +2,7 @@ import React, { useState } from "react";

 import { useMutation } from "@apollo/client";
 import { Button, Form, notification, Popover, Select, Space } from "antd";
-import day from "../../utils/day";
+import dayjs from "../../utils/day";
 import { useTranslation } from "react-i18next";
 import { connect } from "react-redux";
 import { createStructuredSelector } from "reselect";
@@ -48,7 +48,7 @@ export function JobLineDispatchButton({
      const result = await dispatchLines({
        variables: {
          partsDispatch: {
-            dispatched_at: day(),
+            dispatched_at: dayjs(),
            employeeid: values.employeeid,
            jobid: job.id,
            dispatched_by: currentUser.email,
@@ -138,7 +138,11 @@ export function JobLineDispatchButton({

  return (
    <Popover open={visible} content={popMenu}>
-      <Button disabled={selectedLines.length === 0 || jobRO || disabled} loading={loading} onClick={() => setVisible(true)}>
+      <Button
+        disabled={selectedLines.length === 0 || jobRO || disabled}
+        loading={loading}
+        onClick={() => setVisible(true)}
+      >
        {t("joblines.actions.dispatchparts", { count: selectedLines.length })}
      </Button>
    </Popover>
--- a/client/src/components/parts-dispatch-expander/parts-dispatch-expander.component.jsx
+++ b/client/src/components/parts-dispatch-expander/parts-dispatch-expander.component.jsx
@@ -1,6 +1,6 @@
 import { useMutation } from "@apollo/client";
 import { Button, Card, Col, notification, Row, Table } from "antd";
-import day from "../../utils/day";
+import dayjs from "../../utils/day";
 import React from "react";
 import { useTranslation } from "react-i18next";
 import { UPDATE_PARTS_DISPATCH_LINE } from "../../graphql/parts-dispatch.queries";
@@ -11,7 +11,7 @@ export default function PartsDispatchExpander({ dispatch, job }) {
  const [updateDispatchLine] = useMutation(UPDATE_PARTS_DISPATCH_LINE);

  const handleAccept = async ({ partsDispatchLineId }) => {
-    const accepted_at = day();
+    const accepted_at = dayjs();
    const result = await updateDispatchLine({
      variables: { id: partsDispatchLineId, line: { accepted_at } },
      optimisticResponse: {
--- a/client/src/components/schedule-calendar-wrapper/localizer.js
+++ b/client/src/components/schedule-calendar-wrapper/localizer.js
@@ -120,14 +120,6 @@ var formats = {
 };

 const localizer = (dayjsLib) => {
-  // load dayjs plugins
-  dayjsLib.extend(isBetween);
-  dayjsLib.extend(isSameOrAfter);
-  dayjsLib.extend(isSameOrBefore);
-  dayjsLib.extend(localeData);
-  dayjsLib.extend(localizedFormat);
-  dayjsLib.extend(minMax);
-  dayjsLib.extend(utc);
  var locale = function locale(dj, c) {
    return c ? dj.locale(c) : dj;
  };
@@ -136,7 +128,8 @@ const localizer = (dayjsLib) => {
  // then use the timezone aware version

  //TODO This was the issue entirely...
-  //  var dayjs = dayjsLib.tz ? dayjsLib.tz : dayjsLib;
+  // var dayjs = dayjsLib.tz ? dayjsLib.tz : dayjsLib;
+
  var dayjs = dayjsLib;

  function getTimezoneOffset(date) {
--- a/client/src/components/schedule-calendar-wrapper/scheduler-calendar-wrapper.component.jsx
+++ b/client/src/components/schedule-calendar-wrapper/scheduler-calendar-wrapper.component.jsx
@@ -20,6 +20,7 @@ const mapStateToProps = createStructuredSelector({
  bodyshop: selectBodyshop,
  problemJobs: selectProblemJobs
 });
+
 const localizer = local(dayjs);

 export function ScheduleCalendarWrapperComponent({
--- a/client/src/components/task-list/task-list.component.jsx
+++ b/client/src/components/task-list/task-list.component.jsx
@@ -1,10 +1,3 @@
-import { Button, Card, Space, Switch, Table } from "antd";
-import queryString from "query-string";
-import React, { useCallback, useEffect } from "react";
-import { useTranslation } from "react-i18next";
-import { Link, useLocation, useNavigate } from "react-router-dom";
-import { pageLimit } from "../../utils/config";
-import dayjs from "../../utils/day";
 import {
  CheckCircleFilled,
  CheckCircleOutlined,
@@ -15,9 +8,16 @@ import {
  PlusCircleFilled,
  SyncOutlined
 } from "@ant-design/icons";
-import { DateFormatter, DateTimeFormatter } from "../../utils/DateFormatter.jsx";
+import { Button, Card, Space, Switch, Table } from "antd";
+import queryString from "query-string";
+import React, { useCallback, useEffect } from "react";
+import { useTranslation } from "react-i18next";
 import { connect } from "react-redux";
+import { Link, useLocation, useNavigate } from "react-router-dom";
 import { setModalContext } from "../../redux/modals/modals.actions";
+import { pageLimit } from "../../utils/config";
+import { DateFormatter, DateTimeFormatter } from "../../utils/DateFormatter.jsx";
+import dayjs from "../../utils/day";

 /**
 * Task List Component
@@ -140,6 +140,17 @@ function TaskListComponent({
    render: (text, record) => <DateTimeFormatter>{record.created_at}</DateTimeFormatter>
  });

+  columns.push({
+    title: t("tasks.fields.created_by"),
+    dataIndex: "created_by",
+    key: "created_by",
+    width: "10%",
+    defaultSortOrder: "descend",
+    sorter: true,
+    sortOrder: sortcolumn === "created_by" && sortorder,
+    render: (text, record) => record.created_by
+  });
+
  if (!onlyMine) {
    columns.push({
      title: t("tasks.fields.assigned_to"),
--- a/client/src/components/time-tickets-commit-toggle/time-tickets-commit-toggle.component.jsx
+++ b/client/src/components/time-tickets-commit-toggle/time-tickets-commit-toggle.component.jsx
@@ -1,6 +1,6 @@
 import { useMutation } from "@apollo/client";
 import { Button, notification } from "antd";
-import day from "../../utils/day";
+import dayjs from "../../utils/day";
 import React, { useState } from "react";
 import { useTranslation } from "react-i18next";
 import { connect } from "react-redux";
@@ -29,7 +29,7 @@ export function TimeTicketsCommit({ bodyshop, currentUser, timeticket, disabled,
        ? { commited_by: null, committed_at: null }
        : {
            commited_by: currentUser.email,
-            committed_at: day()
+            committed_at: dayjs()
          };

      const result = await updateTimeTicket({
--- a/client/src/components/time-tickets-commit/time-tickets-commit.component.jsx
+++ b/client/src/components/time-tickets-commit/time-tickets-commit.component.jsx
@@ -1,6 +1,6 @@
 import { useMutation } from "@apollo/client";
 import { Button, notification } from "antd";
-import day from "../../utils/day";
+import dayjs from "../../utils/day";
 import React, { useState } from "react";
 import { useTranslation } from "react-i18next";
 import { connect } from "react-redux";
@@ -34,7 +34,7 @@ export function TimeTicketsCommit({
          timeticketIds: timetickets.map((ticket) => ticket.id),
          timeticket: {
            commited_by: currentUser.email,
-            committed_at: day()
+            committed_at: dayjs()
          }
        },
        update(cache) {
@@ -47,7 +47,7 @@ export function TimeTicketsCommit({
                    return {
                      ...ticket,
                      commited_by: currentUser.email,
-                      committed_at: day()
+                      committed_at: dayjs()
                    };
                  }
                  return ticket;
--- a/client/src/components/tt-approve-button/tt-approve-button.component.jsx
+++ b/client/src/components/tt-approve-button/tt-approve-button.component.jsx
@@ -1,7 +1,7 @@
 import { useApolloClient } from "@apollo/client";
 import { Button, notification } from "antd";
 import _ from "lodash";
-import day from "../../utils/day";
+import dayjs from "../../utils/day";
 import React, { useState } from "react";
 import { useTranslation } from "react-i18next";
 import { connect } from "react-redux";
@@ -49,7 +49,7 @@ export function TtApproveButton({
          })),
          approvalIds: selectedTickets,
          approvalUpdate: {
-            approved_at: day(),
+            approved_at: dayjs(),
            approved_by: currentUser.email
          }
        }
--- a/client/src/graphql/appointments.queries.js
+++ b/client/src/graphql/appointments.queries.js
@@ -48,6 +48,7 @@ export const QUERY_ALL_ACTIVE_APPOINTMENTS = gql`
        v_model_desc
        est_ct_fn
        est_ct_ln
+        comment
        labhrs: joblines_aggregate(where: { mod_lbr_ty: { _neq: "LAR" }, removed: { _eq: false } }) {
          aggregate {
            sum {
--- a/client/src/pages/dms-payables/dms-payables.container.jsx
+++ b/client/src/pages/dms-payables/dms-payables.container.jsx
@@ -123,7 +123,6 @@ export function DmsContainer({ bodyshop, setBreadcrumbs, setSelectedHeader }) {
                    socket.emit("set-log-level", value);
                  }}
                >
-                  <Select.Option key="TRACE">TRACE</Select.Option>
                  <Select.Option key="DEBUG">DEBUG</Select.Option>
                  <Select.Option key="INFO">INFO</Select.Option>
                  <Select.Option key="WARNING">WARNING</Select.Option>
--- a/client/src/pages/dms/dms.container.jsx
+++ b/client/src/pages/dms/dms.container.jsx
@@ -173,7 +173,6 @@ export function DmsContainer({ bodyshop, setBreadcrumbs, setSelectedHeader, inse
                      socket.emit("set-log-level", value);
                    }}
                  >
-                    <Select.Option key="TRACE">TRACE</Select.Option>
                    <Select.Option key="DEBUG">DEBUG</Select.Option>
                    <Select.Option key="INFO">INFO</Select.Option>
                    <Select.Option key="WARNING">WARNING</Select.Option>
--- a/client/src/redux/user/user.sagas.js
+++ b/client/src/redux/user/user.sagas.js
@@ -28,7 +28,7 @@ import {
 } from "../../firebase/firebase.utils";
 import { QUERY_EULA } from "../../graphql/bodyshop.queries";
 import client from "../../utils/GraphQLClient";
-import day from "../../utils/day";
+import dayjs from "../../utils/day";
 import InstanceRenderManager from "../../utils/instanceRenderMgr";
 import {
  checkInstanceId,
@@ -96,7 +96,7 @@ export function* isUserAuthenticated() {
    const eulaQuery = yield client.query({
      query: QUERY_EULA,
      variables: {
-        now: day()
+        now: dayjs()
      }
    });

@@ -314,8 +314,7 @@ export function* SetAuthLevelFromShopDetails({ payload }) {
  try {
    const userEmail = yield select((state) => state.user.currentUser.email);
    try {
-      console.log("Setting shop timezone.");
-      day.tz.setDefault(payload.timezone);
+      dayjs.tz.setDefault(payload.timezone);
    } catch (error) {
      console.log(error);
    }
--- a/client/src/translations/en_us/common.json
+++ b/client/src/translations/en_us/common.json
@@ -3187,6 +3187,7 @@
        "billid": "Bill",
        "completed": "Completed",
        "created_at": "Created At",
+        "created_by": "Created By",
        "description": "Description",
        "due_date": "Due Date",
        "job": {
--- a/client/src/translations/es/common.json
+++ b/client/src/translations/es/common.json
@@ -3187,6 +3187,7 @@
        "billid": "",
        "completed": "",
        "created_at": "",
+        "created_by": "",
        "description": "",
        "due_date": "",
        "job": {
--- a/client/src/translations/fr/common.json
+++ b/client/src/translations/fr/common.json
@@ -3187,6 +3187,7 @@
        "billid": "",
        "completed": "",
        "created_at": "",
+        "created_by": "",
        "description": "",
        "due_date": "",
        "job": {
--- a/client/src/utils/day.js
+++ b/client/src/utils/day.js
@@ -1,5 +1,6 @@
 import dayjs from "dayjs";

+import "dayjs/locale/en";
 import dayjsBusinessDays from "dayjs-business-days2";
 import isSameOrAfter from "dayjs/plugin/isSameOrAfter";
 import updateLocale from "dayjs/plugin/updateLocale";
@@ -64,4 +65,6 @@ dayjs.extend(minMax);
 dayjs.extend(isBetween);
 dayjs.extend(dayjsBusinessDays);

+dayjs.locale("en");
+
 export default dayjs;
--- a/server.js
+++ b/server.js
@@ -153,18 +153,13 @@ const connectToRedisCluster = async () => {
  } else {
    // Use the Dockerized Redis cluster in development
    if (isEmpty(process.env?.REDIS_URL) || !isString(process.env?.REDIS_URL)) {
-      logger.log(`[${process.env.NODE_ENV}] No or Malformed REDIS_URL present.`, "ERROR", "redis", "api");
+      logger.log(`No or Malformed REDIS_URL present.`, "ERROR", "redis", "api");
      process.exit(1);
    }
    try {
      redisServers = JSON.parse(process.env.REDIS_URL);
    } catch (error) {
-      logger.log(
-        `[${process.env.NODE_ENV}] Failed to parse REDIS_URL: ${error.message}. Exiting...`,
-        "ERROR",
-        "redis",
-        "api"
-      );
+      logger.log(`Failed to parse REDIS_URL: ${error.message}. Exiting...`, "ERROR", "redis", "api");
      process.exit(1);
    }
  }
@@ -172,12 +167,7 @@ const connectToRedisCluster = async () => {
  const clusterRetryStrategy = (times) => {
    const delay =
      Math.min(CLUSTER_RETRY_BASE_DELAY + times * 50, CLUSTER_RETRY_MAX_DELAY) + Math.random() * CLUSTER_RETRY_JITTER;
-    logger.log(
-      `[${process.env.NODE_ENV}] Redis cluster not yet ready. Retrying in ${delay.toFixed(2)}ms`,
-      "WARN",
-      "redis",
-      "api"
-    );
+    logger.log(`Redis cluster not yet ready. Retrying in ${delay.toFixed(2)}ms`, "WARN", "redis", "api");
    return delay;
  };

@@ -194,12 +184,12 @@ const connectToRedisCluster = async () => {

  return new Promise((resolve, reject) => {
    redisCluster.on("ready", () => {
-      logger.log(`[${process.env.NODE_ENV}] Redis cluster connection established.`, "INFO", "redis", "api");
+      logger.log(`Redis cluster connection established.`, "INFO", "redis", "api");
      resolve(redisCluster);
    });

    redisCluster.on("error", (err) => {
-      logger.log(`[${process.env.NODE_ENV}] Redis cluster connection failed: ${err.message}`, "ERROR", "redis", "api");
+      logger.log(`Redis cluster connection failed: ${err.message}`, "ERROR", "redis", "api");
      reject(err);
    });
  });
@@ -215,7 +205,7 @@ const applySocketIO = async ({ server, app }) => {

  // Handle errors
  redisCluster.on("error", (err) => {
-    logger.log(`[${process.env.NODE_ENV}] Redis ERROR`, "ERROR", "redis", "api");
+    logger.log(`Redis ERROR`, "ERROR", "redis", "api");
  });

  const pubClient = redisCluster;
@@ -249,7 +239,7 @@ const applySocketIO = async ({ server, app }) => {
  });

  if (isString(process.env.REDIS_ADMIN_PASS) && !isEmpty(process.env.REDIS_ADMIN_PASS)) {
-    logger.log(`[${process.env.NODE_ENV}] Initializing Redis Admin UI....`, "INFO", "redis", "api");
+    logger.log(`Initializing Redis Admin UI....`, "INFO", "redis", "api");
    instrument(ioRedis, {
      auth: {
        type: "basic",
@@ -312,9 +302,9 @@ const main = async () => {

  try {
    await server.listen(port);
-    logger.log(`[${process.env.NODE_ENV}] Server started on port ${port}`, "INFO", "api");
+    logger.log(`Server started on port ${port}`, "INFO", "api");
  } catch (error) {
-    logger.log(`[${process.env.NODE_ENV}] Server failed to start on port ${port}`, "ERROR", "api", error);
+    logger.log(`Server failed to start on port ${port}`, "ERROR", "api", error);
  }
 };

--- a/server/accounting/pbs/pbs-ap-allocations.js
+++ b/server/accounting/pbs/pbs-ap-allocations.js
@@ -26,7 +26,7 @@ axios.interceptors.request.use((x) => {
  } | ${JSON.stringify(x.data)} | ${JSON.stringify(headers)}`;
  //console.log(printable);

-  CdkBase.createJsonEvent(socket, "TRACE", `Raw Request: ${printable}`, x.data);
+  CdkBase.createJsonEvent(socket, "SILLY", `Raw Request: ${printable}`, x.data);

  return x;
 });
@@ -36,7 +36,7 @@ axios.interceptors.response.use((x) => {

  const printable = `${new Date()} | Response: ${x.status} | ${JSON.stringify(x.data)}`;
  //console.log(printable);
-  CdkBase.createJsonEvent(socket, "TRACE", `Raw Response: ${printable}`, x.data);
+  CdkBase.createJsonEvent(socket, "SILLY", `Raw Response: ${printable}`, x.data);

  return x;
 });
@@ -181,7 +181,7 @@ async function QueryBillData(socket, billids) {
  const result = await client
    .setHeaders({ Authorization: `Bearer ${socket.handshake.auth.token}` })
    .request(queries.GET_PBS_AP_ALLOCATIONS, { billids: billids });
-  CdkBase.createLogEvent(socket, "TRACE", `Bill data query result ${JSON.stringify(result, null, 2)}`);
+  CdkBase.createLogEvent(socket, "SILLY", `Bill data query result ${JSON.stringify(result, null, 2)}`);

  return result;
 }
--- a/server/accounting/pbs/pbs-job-export.js
+++ b/server/accounting/pbs/pbs-job-export.js
@@ -28,7 +28,7 @@ axios.interceptors.request.use((x) => {
  } | ${JSON.stringify(x.data)} | ${JSON.stringify(headers)}`;
  //console.log(printable);

-  CdkBase.createJsonEvent(socket, "TRACE", `Raw Request: ${printable}`, x.data);
+  CdkBase.createJsonEvent(socket, "SILLY", `Raw Request: ${printable}`, x.data);

  return x;
 });
@@ -38,7 +38,7 @@ axios.interceptors.response.use((x) => {

  const printable = `${new Date()} | Response: ${x.status} | ${JSON.stringify(x.data)}`;
  //console.log(printable);
-  CdkBase.createJsonEvent(socket, "TRACE", `Raw Response: ${printable}`, x.data);
+  CdkBase.createJsonEvent(socket, "SILLY", `Raw Response: ${printable}`, x.data);

  return x;
 });
@@ -118,7 +118,7 @@ async function CheckForErrors(socket, response) {
    CdkBase.createLogEvent(socket, "DEBUG", `Successful response from DMS. ${response.Message || ""}`);
  } else {
    CdkBase.createLogEvent(socket, "ERROR", `Error received from DMS: ${response.Message}`);
-    CdkBase.createLogEvent(socket, "TRACE", `Error received from DMS: ${JSON.stringify(response)}`);
+    CdkBase.createLogEvent(socket, "SILLY", `Error received from DMS: ${JSON.stringify(response)}`);
  }
 }

@@ -130,7 +130,7 @@ async function QueryJobData(socket, jobid) {
  const result = await client
    .setHeaders({ Authorization: `Bearer ${socket.handshake.auth.token}` })
    .request(queries.QUERY_JOBS_FOR_PBS_EXPORT, { id: jobid });
-  CdkBase.createLogEvent(socket, "TRACE", `Job data query result ${JSON.stringify(result, null, 2)}`);
+  CdkBase.createLogEvent(socket, "SILLY", `Job data query result ${JSON.stringify(result, null, 2)}`);
  return result.jobs_by_pk;
 }

--- a/server/cdk/cdk-calculate-allocations.js
+++ b/server/cdk/cdk-calculate-allocations.js
@@ -42,7 +42,7 @@ async function QueryJobData(connectionData, token, jobid) {
  CdkBase.createLogEvent(connectionData, "DEBUG", `Querying job data for id ${jobid}`);
  const client = new GraphQLClient(process.env.GRAPHQL_ENDPOINT, {});
  const result = await client.setHeaders({ Authorization: token }).request(queries.GET_CDK_ALLOCATIONS, { id: jobid });
-  CdkBase.createLogEvent(connectionData, "TRACE", `Job data query result ${JSON.stringify(result, null, 2)}`);
+  CdkBase.createLogEvent(connectionData, "SILLY", `Job data query result ${JSON.stringify(result, null, 2)}`);
  return result.jobs_by_pk;
 }

@@ -373,13 +373,19 @@ function calculateAllocations(connectionData, job) {
    });
    //profile level adjustments for labor and materials
    Object.keys(job.job_totals.rates).forEach((key) => {
-      if (job.job_totals.rates[key] && job.job_totals.rates[key].adjustment && Dinero(job.job_totals.rates[key].adjustment).isZero() === false) {
+      if (
+        job.job_totals.rates[key] &&
+        job.job_totals.rates[key].adjustment &&
+        Dinero(job.job_totals.rates[key].adjustment).isZero() === false
+      ) {
        const accountName = selectedDmsAllocationConfig.profits[key.toUpperCase()];
        const otherAccount = bodyshop.md_responsibility_centers.profits.find((c) => c.name === accountName);
        if (otherAccount) {
          if (!profitCenterHash[accountName]) profitCenterHash[accountName] = Dinero();

-          profitCenterHash[accountName] = profitCenterHash[accountName].add(Dinero(job.job_totals.rates[key].adjustments));
+          profitCenterHash[accountName] = profitCenterHash[accountName].add(
+            Dinero(job.job_totals.rates[key].adjustments)
+          );
        } else {
          CdkBase.createLogEvent(
            connectionData,
--- a/server/cdk/cdk-job-export.js
+++ b/server/cdk/cdk-job-export.js
@@ -151,7 +151,7 @@ async function QueryJobData(socket, jobid) {
  const result = await client
    .setHeaders({ Authorization: `Bearer ${socket.handshake.auth.token}` })
    .request(queries.QUERY_JOBS_FOR_CDK_EXPORT, { id: jobid });
-  CdkBase.createLogEvent(socket, "TRACE", `Job data query result ${JSON.stringify(result, null, 2)}`);
+  CdkBase.createLogEvent(socket, "SILLY", `Job data query result ${JSON.stringify(result, null, 2)}`);
  return result.jobs_by_pk;
 }

@@ -171,7 +171,7 @@ async function CalculateDmsVid(socket, JobData) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientVehicleInsertUpdate.getVehIdsAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CheckCdkResponseForError(socket, soapResponseVehicleInsertUpdate);
@@ -214,7 +214,7 @@ async function QueryDmsVehicleById(socket, JobData, DMSVid) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientVehicleInsertUpdate.readAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientVehicleInsertUpdate.readAsync response.`);
@@ -246,7 +246,7 @@ async function QueryDmsCustomerById(socket, JobData, CustomerId) {
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientCustomerInsertUpdate.readAsync response.`);
    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientCustomerInsertUpdate.readAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CheckCdkResponseForError(socket, soapResponseCustomerInsertUpdate);
@@ -295,7 +295,7 @@ async function QueryDmsCustomerByName(socket, JobData) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientCustomerSearch.executeSearchBulkAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CheckCdkResponseForError(socket, soapResponseCustomerSearch);
@@ -337,7 +337,7 @@ async function GenerateDmsCustomerNumber(socket) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientCustomerInsertUpdate.getCustomerNumberAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CheckCdkResponseForError(socket, soapResponseCustomerInsertUpdate);
@@ -425,7 +425,7 @@ async function InsertDmsCustomer(socket, newCustomerNumber) {
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientCustomerInsertUpdate.insertAsync response.`);
    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientCustomerInsertUpdate.insertAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CheckCdkResponseForError(socket, soapResponseCustomerInsertUpdate);
@@ -505,7 +505,7 @@ async function InsertDmsVehicle(socket) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientVehicleInsertUpdate.insertAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientVehicleInsertUpdate.insertAsync response.`);
@@ -611,7 +611,7 @@ async function UpdateDmsVehicle(socket) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "DEBUG",
      `soapClientVehicleInsertUpdate.updateAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientVehicleInsertUpdate.updateAsync response.`);
@@ -650,7 +650,7 @@ async function InsertServiceVehicleHistory(socket) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientServiceHistoryInsert.serviceHistoryHeaderInsert Result ${JSON.stringify(result, null, 2)}`
    );
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientServiceHistoryInsert.serviceHistoryHeaderInsert response.`);
@@ -690,7 +690,7 @@ async function InsertDmsStartWip(socket) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientAccountingGLInsertUpdate.doStartWIPAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientAccountingGLInsertUpdate.doStartWIPAsync response.`);
@@ -721,7 +721,7 @@ async function InsertDmsBatchWip(socket) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientAccountingGLInsertUpdate.doTransBatchWIPAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientAccountingGLInsertUpdate.doTransBatchWIPAsync response.`);
@@ -885,7 +885,7 @@ async function PostDmsBatchWip(socket) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientAccountingGLInsertUpdate.doPostBatchWIPAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientAccountingGLInsertUpdate.doPostBatchWIPAsync response.`);
@@ -914,7 +914,7 @@ async function QueryDmsErrWip(socket) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "DEBUG",
      `soapClientAccountingGLInsertUpdate.doErrWIPAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientAccountingGLInsertUpdate.doErrWIPAsync response.`);
@@ -945,7 +945,7 @@ async function DeleteDmsWip(socket) {

    CdkBase.createLogEvent(
      socket,
-      "TRACE",
+      "SILLY",
      `soapClientAccountingGLInsertUpdate.doPostBatchWIPAsync Result ${JSON.stringify(result, null, 2)}`
    );
    CdkBase.createXmlEvent(socket, rawResponse, `soapClientAccountingGLInsertUpdate.doPostBatchWIPAsync response.`);
--- a/server/email/tasksEmails.js
+++ b/server/email/tasksEmails.js
@@ -77,6 +77,7 @@ const formatPriority = (priority) => {
 * @param priority
 * @param description
 * @param dueDate
+ * @param createdBy
 * @param bodyshop
 * @param job
 * @param taskId
@@ -96,11 +97,11 @@ const getEndpoints = (bodyshop) =>
          : "https://romeonline.io"
  });

-const generateTemplateArgs = (title, priority, description, dueDate, bodyshop, job, taskId, dateLine) => {
+const generateTemplateArgs = (title, priority, description, dueDate, bodyshop, job, taskId, dateLine, createdBy) => {
  const endPoints = getEndpoints(bodyshop);
  return {
    header: title,
-    subHeader: `Body Shop: ${bodyshop.shopname} | Priority: ${formatPriority(priority)} ${formatDate(dueDate)}`,
+    subHeader: `Body Shop: ${bodyshop.shopname} | Priority: ${formatPriority(priority)} ${formatDate(dueDate)} | Created By: ${createdBy || "N/A"}`,
    body: `Reference: ${job.ro_number || "N/A"} | ${job.ownr_co_nm ? job.ownr_co_nm : `${job.ownr_fn || ""} ${job.ownr_ln || ""}`.trim()} | ${`${job.v_model_yr || ""} ${job.v_make_desc || ""} ${job.v_model_desc || ""}`.trim()}<br>${description ? description.concat("<br>") : ""}<a href="${endPoints}/manage/tasks/alltasks?taskid=${taskId}">View this task.</a>`,
    dateLine
  };
@@ -181,7 +182,8 @@ const taskAssignedEmail = async (req, res) => {
        tasks_by_pk.bodyshop,
        tasks_by_pk.job,
        newTask.id,
-        dateLine
+        dateLine,
+        newTask.created_by
      )
    ),
    null,
@@ -268,7 +270,8 @@ const tasksRemindEmail = async (req, res) => {
            onlyTask.bodyshop,
            onlyTask.job,
            onlyTask.id,
-            dateLine
+            dateLine,
+            onlyTask.created_by
          )
        );
      }
--- a/server/graphql-client/queries.js
+++ b/server/graphql-client/queries.js
@@ -2506,6 +2506,7 @@ exports.QUERY_TASK_BY_ID = `
 query QUERY_TASK_BY_ID($id: uuid!) {
  tasks_by_pk(id: $id) {
    id
+    created_by
    assigned_to_employee{
      id
      user_email
--- a/server/ioevent/ioevent.js
+++ b/server/ioevent/ioevent.js
@@ -35,7 +35,7 @@ exports.default = async (req, res) => {

    res.sendStatus(200);
  } catch (error) {
-    logger.log("ioevent-error", "trace", user, null, {
+    logger.log("ioevent-error", "silly", user, null, {
      operationname: operationName,
      time,
      dbevent,
--- a/server/utils/logger.js
+++ b/server/utils/logger.js
@@ -8,6 +8,7 @@ const InstanceManager = require("../utils/instanceMgr").default;
 const winston = require("winston");
 const WinstonCloudWatch = require("winston-cloudwatch");
 const { isString, isEmpty } = require("lodash");
+const { networkInterfaces } = require("node:os");

 const createLogger = () => {
  try {
@@ -42,6 +43,19 @@ const createLogger = () => {
      })();
    };

+    const getPrivateIP = () => {
+      const interfaces = networkInterfaces();
+      for (const name of Object.keys(interfaces)) {
+        for (const iface of interfaces[name]) {
+          // Find an IPv4 address that's not internal (like localhost)
+          if (iface.family === "IPv4" && !iface.internal) {
+            return iface.address;
+          }
+        }
+      }
+      return "127.0.0.1";
+    };
+
    const createProductionTransport = (level, logStreamName, filters) => {
      return new WinstonCloudWatch({
        level,
@@ -51,17 +65,26 @@ const createLogger = () => {
      });
    };

+    const hostname = process.env.HOSTNAME || getPrivateIP();
+
    const getDevelopmentTransports = () => [
      new winston.transports.Console({
        level: "silly",
        format: winston.format.combine(
          winston.format.colorize(),
          winston.format.timestamp(),
-          winston.format.printf(({ level, message, timestamp, user, record, object }) => {
-            return `${timestamp} [${level}]: ${message} ${
-              user ? `| user: ${JSON.stringify(user)}` : ""
-            } ${record ? `| record: ${JSON.stringify(record)}` : ""} ${
-              object ? `| object: ${JSON.stringify(object, null, 2)}` : ""
+          winston.format.printf(({ level, message, timestamp, user, record, meta }) => {
+            const hostnameColor = `\x1b[34m${hostname}\x1b[0m`; // Blue
+            const timestampColor = `\x1b[36m${timestamp}\x1b[0m`; // Cyan
+            const labelColor = "\x1b[33m"; // Yellow
+            const separatorColor = "\x1b[35m|\x1b[0m"; // Magenta for separators
+
+            return `${timestampColor} [${hostnameColor}] [${level}]: ${message} ${
+              user ? `${separatorColor} ${labelColor}user:\x1b[0m ${JSON.stringify(user)}` : ""
+            } ${record ? `${separatorColor} ${labelColor}record:\x1b[0m ${JSON.stringify(record)}` : ""}${
+              meta
+                ? `\n${separatorColor} ${labelColor}meta:\x1b[0m ${JSON.stringify(meta, null, 2)} ${separatorColor}`
+                : ""
            }`;
          })
        )
@@ -89,6 +112,7 @@ const createLogger = () => {
        message,
        user,
        record,
+        hostname,
        meta
      });
    };
--- a/server/web-sockets/redisSocketEvents.js
+++ b/server/web-sockets/redisSocketEvents.js
@@ -8,7 +8,6 @@ const redisSocketEvents = ({
 }) => {
  // Logging helper functions
  const createLogEvent = (socket, level, message) => {
-    //console.log(`[IOREDIS LOG EVENT] - ${socket?.user?.email} - ${socket.id} - ${message}`);
    logger.log("ioredis-log-event", level, socket?.user?.email, null, { wsmessage: message });
  };

@@ -33,7 +32,6 @@ const redisSocketEvents = ({
        next(new Error("Authentication error - no authorization token."));
      }
    } catch (error) {
-      //console.log("Uncaught connection error:::", error);
      logger.log("websocket-connection-error", "error", null, null, {
        ...error
      });
@@ -43,7 +41,7 @@ const redisSocketEvents = ({

  // Register Socket Events
  const registerSocketEvents = (socket) => {
-    createLogEvent(socket, "DEBUG", `Registering RedisIO Socket Events.`);
+    createLogEvent(socket, "debug", `Registering RedisIO Socket Events.`);

    // Token Update Events
    const registerUpdateEvents = (socket) => {
@@ -56,7 +54,7 @@ const redisSocketEvents = ({
          // If We ever want to persist user Data across workers
          // await setSessionData(socket.id, "user", user);

-          createLogEvent(socket, "INFO", "Token updated successfully");
+          createLogEvent(socket, "debug", "Token updated successfully");

          socket.emit("token-updated", { success: true });
        } catch (error) {
@@ -67,7 +65,7 @@ const redisSocketEvents = ({
              error: "Stale token."
            });
          } else {
-            createLogEvent(socket, "ERROR", `Token update failed: ${error.message}`);
+            createLogEvent(socket, "error", `Token update failed: ${error.message}`);
            socket.emit("token-updated", { success: false, error: error.message });
            // For any other errors, optionally disconnect the socket
            socket.disconnect();
@@ -82,9 +80,9 @@ const redisSocketEvents = ({
        try {
          const room = getBodyshopRoom(bodyshopUUID);
          socket.join(room);
-          createLogEvent(socket, "DEBUG", `Client joined bodyshop room: ${room}`);
+          createLogEvent(socket, "debug", `Client joined bodyshop room: ${room}`);
        } catch (error) {
-          createLogEvent(socket, "ERROR", `Error joining room: ${error}`);
+          createLogEvent(socket, "error", `Error joining room: ${error}`);
        }
      };

@@ -92,9 +90,9 @@ const redisSocketEvents = ({
        try {
          const room = getBodyshopRoom(bodyshopUUID);
          socket.leave(room);
-          createLogEvent(socket, "DEBUG", `Client left bodyshop room: ${room}`);
+          createLogEvent(socket, "debug", `Client left bodyshop room: ${room}`);
        } catch (error) {
-          createLogEvent(socket, "ERROR", `Error joining room: ${error}`);
+          createLogEvent(socket, "error", `Error joining room: ${error}`);
        }
      };

@@ -102,9 +100,10 @@ const redisSocketEvents = ({
        try {
          const room = getBodyshopRoom(bodyshopUUID);
          io.to(room).emit("bodyshop-message", message);
-          createLogEvent(socket, "DEBUG", `Broadcast message to bodyshop ${room}`);
+          // We do not need this as these can be debugged live
+          // createLogEvent(socket, "debug", `Broadcast message to bodyshop ${room}`);
        } catch (error) {
-          createLogEvent(socket, "ERROR", `Error getting room: ${error}`);
+          createLogEvent(socket, "error", `Error getting room: ${error}`);
        }
      };

@@ -115,7 +114,7 @@ const redisSocketEvents = ({
    // Disconnect Events
    const registerDisconnectEvents = (socket) => {
      const disconnect = () => {
-        createLogEvent(socket, "DEBUG", `User disconnected.`);
+        createLogEvent(socket, "debug", `User disconnected.`);
        const rooms = Array.from(socket.rooms).filter((room) => room !== socket.id);
        for (const room of rooms) {
          socket.leave(room);
--- a/server/web-sockets/web-socket.js
+++ b/server/web-sockets/web-socket.js
@@ -41,7 +41,7 @@ io.use(function (socket, next) {
 });

 io.on("connection", (socket) => {
-  socket.log_level = "TRACE";
+  socket.log_level = "DEBUG";
  createLogEvent(socket, "DEBUG", `Connected and Authenticated.`);

  socket.on("set-log-level", (level) => {
@@ -75,7 +75,7 @@ io.on("connection", (socket) => {
  socket.on("cdk-calculate-allocations", async (jobid, callback) => {
    const allocations = await CdkCalculateAllocations(socket, jobid);
    createLogEvent(socket, "DEBUG", `Allocations calculated.`);
-    createLogEvent(socket, "TRACE", `Allocations calculated. ${JSON.stringify(allocations, null, 2)}`);
+    createLogEvent(socket, "SILLY", `Allocations calculated. ${JSON.stringify(allocations, null, 2)}`);

    callback(allocations);
  });
@@ -85,7 +85,7 @@ io.on("connection", (socket) => {
  socket.on("pbs-calculate-allocations", async (jobid, callback) => {
    const allocations = await CdkCalculateAllocations(socket, jobid);
    createLogEvent(socket, "DEBUG", `Allocations calculated.`);
-    createLogEvent(socket, "TRACE", `Allocations calculated. ${JSON.stringify(allocations, null, 2)}`);
+    createLogEvent(socket, "SILLY", `Allocations calculated. ${JSON.stringify(allocations, null, 2)}`);

    callback(allocations);
  });
@@ -103,7 +103,7 @@ io.on("connection", (socket) => {
  socket.on("pbs-calculate-allocations-ap", async (billids, callback) => {
    const allocations = await PbsCalculateAllocationsAp(socket, billids);
    createLogEvent(socket, "DEBUG", `AP Allocations calculated.`);
-    createLogEvent(socket, "TRACE", `Allocations calculated. ${JSON.stringify(allocations, null, 2)}`);
+    createLogEvent(socket, "DEBUG", `Allocations calculated. ${JSON.stringify(allocations, null, 2)}`);
    socket.apAllocations = allocations;
    callback(allocations);
  });
@@ -122,7 +122,7 @@ io.on("connection", (socket) => {

 function createLogEvent(socket, level, message) {
  if (LogLevelHierarchy(socket.log_level) >= LogLevelHierarchy(level)) {
-   // console.log(`[WS LOG EVENT] ${level} - ${new Date()} - ${socket.user.email} - ${socket.id} - ${message}`);
+    // console.log(`[WS LOG EVENT] ${level} - ${new Date()} - ${socket.user.email} - ${socket.id} - ${message}`);
    socket.emit("log-event", {
      timestamp: new Date(),
      level,
@@ -173,17 +173,17 @@ function createJsonEvent(socket, level, message, json) {
 }

 function createXmlEvent(socket, xml, message, isError = false) {
-  if (LogLevelHierarchy(socket.log_level) >= LogLevelHierarchy("TRACE")) {
+  if (LogLevelHierarchy(socket.log_level) >= LogLevelHierarchy("SILLY")) {
    socket.emit("log-event", {
      timestamp: new Date(),
-      level: isError ? "ERROR" : "TRACE",
+      level: isError ? "ERROR" : "SILLY",
      message: `${message}: ${xml}`
    });
  }

  logger.log(
    isError ? "ws-log-event-xml-error" : "ws-log-event-xml",
-    isError ? "ERROR" : "TRACE",
+    isError ? "ERROR" : "SILLY",
    socket.user.email,
    socket.recordid,
    {
@@ -195,7 +195,7 @@ function createXmlEvent(socket, xml, message, isError = false) {
  if (socket.logEvents && isArray(socket.logEvents)) {
    socket.logEvents.push({
      timestamp: new Date(),
-      level: isError ? "ERROR" : "TRACE",
+      level: isError ? "ERROR" : "SILLY",
      message,
      xml
    });
@@ -206,7 +206,7 @@ function LogLevelHierarchy(level) {
  switch (level) {
    case "XML":
      return 5;
-    case "TRACE":
+    case "SILLY":
      return 5;
    case "DEBUG":
      return 4;
Author	SHA1	Message	Date
Dave Richer	971a81fc27	feature/IO-2979-DST - Finish DST Stuff Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-28 14:04:14 -07:00
Dave Richer	e605433379	Merge remote-tracking branch 'origin/release/2024-11-01' into feature/IO-2979-DST	2024-10-28 13:10:08 -07:00
Dave Richer	b9ebb70b7a	release/2024-11-01 - Remove Trace Log Level Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-28 13:06:47 -07:00
Dave Richer	79ed6f2388	release/2024-11-01 - Remove Trace Log Level Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-28 12:24:40 -07:00
Dave Richer	785449a986	release/2024-11-01 - Remove Trace Log Level Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-28 12:03:48 -07:00
Dave Richer	0b7d469e0e	feature/IO-2979-DST - Finish DST Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-28 11:55:13 -07:00
Dave Richer	a57156756e	feature/IO-2979-DST - Normalize usages of dayjs to dayjs not day, move locale hook Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-28 11:03:30 -07:00
Dave Richer	c4c30d98d4	release/2024-11-01 - Adjust hostname check Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-28 10:07:10 -07:00
Dave Richer	d4e8803b13	release/2024-11-01 - Adjust client body buffer size Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-28 09:47:27 -07:00
Dave Richer	1f2786ddec	release/2024-11-01 - Fix some log things Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-28 09:31:37 -07:00
Dave Richer	e90cda07e4	Merged in release/2024-10-25 (pull request #1848 ) Release/2024-10-25 - IO-2921, IO-2966, IO-2973, IO-2974, IO-2978, IO-2992, IO-2996, IO-2998	2024-10-26 04:48:05 +00:00
Dave Richer	9793daa04c	release/2024-10-25 - Add The local email viewer to the reference folder. Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-25 11:58:50 -07:00
Allan Carr	117ced8fe7	Merged in feature/IO-2973-Created-By-Tasks (pull request #1846 ) IO-2973 Created By Tasks Approved-by: Dave Richer	2024-10-25 18:53:11 +00:00
Dave Richer	e7909205d1	feature/IO-2973-Created-By-Tasks - Merge in release, fix conflicts Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-25 11:50:11 -07:00
Dave Richer	18028a70ab	feature/IO-2973-Created-By-Tasks - Merge in release, fix conflicts Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-25 11:22:59 -07:00
Dave Richer	eeb8d8d26f	release/2024-10-25 - Clean up referenceDocuments Signed-off-by: Dave Richer <dave@imexsystems.ca>	2024-10-25 11:21:10 -07:00
Allan Carr	23659fc412	IO-2973 Created By Tasks Signed-off-by: Allan Carr <allan.carr@thinkimex.com>	2024-10-25 11:19:40 -07:00
Patrick Fic	ba65057782	Merged in feature/IO-2974-add-comment-to-schedule (pull request #1842 ) IO-2974 add comment to schedule. Approved-by: Dave Richer	2024-10-25 17:03:06 +00:00
Dave Richer	60a859cac8	Merged in feature/IO-2998-enhanced-api-logging (pull request #1843 ) feature/IO-2998-enhanced-api-logging - Missing package	2024-10-25 15:38:46 +00:00
Patrick Fic	d085a9c7c9	IO-2974 add comment to schedule.	2024-10-25 08:33:17 -07:00
Dave Richer	ec518a0593	Merged in feature/IO-2998-enhanced-api-logging (pull request #1840 ) feature/IO-2998-enhanced-api-logging - Missing package	2024-10-25 15:30:26 +00:00
Dave Richer	26836f662a	Merged in feature/IO-2998-enhanced-api-logging (pull request #1838 ) feature/IO-2998-enhanced-api-logging - Finish	2024-10-25 15:12:24 +00:00
Dave Richer	6e88faa9d8	Merged in feature/IO-2998-enhanced-api-logging (pull request #1836 ) Feature/IO-2998 into Release/2024-10-25	2024-10-25 14:11:26 +00:00