mirror of
https://github.com/dgtlmoon/changedetection.io.git
synced 2026-07-08 08:21:14 +00:00
dgtlmoon
110 lines
4.2 KiB
Python
110 lines
4.2 KiB
Python
"""
|
|
History/diff rendering for the restock_diff (price / stock availability) processor.
|
|
|
|
A text diff is meaningless for restock watches - each history snapshot is just a short
|
|
string like "In Stock: True - Price: 12.34". So instead of a diff, this renders the whole
|
|
timeline as a simple smoothed line graph of price over time, coloured green where the item
|
|
was in stock and red where it was out of stock.
|
|
|
|
Conforms to processors.difference_base.DifferenceRenderer (module-level render()), and also
|
|
provides an optional get_data() hook served as JSON by /diff/<uuid>/processor-data so the
|
|
(potentially long) timeline stays out of the rendered HTML - same rationale as the preview
|
|
asset endpoint.
|
|
"""
|
|
import re
|
|
import time
|
|
|
|
from flask_babel import gettext
|
|
from loguru import logger
|
|
|
|
# Snapshot format is written by processor.py: f"In Stock: {in_stock} - Price: {price}"
|
|
_RE_PRICE = re.compile(r"Price:\s*([\d.]+)", re.IGNORECASE)
|
|
_RE_INSTOCK = re.compile(r"In Stock:\s*(True|False)", re.IGNORECASE)
|
|
|
|
|
|
def _parse_restock_snapshot(text):
|
|
"""Parse a snapshot string into (price: float|None, in_stock: bool|None)."""
|
|
price = None
|
|
in_stock = None
|
|
if text:
|
|
m = _RE_PRICE.search(text)
|
|
if m:
|
|
try:
|
|
price = float(m.group(1))
|
|
except (TypeError, ValueError):
|
|
price = None
|
|
mi = _RE_INSTOCK.search(text)
|
|
if mi:
|
|
in_stock = mi.group(1).lower() == 'true'
|
|
return price, in_stock
|
|
|
|
|
|
def _currency(watch):
|
|
try:
|
|
return (watch.get('restock') or {}).get('currency') or ''
|
|
except Exception:
|
|
return ''
|
|
|
|
|
|
def _build_series(watch):
|
|
"""Read the full history into a [{timestamp, price, in_stock}] timeline (oldest -> newest)."""
|
|
series = []
|
|
for ts in list(watch.history.keys()):
|
|
try:
|
|
snapshot = watch.get_history_snapshot(timestamp=ts)
|
|
except Exception as e:
|
|
logger.error(f"Restock diff: unable to read snapshot {ts} for {watch.get('uuid')}: {e}")
|
|
continue
|
|
price, in_stock = _parse_restock_snapshot(snapshot)
|
|
series.append({'timestamp': int(ts), 'price': price, 'in_stock': in_stock})
|
|
return series
|
|
|
|
|
|
def get_data(watch, datastore, request):
|
|
"""JSON payload for the price/stock graph, fetched via /diff/<uuid>/processor-data.
|
|
Keeps the full timeline out of the HTML page."""
|
|
series = _build_series(watch)
|
|
priced = sum(1 for p in series if p['price'] is not None)
|
|
logger.info(f"Restock diff get_data for {watch.get('uuid')}: {len(series)} snapshots, {priced} with a price")
|
|
return {
|
|
'series': series,
|
|
'currency': _currency(watch),
|
|
}
|
|
|
|
|
|
def render(watch, datastore, request, url_for, render_template, flash, redirect, extract_form=None):
|
|
"""Render the price/stock timeline page (shell + summary). The graph data is loaded
|
|
asynchronously from get_data() so this stays light regardless of history length."""
|
|
uuid = watch.get('uuid')
|
|
dates = list(watch.history.keys())
|
|
|
|
# Light render: read only the most recent snapshot for the summary badge/price.
|
|
latest = None
|
|
if dates:
|
|
try:
|
|
price, in_stock = _parse_restock_snapshot(watch.get_history_snapshot(timestamp=dates[-1]))
|
|
latest = {'timestamp': int(dates[-1]), 'price': price, 'in_stock': in_stock}
|
|
except Exception as e:
|
|
logger.error(f"Restock diff: unable to read latest snapshot for {uuid}: {e}")
|
|
|
|
# Opening the history page counts as viewing it (mirrors the text diff page).
|
|
datastore.set_last_viewed(uuid, time.time())
|
|
|
|
return render_template(
|
|
'restock_diff/difference.html',
|
|
uuid=uuid,
|
|
watch=watch,
|
|
current_diff_url=watch['url'],
|
|
extra_title=f" - {watch.label} - {gettext('Price history')}",
|
|
last_error=watch['last_error'],
|
|
last_error_screenshot=watch.get_error_snapshot(),
|
|
last_error_text=watch.get_error_text(),
|
|
versions=dates,
|
|
from_version=str(dates[-2]) if len(dates) >= 2 else (str(dates[-1]) if dates else ''),
|
|
to_version=str(dates[-1]) if dates else '',
|
|
restock_latest=latest,
|
|
restock_currency=_currency(watch),
|
|
has_enough_history=len(dates) >= 2,
|
|
processor_data_url=url_for('ui.ui_diff.diff_history_page_processor_data', uuid=uuid),
|
|
)
|