-
-
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) || /
+
+
+
+
+
+
+
+ ${value}
+`;
+}
+
+function stripTags(value) {
+ return String(value || "")
+ .replace(//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.
+
+
+
+
+
+
+
+
+
+
+
+
+ Waiting for first refresh...
+
+
+
+
+ Total00 visible
+ New0New since last refresh
+ NewestNo messagesNot refreshed yet
+ FetchIdleEndpoint: ${escapeHtml(SES_ENDPOINT)}
+
+
+
+
+
+
+
+
+
+
${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.
Loading raw source...
';
+ }
+
+ if (raw.status === "error") {
+ return `Unable to load raw source: ${escapeHtml(raw.error)}
${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",