Status
@@ -1683,14 +1825,15 @@
}
function renderPriceTrend(opt) {
- const series = Array.isArray(opt.priceHistory)
- ? opt.priceHistory.filter(point => typeof point.price === 'number' && !Number.isNaN(point.price))
- : [];
+ const selectedSourceKey = getOptionSelectedSourceKey(opt);
+ const series = getOptionSourceSeries(opt, selectedSourceKey)
+ .filter(point => typeof point.price === 'number' && !Number.isNaN(point.price));
+ const selectedMeta = getOptionSourceMeta(opt, selectedSourceKey);
if (series.length === 0) {
return `
- Price tracking appears after the next automation run.
+ ${selectedMeta?.sourceLabel ? `${escapeHtml(selectedMeta.sourceLabel)} price tracking appears after the next automation run.` : 'Price tracking appears after the next automation run.'}
`;
}
@@ -1733,13 +1876,14 @@
? 'flat from first check'
: `${delta > 0 ? '+' : '−'}${formatCurrency(Math.abs(delta), latest.currency)}`;
const checkedLabel = latest.checkedAt ? formatTrackedDate(latest.checkedAt) : '';
+ const sourceLabel = selectedMeta?.sourceLabel || latest.source || 'Tracked source';
return `
diff --git a/server.js b/server.js
index 3960895..6019066 100644
--- a/server.js
+++ b/server.js
@@ -63,6 +63,10 @@ function normalizeKey(value) {
.replace(/^-+|-+$/g, '');
}
+function normalizeSourceLabel(value) {
+ return String(value || 'Unknown source').trim() || 'Unknown source';
+}
+
const HISTORY_KEY_ALIASES = {
'costco-breathless': 'hotel-breathless',
'costco-grand-fiesta': 'hotel-grand-fiesta',
@@ -194,7 +198,8 @@ function loadPriceHistoryState() {
price,
currency: point.currency || 'USD',
displayPrice: point.displayPrice || point.priceLabel || point.label || null,
- source: point.source || null,
+ source: normalizeSourceLabel(point.source || point.sourceLabel || point.vendor || null),
+ sourceKey: normalizeKey(point.sourceKey || point.sourceId || point.source || point.sourceLabel || point.vendor || 'unknown-source'),
sourceUrl: point.sourceUrl || point.url || null,
note: point.note || point.description || null,
availability: point.availability || point.status || null,
@@ -223,6 +228,61 @@ function loadPriceHistoryState() {
};
}
+function buildPriceHistoryBySource(priceHistory) {
+ const grouped = new Map();
+
+ priceHistory.forEach((point) => {
+ const sourceKey = normalizeKey(point.sourceKey || point.source || 'unknown-source');
+ const sourceLabel = normalizeSourceLabel(point.source || point.sourceLabel || sourceKey);
+ if (!grouped.has(sourceKey)) {
+ grouped.set(sourceKey, {
+ sourceKey,
+ sourceLabel,
+ sourceUrl: point.sourceUrl || null,
+ points: [],
+ });
+ }
+
+ const bucket = grouped.get(sourceKey);
+ bucket.points.push({
+ ...point,
+ sourceKey,
+ source: sourceLabel,
+ });
+ if (!bucket.sourceUrl && point.sourceUrl) bucket.sourceUrl = point.sourceUrl;
+ if (bucket.sourceLabel === 'Unknown source' && sourceLabel) bucket.sourceLabel = sourceLabel;
+ });
+
+ const seriesBySource = {};
+ const sourceSummaries = [...grouped.values()].map((bucket) => {
+ bucket.points.sort((a, b) => a.runIndex - b.runIndex);
+ seriesBySource[bucket.sourceKey] = bucket.points;
+ const latestPoint = bucket.points.at(-1) || null;
+
+ return {
+ sourceKey: bucket.sourceKey,
+ sourceLabel: bucket.sourceLabel,
+ sourceUrl: bucket.sourceUrl,
+ pointCount: bucket.points.length,
+ latestCheckedAt: latestPoint?.checkedAt || null,
+ latestCheckedAtMs: latestPoint?.checkedAtMs || 0,
+ latestPrice: latestPoint?.price ?? null,
+ latestDisplayPrice: latestPoint?.displayPrice || null,
+ currency: latestPoint?.currency || 'USD',
+ };
+ }).sort((a, b) => {
+ const aMs = a.latestCheckedAtMs || 0;
+ const bMs = b.latestCheckedAtMs || 0;
+ if (aMs !== bMs) return bMs - aMs;
+ return a.sourceLabel.localeCompare(b.sourceLabel);
+ });
+
+ return {
+ seriesBySource,
+ sourceSummaries,
+ };
+}
+
function getPriceHistoryForOption(option, priceHistoryState) {
const optionKeys = getOptionHistoryKeys(option);
for (const key of optionKeys) {
@@ -237,7 +297,11 @@ function getPriceHistoryForOption(option, priceHistoryState) {
function decorateOptionWithPriceHistory(option, priceHistoryState) {
const priceHistory = getPriceHistoryForOption(option, priceHistoryState);
- const latestPricePoint = priceHistory.at(-1) || null;
+ const { seriesBySource, sourceSummaries } = buildPriceHistoryBySource(priceHistory);
+ const defaultSourceSummary = sourceSummaries[0] || null;
+ const defaultSourceKey = defaultSourceSummary?.sourceKey || null;
+ const defaultPriceHistory = defaultSourceKey ? seriesBySource[defaultSourceKey] || [] : priceHistory;
+ const latestPricePoint = defaultPriceHistory.at(-1) || null;
const optionDetails = toTextList(option.details);
const automationHighlights = toTextList(latestPricePoint?.highlights);
const automationFeatures = toTextList(latestPricePoint?.features);
@@ -255,7 +319,11 @@ function decorateOptionWithPriceHistory(option, priceHistoryState) {
return {
...option,
- priceHistory,
+ priceHistory: defaultPriceHistory,
+ priceHistoryBySource: seriesBySource,
+ availableSources: sourceSummaries,
+ defaultSourceKey,
+ currentSourceKey: defaultSourceKey,
latestPricePoint,
currentPrice: latestPricePoint?.price ?? null,
decisionDetails: [...new Set(decisionDetails)],