-
-
Message ${index + 1}
-
From: ${message.Source}
-
To: ${parsed.to.text || "No To Address"}
-
Subject: ${parsed.subject || "No Subject"}
-
Region: ${message.Region}
-
Timestamp: ${message.Timestamp}
-
-
${parsed.html || parsed.textAsHtml || "No HTML content available"}
-
-
Message ${index + 1}
-
From: ${message.Source}
-
Region: ${message.Region}
-
Timestamp: ${message.Timestamp}
-
Error parsing email content
-
-
Email Messages Viewer
-
${messagesHtml}
+async function fetchSesMessages() {
+ const response = await fetch(SES_ENDPOINT, {
+ signal: AbortSignal.timeout(FETCH_TIMEOUT_MS)
+ });
+
+ if (!response.ok) {
+ throw new Error(`SES endpoint responded with ${response.status}`);
+ }
+
+ const data = await response.json();
+ return Array.isArray(data.messages) ? data.messages : [];
+}
+
+async function toMessageViewModel(message, index) {
+ const id = resolveMessageId(message, index);
+
+ try {
+ const parsed = await simpleParser(message.RawData || "");
+ const textContent = normalizeText(parsed.text || "");
+ const renderedHtml = buildRenderedHtml(parsed.html || parsed.textAsHtml || "");
+ const timestamp = normalizeTimestamp(message.Timestamp || parsed.date);
+
+ return {
+ id,
+ index,
+ from: formatAddressList(parsed.from) || message.Source || "Unknown sender",
+ to: formatAddressList(parsed.to) || "No To Address",
+ replyTo: formatAddressList(parsed.replyTo),
+ subject: parsed.subject || "No Subject",
+ region: message.Region || "",
+ timestamp,
+ timestampMs: timestamp ? Date.parse(timestamp) : 0,
+ messageId: parsed.messageId || "",
+ rawSizeBytes: Buffer.byteLength(message.RawData || "", "utf8"),
+ attachmentCount: parsed.attachments.length,
+ attachments: parsed.attachments.map((attachment) => ({
+ filename: attachment.filename || "Unnamed attachment",
+ contentType: attachment.contentType || "application/octet-stream",
+ size: attachment.size || 0
+ })),
+ preview: buildPreview(textContent, renderedHtml),
+ textContent,
+ renderedHtml,
+ hasHtml: Boolean(renderedHtml),
+ parseError: ""
+ };
+ } catch (error) {
+ return {
+ id,
+ index,
+ from: message.Source || "Unknown sender",
+ to: "Unknown recipient",
+ replyTo: "",
+ subject: "Unable to parse message",
+ region: message.Region || "",
+ timestamp: normalizeTimestamp(message.Timestamp),
+ timestampMs: message.Timestamp ? Date.parse(message.Timestamp) : 0,
+ messageId: "",
+ rawSizeBytes: Buffer.byteLength(message.RawData || "", "utf8"),
+ attachmentCount: 0,
+ attachments: [],
+ preview: "This message could not be parsed. Open the raw view to inspect the MIME source.",
+ textContent: "",
+ renderedHtml: "",
+ hasHtml: false,
+ parseError: error.message
+ };
+ }
+}
+
+function resolveMessageId(message, index = 0) {
+ return message.Id || `${message.Timestamp || "unknown"}-${message.Source || "unknown"}-${index}`;
+}
+
+function normalizeTimestamp(value) {
+ if (!value) {
+ return "";
+ }
+
+ const date = value instanceof Date ? value : new Date(value);
+ return Number.isNaN(date.getTime()) ? "" : date.toISOString();
+}
+
+function normalizeText(value) {
+ return String(value || "")
+ .replace(/\r\n/g, "\n")
+ .trim();
+}
+
+function buildPreview(textContent, renderedHtml) {
+ const source = (textContent || stripTags(renderedHtml)).replace(/\s+/g, " ").trim();
+
+ if (!source) {
+ return "No message preview available.";
+ }
+
+ return source.length > 220 ? `${source.slice(0, 217)}...` : source;
+}
+
+function buildRenderedHtml(html) {
+ if (!html) {
+ return "";
+ }
+
+ const value = String(html);
+ const hasDocument = /
]/i.test(value) || /
+
+
+ /gi, " ")
+ .replace(//gi, " ")
+ .replace(/<[^>]+>/g, " ");
+}
+
+function formatAddressList(addresses) {
+ if (!addresses?.value?.length) {
+ return "";
+ }
+
+ return addresses.value
+ .map(({ name, address }) => {
+ if (name && address) {
+ return `${name} <${address}>`;
+ }
+
+ return address || name || "";
+ })
+ .filter(Boolean)
+ .join(", ");
+}
+
+function getClientConfig() {
+ return {
+ defaultRefreshMs: DEFAULT_REFRESH_MS,
+ endpoint: SES_ENDPOINT
+ };
+}
+
+function renderHtml() {
+ return `
+
+
+ LocalStack Email Viewer
+
+
+
+
+
+
+
LocalStack SES
+
Email Viewer
+
A faster local inbox for generated emails with live refresh, manual refresh, search, and raw MIME inspection.
+
+ Refresh now
+ Every
+
+ 5s
+ 10s
+ 15s
+ 30s
+ 60s
+
+
+
+
+ Clear
+
+
+ Expand all
+ Collapse all
+ Waiting for first refresh...
+
+
+
+
+ Total 0 0 visible New 0 New since last refresh Newest No messages Not refreshed yet Fetch Idle Endpoint: ${escapeHtml(SES_ENDPOINT)}
+
+
+
+
+
New ');
+ }
+
+ if (message.attachmentCount) {
+ tags.push(
+ `${message.attachmentCount} attachment${message.attachmentCount === 1 ? "" : "s"} `
+ );
+ }
+
+ tags.push(`${message.hasHtml ? "HTML" : "Text only"} `);
+
+ if (message.parseError) {
+ tags.push('Parse issue ');
+ }
+
+ return `
+
+
+
+
+
${escapeHtml(message.subject)}
+
${escapeHtml(message.from)} to ${escapeHtml(message.to)}
+
+
${escapeHtml(formatDateTime(message.timestamp))}
+
${tags.join("")}
+ ${escapeHtml(message.preview)}
+
+
+
+
+
+ ${metaCard("From", message.from)}
+ ${metaCard("To", message.to)}
+ ${metaCard("Reply-To", message.replyTo || "None")}
+ ${metaCard("Sent", formatDateTime(message.timestamp))}
+ ${metaCard("Region", message.region || "Unknown region")}
+ ${metaCard("LocalStack Id", message.id)}
+ ${metaCard("Message-Id", message.messageId || "Not available")}
+ ${metaCard("Raw size", formatBytes(message.rawSizeBytes))}
+ ${message.parseError ? metaCard("Parse error", message.parseError) : ""}
+
+
+ ${
+ message.attachments?.length
+ ? `
${message.attachments
+ .map((attachment) => {
+ const size = attachment.size ? `, ${formatBytes(attachment.size)}` : "";
+ return `${escapeHtml(attachment.filename)} (${escapeHtml(attachment.contentType)}${escapeHtml(size)}) `;
+ })
+ .join("")}
`
+ : ""
+ }
+
+
${renderPanel(message, view)}
+
+ `;
+ }
+
+ function renderPanel(message, view) {
+ if (view === "rendered" && message.hasHtml) {
+ return ``;
+ }
+
+ if (view === "raw") {
+ const raw = state.raw[message.id];
+
+ if (!raw) {
+ return `Raw MIME source is loaded on demand.
Load raw source
Loading raw source...
';
+ }
+
+ if (raw.status === "error") {
+ return `Unable to load raw source: ${escapeHtml(raw.error)}
Retry
${escapeHtml(raw.value)} `;
+ }
+
+ return `${escapeHtml(message.textContent || "No plain-text content available for this message.")} `;
+ }
+
+ function metaCard(label, value) {
+ return `
${escapeHtml(label)} ${escapeHtml(value)} `;
+ }
+
+ function hydrate(details, message) {
+ if (!details || !details.open || !message) {
+ return;
+ }
+
+ const view = state.views[message.id] || (message.hasHtml ? "rendered" : "text");
+
+ if (view !== "rendered" || !message.hasHtml) {
+ return;
+ }
+
+ const iframe = details.querySelector("[data-frame]");
+
+ if (iframe) {
+ iframe.referrerPolicy = "no-referrer";
+ iframe.sandbox = "";
+ iframe.srcdoc = message.renderedHtml || "";
+ }
+ }
+
+ function getMessage(id) {
+ return state.messages.find((message) => message.id === id);
+ }
+
+ async function loadRaw(id) {
+ if (state.raw[id]?.status === "loaded") {
+ return state.raw[id].value;
+ }
+
+ if (state.raw[id]?.status === "loading") {
+ return null;
+ }
+
+ state.raw[id] = { status: "loading" };
+ renderList();
+
+ try {
+ const response = await fetch(`/api/messages/${encodeURIComponent(id)}/raw`, { cache: "no-store" });
+
+ if (!response.ok) {
+ throw new Error((await response.text()) || `Request failed with ${response.status}`);
+ }
+
+ const value = await response.text();
+ state.raw[id] = { status: "loaded", value };
+ return value;
+ } catch (error) {
+ state.raw[id] = { status: "error", error: error.message || "Unknown raw load error" };
+ setStatus("Could not load the raw message source.", "bad");
+ return null;
+ } finally {
+ renderList();
+ }
+ }
+
+ async function copyText(value) {
+ try {
+ await navigator.clipboard.writeText(value);
+ } catch {
+ const input = document.createElement("textarea");
+ input.value = value;
+ input.setAttribute("readonly", "");
+ input.style.position = "fixed";
+ input.style.opacity = "0";
+ document.body.appendChild(input);
+ input.select();
+ document.execCommand("copy");
+ document.body.removeChild(input);
+ }
+ }
+
+ function setStatus(message, tone) {
+ el.statusChip.className = "status";
+
+ if (tone) {
+ el.statusChip.classList.add(tone);
+ }
+
+ el.statusChip.textContent = message;
+ }
+
+ function formatDateTime(value) {
+ if (!value) {
+ return "Unknown time";
+ }
+
+ const date = new Date(value);
+ return Number.isNaN(date.getTime())
+ ? "Unknown time"
+ : new Intl.DateTimeFormat(undefined, { dateStyle: "medium", timeStyle: "short" }).format(date);
+ }
+
+ function formatRelative(timestampMs) {
+ const seconds = Math.max(1, Math.round((Date.now() - timestampMs) / 1000));
+
+ if (seconds < 60) {
+ return `${seconds}s ago`;
+ }
+
+ const minutes = Math.round(seconds / 60);
+
+ if (minutes < 60) {
+ return `${minutes}m ago`;
+ }
+
+ const hours = Math.round(minutes / 60);
+
+ if (hours < 24) {
+ return `${hours}h ago`;
+ }
+
+ return `${Math.round(hours / 24)}d ago`;
+ }
+
+ function formatBytes(value) {
+ if (!value) {
+ return "0 B";
+ }
+
+ const units = ["B", "KB", "MB", "GB"];
+ let size = value;
+ let index = 0;
+
+ while (size >= 1024 && index < units.length - 1) {
+ size /= 1024;
+ index += 1;
+ }
+
+ return `${index === 0 ? size : size.toFixed(1)} ${units[index]}`;
+ }
+
+ function escapeHtml(value) {
+ return String(value ?? "")
+ .replace(/&/g, "&")
+ .replace(//g, ">")
+ .replace(/"/g, """)
+ .replace(/'/g, "'");
+ }
+
+ async function safeJson(response) {
+ try {
+ return await response.json();
+ } catch {
+ return null;
+ }
+ }
+}
+
app.listen(PORT, () => {
- console.log(`Server is running on http://localhost:${PORT}`);
+ console.log(`Local email viewer is running on http://localhost:${PORT}`);
+ console.log(`Watching LocalStack SES endpoint at ${SES_ENDPOINT}`);
});
diff --git a/_reference/localEmailViewer/package.json b/_reference/localEmailViewer/package.json
index 5f553cf17..a6b522e0e 100644
--- a/_reference/localEmailViewer/package.json
+++ b/_reference/localEmailViewer/package.json
@@ -4,12 +4,13 @@
"main": "index.js",
"type": "module",
"scripts": {
- "test": "echo \"Error: no test specified\" && exit 1"
+ "start": "node index.js",
+ "check": "node --check index.js"
},
"keywords": [],
"author": "",
"license": "ISC",
- "description": "",
+ "description": "LocalStack SES email viewer for inspecting local outbound mail",
"dependencies": {
"express": "^5.1.0",
"mailparser": "^3.7.4",
diff --git a/client/src/components/_test/test.page.jsx b/client/src/components/_test/test.page.jsx
index 87ef90e95..a50a7d894 100644
--- a/client/src/components/_test/test.page.jsx
+++ b/client/src/components/_test/test.page.jsx
@@ -1,7 +1,11 @@
-import { Button } from "antd";
+import { Button, Card, Divider, Form, Space, Typography } from "antd";
import { connect } from "react-redux";
+import queryString from "query-string";
+import { useLocation } from "react-router-dom";
import { createStructuredSelector } from "reselect";
import { setModalContext } from "../../redux/modals/modals.actions";
+import { PayrollLaborAllocationsTable } from "../labor-allocations-table/labor-allocations-table.payroll.component.jsx";
+import { TimeTicketTaskModalComponent } from "../time-ticket-task-modal/time-ticket-task-modal.component.jsx";
const mapStateToProps = createStructuredSelector({});
@@ -9,8 +13,109 @@ const mapDispatchToProps = (dispatch) => ({
setRefundPaymentContext: (context) => dispatch(setModalContext({ context: context, modal: "refund_payment" }))
});
+const commissionCutFixture = {
+ bodyshop: {
+ features: {
+ timetickets: true
+ },
+ employees: [
+ { id: "emp-1", first_name: "Avery", last_name: "Johnson" },
+ { id: "emp-2", first_name: "Morgan", last_name: "Lee" }
+ ],
+ md_tasks_presets: {
+ presets: [
+ {
+ name: "Body Prep",
+ percent: 50,
+ hourstype: ["LAA", "LAB"],
+ nextstatus: "In Progress"
+ }
+ ]
+ }
+ },
+ jobId: "fixture-job-1",
+ joblines: [
+ {
+ id: "line-1",
+ mod_lbr_ty: "LAA",
+ mod_lb_hrs: 4,
+ assigned_team: "team-1",
+ convertedtolbr: false
+ }
+ ],
+ previewValues: {
+ task: "Body Prep",
+ timetickets: [
+ {
+ employeeid: "emp-1",
+ cost_center: "Body",
+ ciecacode: "LAA",
+ productivehrs: 2,
+ rate: 40,
+ payoutamount: 80,
+ payout_context: {
+ payout_method: "commission"
+ }
+ },
+ {
+ employeeid: "emp-2",
+ cost_center: "Refinish",
+ ciecacode: "LAB",
+ productivehrs: 1,
+ rate: 28,
+ payoutamount: 28,
+ payout_context: {
+ payout_method: "hourly"
+ }
+ }
+ ]
+ }
+};
+
+function CommissionCutHarness() {
+ const [form] = Form.useForm();
+
+ return (
+
+ Commission Cut Test Harness
+
+ This fixture keeps commission-cut browser checks stable by rendering representative payroll and preview UI with
+ local data.
+
+
+ {}}
+ />
+
+
+
+
+
+ );
+}
+
function Test({ setRefundPaymentContext, refundPaymentModal }) {
+ const search = queryString.parse(useLocation().search);
console.log("refundPaymentModal", refundPaymentModal);
+
+ if (search.fixture === "commission-cut") {
+ return
"audit-entry");
+
+vi.mock("@apollo/client/react", () => ({
+ useMutation: (...args) => useMutationMock(...args)
+}));
+
+vi.mock("react-i18next", () => ({
+ useTranslation: () => ({
+ t: (key) => {
+ const translations = {
+ "joblines.fields.mod_lbr_ty": "Labor Type",
+ "joblines.fields.lbr_types.LAA": "LAA",
+ "jobs.fields.adjustmenthours": "Adjustment Hours",
+ "general.actions.save": "Save",
+ "jobs.successes.save": "Saved"
+ };
+
+ return translations[key] || key;
+ }
+ })
+}));
+
+vi.mock("../../contexts/Notifications/notificationContext.jsx", () => ({
+ useNotification: () => notification
+}));
+
+vi.mock("../../utils/AuditTrailMappings", () => ({
+ default: {
+ jobmodifylbradj: (...args) => jobmodifylbradjMock(...args)
+ }
+}));
+
+describe("LaborAllocationsAdjustmentEdit", () => {
+ beforeEach(() => {
+ vi.clearAllMocks();
+
+ useMutationMock.mockImplementation((mutation) => {
+ if (mutation === UPDATE_JOB) {
+ return [updateAdjustmentsMock];
+ }
+
+ return [vi.fn()];
+ });
+
+ updateAdjustmentsMock.mockResolvedValue({});
+ });
+
+ it("saves merged labor adjustments and records the adjustment delta", async () => {
+ render(
+
+ Edit Adjustment
+
+ );
+
+ fireEvent.click(screen.getByRole("button", { name: "Edit Adjustment" }));
+
+ fireEvent.change(screen.getByRole("spinbutton"), {
+ target: { value: "3.7" }
+ });
+
+ fireEvent.click(screen.getByRole("button", { name: "Save" }));
+
+ await waitFor(() => {
+ expect(updateAdjustmentsMock).toHaveBeenCalledWith({
+ variables: {
+ jobId: "job-1",
+ job: {
+ lbr_adjustments: {
+ LAA: 3.7,
+ LAB: 0.5
+ }
+ }
+ },
+ refetchQueries: ["QUERY_JOB"]
+ });
+ });
+
+ expect(jobmodifylbradjMock).toHaveBeenCalledWith({
+ mod_lbr_ty: "LAA",
+ hours: 2.5
+ });
+ expect(insertAuditTrailMock).toHaveBeenCalledWith({
+ jobid: "job-1",
+ operation: "audit-entry",
+ type: "jobmodifylbradj"
+ });
+ expect(notification.success).toHaveBeenCalledWith({
+ title: "Saved"
+ });
+ });
+});
diff --git a/client/src/components/labor-allocations-table/labor-allocations-table.payroll.component.test.jsx b/client/src/components/labor-allocations-table/labor-allocations-table.payroll.component.test.jsx
new file mode 100644
index 000000000..82caf248d
--- /dev/null
+++ b/client/src/components/labor-allocations-table/labor-allocations-table.payroll.component.test.jsx
@@ -0,0 +1,190 @@
+import { fireEvent, render, screen, waitFor } from "@testing-library/react";
+import axios from "axios";
+import { describe, expect, it, beforeEach, vi } from "vitest";
+import { PayrollLaborAllocationsTable } from "./labor-allocations-table.payroll.component.jsx";
+
+const notification = {
+ success: vi.fn(),
+ error: vi.fn()
+};
+
+vi.mock("axios", () => ({
+ default: {
+ post: vi.fn()
+ }
+}));
+
+vi.mock("react-i18next", () => ({
+ useTranslation: () => ({
+ t: (key, values = {}) => {
+ const translations = {
+ "jobs.labels.laborallocations": "Labor Allocations",
+ "timetickets.actions.payall": "Pay All",
+ "general.labels.totals": "Totals",
+ "jobs.labels.outstandinghours": "Outstanding hours remain."
+ };
+
+ if (key === "timetickets.successes.payall") {
+ return "All hours paid out successfully.";
+ }
+
+ if (key === "timetickets.errors.payall") {
+ return `Error flagging hours. ${values.error || ""}`.trim();
+ }
+
+ return translations[key] || key;
+ }
+ })
+}));
+
+vi.mock("../../contexts/Notifications/notificationContext.jsx", () => ({
+ useNotification: () => notification
+}));
+
+vi.mock("../responsive-table/responsive-table.component", () => {
+ function ResponsiveTable({ dataSource = [], summary }) {
+ return (
+
+
{`rows:${dataSource.length}`}
+ {summary ?
{summary()}
: null}
+
{children}
,
+ Cell: ({ children }) => {children}
+ };
+
+ return {
+ default: ResponsiveTable
+ };
+});
+
+vi.mock("../feature-wrapper/feature-wrapper.component", () => ({
+ HasFeatureAccess: () => true
+}));
+
+vi.mock("../upsell/upsell.component", () => ({
+ default: () => Upsell
,
+ upsellEnum: () => ({
+ timetickets: {
+ allocations: "allocations"
+ }
+ })
+}));
+
+vi.mock("../lock-wrapper/lock-wrapper.component", () => ({
+ default: ({ children }) => children
+}));
+
+describe("PayrollLaborAllocationsTable", () => {
+ beforeEach(() => {
+ vi.clearAllMocks();
+ });
+
+ it("shows a success notification after Pay All completes", async () => {
+ axios.post
+ .mockResolvedValueOnce({
+ data: [
+ {
+ employeeid: "emp-1",
+ mod_lbr_ty: "LAA",
+ expectedHours: 4,
+ claimedHours: 1
+ }
+ ]
+ })
+ .mockResolvedValueOnce({
+ status: 200,
+ data: [{ id: "ticket-1" }]
+ });
+
+ const refetch = vi.fn();
+
+ render(
+ onChange?.(event.target.value || undefined)}
+ >
+ Select Employee
+ {options.map((option) => (
+
+ {[option.first_name, option.last_name].filter(Boolean).join(" ")}
+
+ ))}
+
+ )
+}));
+
+vi.mock("../form-items-formatted/currency-form-item.component", () => ({
+ default: ({ id, value, onChange }) => (
+
+ {title}
+ {extra}
+ {children}
+
+ )
+}));
+
+vi.mock("../form-list-move-arrows/form-list-move-arrows.component", () => ({
+ default: () => null
+}));
+
+const bodyshop = {
+ id: "shop-1",
+ employees: [
+ {
+ id: "emp-1",
+ first_name: "Avery",
+ last_name: "Johnson"
+ },
+ {
+ id: "emp-2",
+ first_name: "Morgan",
+ last_name: "Lee"
+ }
+ ]
+};
+
+const fillHourlyRates = (value) => {
+ LABOR_TYPES.forEach((laborType) => {
+ fireEvent.change(screen.getByLabelText(laborType), {
+ target: { value: String(value) }
+ });
+ });
+};
+
+const addBaseTeamMember = ({ employeeId = "emp-1", percentage = 100, rate = 25 } = {}) => {
+ fireEvent.click(screen.getByRole("button", { name: "New Team Member" }));
+
+ fireEvent.change(screen.getByLabelText("Employee"), {
+ target: { value: employeeId }
+ });
+ fireEvent.change(screen.getByRole("spinbutton", { name: "Allocation %" }), {
+ target: { value: String(percentage) }
+ });
+ fillHourlyRates(rate);
+};
+
+describe("ShopEmployeeTeamsFormComponent", () => {
+ beforeEach(() => {
+ vi.clearAllMocks();
+
+ useQueryMock.mockReturnValue({
+ error: null,
+ data: null,
+ loading: false
+ });
+
+ useMutationMock.mockImplementation((mutation) => {
+ if (mutation === UPDATE_EMPLOYEE_TEAM) {
+ return [updateEmployeeTeamMock];
+ }
+
+ if (mutation === INSERT_EMPLOYEE_TEAM) {
+ return [insertEmployeeTeamMock];
+ }
+
+ return [vi.fn()];
+ });
+
+ insertEmployeeTeamMock.mockResolvedValue({
+ data: {
+ insert_employee_teams_one: {
+ id: "team-1"
+ }
+ }
+ });
+ });
+
+ it("switches a new team member from hourly rates to commission percentages", async () => {
+ render({value}
+}));
+
+vi.mock("../job-search-select/job-search-select.component", () => ({
+ default: () => Job Search
+}));
+
+function TestHarness({ unassignedHours = 0 }) {
+ const [form] = Form.useForm();
+
+ return (
+
+ );
+}
+
+describe("TimeTicketTaskModalComponent", () => {
+ it("shows preview payout methods for both commission and hourly tickets", () => {
+ render(