-
- {NAV_ITEMS.map((item, index) => (
-
- ))}
+
-
-
-
@@ -1058,9 +916,8 @@ function ScanTerminalScreen() {
-
) : (
renderMainView()
diff --git a/frontend/lib/dashboard-types.ts b/frontend/lib/dashboard-types.ts
index 6070fff7..38409344 100644
--- a/frontend/lib/dashboard-types.ts
+++ b/frontend/lib/dashboard-types.ts
@@ -497,6 +497,11 @@ export interface ScanOpportunityRow {
distribution_bias_direction?: string | null;
distribution_bias_score?: number | null;
distribution_bias_available?: boolean;
+ peak_probability?: number | null;
+ peak_value?: number | null;
+ peak_distance?: number | null;
+ peak_alignment_score?: number | null;
+ is_peak_candidate?: boolean;
window_phase?: string | null;
window_score?: number | null;
remaining_window_minutes?: number | null;
@@ -525,6 +530,12 @@ export interface PrimarySignal extends ScanOpportunityRow {}
export interface ScanTerminalResponse {
generated_at: string;
+ snapshot_id?: string | null;
+ status?: "ready" | "stale" | "failed" | string;
+ stale?: boolean;
+ stale_reason?: string | null;
+ last_success_at?: string | null;
+ last_failed_at?: string | null;
filters: ScanTerminalFilters;
summary: {
recommended_count: number;
diff --git a/src/data_collection/polymarket_readonly.py b/src/data_collection/polymarket_readonly.py
index aca09423..d806b838 100644
--- a/src/data_collection/polymarket_readonly.py
+++ b/src/data_collection/polymarket_readonly.py
@@ -2810,12 +2810,60 @@ class PolymarketReadOnlyLayer:
)
distribution_preview[highlighted_index]["highlighted"] = True
+ peak_probability = None
+ peak_value = None
+ if distribution_preview:
+ highlighted_preview = next(
+ (item for item in distribution_preview if item.get("highlighted")),
+ None,
+ )
+ if isinstance(highlighted_preview, dict):
+ peak_probability = _safe_float(highlighted_preview.get("model_probability"))
+ peak_value = _safe_float(highlighted_preview.get("value"))
+
+ ordered_entry_indices = sorted(
+ range(len(market_entries)),
+ key=lambda index: (
+ _safe_float(market_entries[index].get("bucket_temp"))
+ if _safe_float(market_entries[index].get("bucket_temp")) is not None
+ else float("inf"),
+ str(market_entries[index].get("target_label") or ""),
+ ),
+ )
+ entry_order_map = {
+ ordered_entry_indices[position]: position
+ for position in range(len(ordered_entry_indices))
+ }
+ peak_entry_order = None
+ if peak_value is not None and ordered_entry_indices:
+ peak_entry_order = min(
+ range(len(ordered_entry_indices)),
+ key=lambda position: abs(
+ (
+ _safe_float(
+ market_entries[ordered_entry_indices[position]].get("bucket_temp")
+ )
+ if _safe_float(
+ market_entries[ordered_entry_indices[position]].get("bucket_temp")
+ )
+ is not None
+ else peak_value
+ )
+ - peak_value
+ ),
+ )
+
current_reference_raw = _safe_float(
(scan_context or {}).get("current_max_so_far")
or (scan_context or {}).get("current_temp")
)
- def _row_from_entry(entry: Dict[str, Any], side: str) -> Optional[Dict[str, Any]]:
+ def _row_from_entry(
+ entry: Dict[str, Any],
+ side: str,
+ *,
+ entry_index: int,
+ ) -> Optional[Dict[str, Any]]:
model_event_probability = _clamp_probability(_safe_float(entry.get("model_event_probability")))
market_event_probability = _clamp_probability(_safe_float(entry.get("market_event_probability")))
ask = _clamp_probability(_safe_float(entry.get("yes_ask") if side == "yes" else entry.get("no_ask")))
@@ -2850,6 +2898,21 @@ class PolymarketReadOnlyLayer:
if target_threshold is not None and current_reference is not None
else None
)
+ entry_order = entry_order_map.get(entry_index)
+ peak_distance = None
+ is_peak_candidate = False
+ if entry_order is not None and peak_entry_order is not None:
+ peak_distance = abs(entry_order - peak_entry_order)
+ is_peak_candidate = peak_distance <= 1
+ peak_alignment_score = 0.0
+ if peak_distance is None:
+ peak_alignment_score = 0.35
+ elif peak_distance == 0:
+ peak_alignment_score = 1.0
+ elif peak_distance == 1:
+ peak_alignment_score = 0.8
+ else:
+ peak_alignment_score = max(0.0, 0.55 - 0.15 * float(peak_distance - 2))
temperature_direction = self._resolve_temperature_direction(
side=side,
market_direction=str(entry.get("market_direction") or "exact"),
@@ -2899,6 +2962,7 @@ class PolymarketReadOnlyLayer:
+ 0.20 * float(window_meta.get("score") or 0.0)
+ 0.10 * liquidity_score
+ 0.10 * price_usefulness_score
+ + 0.08 * peak_alignment_score
) - spread_penalty
market_slug = str(market.get("slug") or "").strip()
target_label = str(entry.get("target_label") or "").strip()
@@ -2974,6 +3038,11 @@ class PolymarketReadOnlyLayer:
"distribution_bias_score": distribution_bias_score,
"distribution_bias_available": distribution_bias["available"],
"distribution_preview": distribution_preview[:6],
+ "peak_probability": peak_probability,
+ "peak_value": peak_value,
+ "peak_distance": peak_distance,
+ "peak_alignment_score": peak_alignment_score,
+ "is_peak_candidate": is_peak_candidate,
"current_reference": current_reference,
"gap_to_target": gap_to_target,
"touch_distance": abs(gap_to_target) if gap_to_target is not None else None,
@@ -2991,9 +3060,9 @@ class PolymarketReadOnlyLayer:
}
preliminary_rows: List[Dict[str, Any]] = []
- for entry in market_entries:
- row_yes = _row_from_entry(entry, "yes")
- row_no = _row_from_entry(entry, "no")
+ for entry_index, entry in enumerate(market_entries):
+ row_yes = _row_from_entry(entry, "yes", entry_index=entry_index)
+ row_no = _row_from_entry(entry, "no", entry_index=entry_index)
if row_yes:
preliminary_rows.append(row_yes)
if row_no:
@@ -3041,9 +3110,9 @@ class PolymarketReadOnlyLayer:
entry["spread"] = max(0.0, float(entry["yes_ask"]) - float(entry["yes_bid"]))
final_rows: List[Dict[str, Any]] = []
- for entry in market_entries:
+ for entry_index, entry in enumerate(market_entries):
for side in ("yes", "no"):
- row = _row_from_entry(entry, side)
+ row = _row_from_entry(entry, side, entry_index=entry_index)
if row:
final_rows.append(row)
@@ -3074,7 +3143,10 @@ class PolymarketReadOnlyLayer:
def _passes_mode_filters(row: Dict[str, Any]) -> bool:
scan_mode = filters["scan_mode"]
if scan_mode == "tradable":
- return float(row.get("window_score") or 0.0) >= 0.65
+ return (
+ float(row.get("window_score") or 0.0) >= 0.65
+ and bool(row.get("is_peak_candidate"))
+ )
if scan_mode == "early":
return str(row.get("window_phase") or "") in {"tomorrow", "week_ahead", "early_today"}
if scan_mode == "touch":
@@ -3095,6 +3167,7 @@ class PolymarketReadOnlyLayer:
]
filtered_rows.sort(
key=lambda row: (
+ 1.0 if bool(row.get("is_peak_candidate")) else 0.0,
float(row.get("final_score") or 0.0),
float(row.get("edge_percent") or 0.0),
),
diff --git a/tests/test_polymarket_readonly.py b/tests/test_polymarket_readonly.py
index 07b862bf..388cf006 100644
--- a/tests/test_polymarket_readonly.py
+++ b/tests/test_polymarket_readonly.py
@@ -675,6 +675,39 @@ def test_distribution_scan_hard_filters_block_unusable_extreme_quotes():
assert scan["rows"] == []
+def test_distribution_scan_tradable_prefers_peak_bucket_and_adjacent_only():
+ layer, markets = _build_scan_test_layer()
+
+ scan = layer._build_distribution_scan_pack(
+ city_key="wellington",
+ target_date="2026-04-24",
+ primary_market=markets[0],
+ probability_distribution=[
+ {"value": 14, "probability": 20},
+ {"value": 15, "probability": 48},
+ {"value": 16, "probability": 24},
+ {"value": 17, "probability": 8},
+ ],
+ temp_symbol="°C",
+ scan_context={
+ "local_date": "2026-04-24",
+ "local_time": "13:10",
+ "peak": {"first_h": 14, "last_h": 16},
+ "current_max_so_far": 13.6,
+ "current_temp": 13.2,
+ "trend": {"recent": []},
+ "network_lead_signal": {},
+ },
+ scan_filters={"limit": 10, "scan_mode": "tradable", "min_edge_pct": 2},
+ )
+
+ assert scan["signal_status"] == "ready"
+ assert scan["primary_signal"]["is_peak_candidate"] is True
+ assert scan["primary_signal"]["peak_distance"] in {0, 1}
+ assert all(bool(row.get("is_peak_candidate")) for row in scan["rows"])
+ assert all((row.get("peak_distance") or 0) <= 1 for row in scan["rows"])
+
+
def test_batch_token_market_data_falls_back_to_single_fetch_when_batch_fails():
layer = PolymarketReadOnlyLayer()
layer._clob_post = lambda *_args, **_kwargs: None
diff --git a/tests/test_web_observability.py b/tests/test_web_observability.py
index 8f18a6f7..b3aa4d2f 100644
--- a/tests/test_web_observability.py
+++ b/tests/test_web_observability.py
@@ -3,6 +3,7 @@ from fastapi.testclient import TestClient
from web.app import app
import web.routes as routes
+import web.scan_terminal_service as scan_terminal_service
from web.scan_terminal_service import _scan_terminal_cache_key
from src.database.db_manager import DBManager
from src.database.runtime_state import TruthRecordRepository, TrainingFeatureRecordRepository
@@ -258,7 +259,66 @@ def test_ops_truth_history_returns_filtered_rows(monkeypatch):
assert "items" in payload
assert payload["filters"]["city"] == "taipei"
assert payload["items"][0]["city"] == "taipei"
- assert payload["items"][0]["settlement_station_code"] == "RCSS"
+
+
+def test_scan_terminal_service_returns_stale_payload_after_failed_refresh(monkeypatch):
+ filters = {"scan_mode": "tradable", "limit": 5}
+ normalized_filters = scan_terminal_service._normalize_scan_terminal_filters(filters)
+ scan_terminal_service._SCAN_TERMINAL_CACHE.clear()
+
+ monkeypatch.setattr(
+ scan_terminal_service,
+ "_scan_city_terminal_rows",
+ lambda *_args, **_kwargs: {
+ "city": "taipei",
+ "rows": [
+ {
+ "id": "row-1",
+ "market_key": "market-1",
+ "edge_percent": 12.4,
+ "final_score": 83.0,
+ "volume": 2000,
+ }
+ ],
+ "candidate_total": 1,
+ "primary_scores": [83.0],
+ },
+ )
+
+ ready = scan_terminal_service.build_scan_terminal_payload(filters, force_refresh=True)
+ assert ready["status"] == "ready"
+ assert ready["rows"][0]["id"] == "row-1"
+
+ def _explode(*_args, **_kwargs):
+ raise RuntimeError("upstream 504")
+
+ monkeypatch.setattr(scan_terminal_service, "_scan_city_terminal_rows", _explode)
+
+ stale = scan_terminal_service.build_scan_terminal_payload(filters, force_refresh=True)
+
+ assert stale["status"] == "stale"
+ assert stale["stale"] is True
+ assert stale["rows"][0]["id"] == "row-1"
+ assert stale["filters"] == normalized_filters
+ assert stale["stale_reason"] == "upstream 504"
+
+
+def test_scan_terminal_service_returns_failed_without_success_snapshot(monkeypatch):
+ filters = {"scan_mode": "tradable", "limit": 5}
+ scan_terminal_service._SCAN_TERMINAL_CACHE.clear()
+
+ def _explode(*_args, **_kwargs):
+ raise RuntimeError("network down")
+
+ monkeypatch.setattr(scan_terminal_service, "_scan_city_terminal_rows", _explode)
+
+ failed = scan_terminal_service.build_scan_terminal_payload(filters, force_refresh=True)
+
+ assert failed["status"] == "failed"
+ assert failed["stale"] is False
+ assert failed["rows"] == []
+ assert failed["summary"]["candidate_total"] == 0
+ assert failed["stale_reason"] == "network down"
def test_scan_terminal_endpoint_forwards_filters(monkeypatch):
diff --git a/web/scan_terminal_service.py b/web/scan_terminal_service.py
index fd5be9b5..027789b0 100644
--- a/web/scan_terminal_service.py
+++ b/web/scan_terminal_service.py
@@ -4,6 +4,7 @@ import json
import os
import threading
import time
+import hashlib
from concurrent.futures import ThreadPoolExecutor, as_completed
from datetime import datetime, timedelta
from typing import Any, Dict, List, Optional
@@ -99,18 +100,125 @@ def _get_cached_scan_terminal_payload(
return dict(payload)
+def _get_scan_terminal_cache_entry(filters: Dict[str, Any]) -> Optional[Dict[str, Any]]:
+ cache_key = _scan_terminal_cache_key(filters)
+ with _SCAN_TERMINAL_CACHE_LOCK:
+ cached = _SCAN_TERMINAL_CACHE.get(cache_key)
+ if not isinstance(cached, dict):
+ return None
+ return dict(cached)
+
+
+def _build_scan_terminal_snapshot_id(
+ filters: Dict[str, Any],
+ rows: List[Dict[str, Any]],
+ summary: Dict[str, Any],
+ top_signal: Optional[Dict[str, Any]],
+) -> str:
+ seed_payload = {
+ "filters": filters,
+ "summary": {
+ "candidate_total": summary.get("candidate_total"),
+ "tradable_market_count": summary.get("tradable_market_count"),
+ "avg_edge_percent": summary.get("avg_edge_percent"),
+ },
+ "top_signal": {
+ "id": (top_signal or {}).get("id"),
+ "edge_percent": (top_signal or {}).get("edge_percent"),
+ "final_score": (top_signal or {}).get("final_score"),
+ },
+ "rows": [
+ {
+ "id": row.get("id"),
+ "edge_percent": row.get("edge_percent"),
+ "final_score": row.get("final_score"),
+ }
+ for row in rows[:10]
+ ],
+ }
+ digest = hashlib.md5(
+ json.dumps(seed_payload, ensure_ascii=True, sort_keys=True).encode("utf-8")
+ ).hexdigest()
+ return f"scan-{digest[:10]}"
+
+
def _set_cached_scan_terminal_payload(
filters: Dict[str, Any],
payload: Dict[str, Any],
) -> None:
cache_key = _scan_terminal_cache_key(filters)
+ existing = _get_scan_terminal_cache_entry(filters) or {}
with _SCAN_TERMINAL_CACHE_LOCK:
_SCAN_TERMINAL_CACHE[cache_key] = {
"t": time.time(),
"payload": dict(payload),
+ "success_t": time.time(),
+ "success_payload": dict(payload),
+ "last_error": existing.get("last_error"),
+ "last_failed_at": existing.get("last_failed_at"),
}
+def _set_scan_terminal_failure_state(
+ filters: Dict[str, Any],
+ *,
+ error_message: str,
+) -> None:
+ cache_key = _scan_terminal_cache_key(filters)
+ with _SCAN_TERMINAL_CACHE_LOCK:
+ existing = _SCAN_TERMINAL_CACHE.get(cache_key) or {}
+ existing["last_error"] = error_message
+ existing["last_failed_at"] = datetime.utcnow().isoformat() + "Z"
+ _SCAN_TERMINAL_CACHE[cache_key] = existing
+
+
+def _build_stale_scan_terminal_payload(
+ *,
+ filters: Dict[str, Any],
+ success_payload: Dict[str, Any],
+ error_message: str,
+ failed_at: Optional[str],
+) -> Dict[str, Any]:
+ payload = dict(success_payload)
+ payload["status"] = "stale"
+ payload["stale"] = True
+ payload["stale_reason"] = error_message
+ payload["last_success_at"] = success_payload.get("generated_at")
+ payload["last_failed_at"] = failed_at
+ payload["filters"] = filters
+ return payload
+
+
+def _build_failed_scan_terminal_payload(
+ *,
+ filters: Dict[str, Any],
+ error_message: str,
+ failed_at: Optional[str] = None,
+) -> Dict[str, Any]:
+ return {
+ "generated_at": datetime.utcnow().isoformat() + "Z",
+ "snapshot_id": None,
+ "status": "failed",
+ "stale": False,
+ "stale_reason": error_message,
+ "last_success_at": None,
+ "last_failed_at": failed_at or (datetime.utcnow().isoformat() + "Z"),
+ "filters": filters,
+ "summary": {
+ "recommended_count": 0,
+ "visible_count": 0,
+ "candidate_total": 0,
+ "avg_edge_percent": None,
+ "avg_primary_confidence": None,
+ "tradable_market_count": 0,
+ "total_volume": 0.0,
+ "resolved_market_type": "maxtemp",
+ },
+ "top_signal": None,
+ "rows": [],
+ }
+
+
def _resolve_time_range_dates(data: Dict[str, Any], time_range: str) -> List[str]:
local_date = str(data.get("local_date") or "").strip()
multi_model_daily = data.get("multi_model_daily") or {}
@@ -265,83 +373,105 @@ def build_scan_terminal_payload(
cached = _get_cached_scan_terminal_payload(filters)
if cached is not None:
return cached
+ cached_entry = _get_scan_terminal_cache_entry(filters) or {}
- city_names = list(CITIES.keys())
- max_workers = max(1, min(6, len(city_names)))
- city_results: List[Dict[str, Any]] = []
+ try:
+ city_names = list(CITIES.keys())
+ max_workers = max(1, min(4, len(city_names)))
+ city_results: List[Dict[str, Any]] = []
+ failed_cities: List[str] = []
+ failed_reasons: List[str] = []
- with ThreadPoolExecutor(max_workers=max_workers) as executor:
- future_map = {
- executor.submit(
- _scan_city_terminal_rows,
- city_name,
- filters,
- force_refresh=force_refresh,
- ): city_name
- for city_name in city_names
- }
- for future in as_completed(future_map):
- city_name = future_map[future]
- try:
- city_results.append(future.result())
- except Exception as exc:
- logger.warning("scan terminal city failed city={}: {}", city_name, exc)
-
- primary_rows: List[Dict[str, Any]] = []
- primary_scores: List[float] = []
- candidate_total = 0
-
- for result in city_results:
- candidate_total += int(result.get("candidate_total") or 0)
- primary_rows.extend(result.get("rows") or [])
- primary_scores.extend(result.get("primary_scores") or [])
-
- primary_rows.sort(
- key=lambda row: (
- float(row.get("final_score") or 0.0),
- float(row.get("edge_percent") or 0.0),
- ),
- reverse=True,
- )
-
- ranked_rows: List[Dict[str, Any]] = []
- for index, row in enumerate(primary_rows[: filters["limit"]], start=1):
- ranked_rows.append(
- {
- **row,
- "rank": index,
+ with ThreadPoolExecutor(max_workers=max_workers) as executor:
+ future_map = {
+ executor.submit(
+ _scan_city_terminal_rows,
+ city_name,
+ filters,
+ force_refresh=force_refresh,
+ ): city_name
+ for city_name in city_names
}
+ for future in as_completed(future_map):
+ city_name = future_map[future]
+ try:
+ city_results.append(future.result())
+ except Exception as exc:
+ failed_cities.append(city_name)
+ failed_reasons.append(str(exc))
+ logger.warning("scan terminal city failed city={}: {}", city_name, exc)
+
+ if city_names and len(failed_cities) >= len(city_names):
+ error_message = failed_reasons[0] if failed_reasons else "all city market scans failed"
+ _set_scan_terminal_failure_state(filters, error_message=error_message)
+ failed_entry = _get_scan_terminal_cache_entry(filters) or {}
+ success_payload = failed_entry.get("success_payload")
+ failed_at = failed_entry.get("last_failed_at")
+ if isinstance(success_payload, dict) and success_payload:
+ return _build_stale_scan_terminal_payload(
+ filters=filters,
+ success_payload=success_payload,
+ error_message=error_message,
+ failed_at=failed_at,
+ )
+ return _build_failed_scan_terminal_payload(
+ filters=filters,
+ error_message=error_message,
+ failed_at=failed_at,
+ )
+
+ primary_rows: List[Dict[str, Any]] = []
+ primary_scores: List[float] = []
+ candidate_total = 0
+
+ for result in city_results:
+ candidate_total += int(result.get("candidate_total") or 0)
+ primary_rows.extend(result.get("rows") or [])
+ primary_scores.extend(result.get("primary_scores") or [])
+
+ primary_rows.sort(
+ key=lambda row: (
+ float(row.get("final_score") or 0.0),
+ float(row.get("edge_percent") or 0.0),
+ ),
+ reverse=True,
)
- unique_market_volume: Dict[str, float] = {}
- for row in primary_rows:
- market_key = str(row.get("market_key") or row.get("id") or "").strip()
- if not market_key:
- continue
- unique_market_volume[market_key] = max(
- unique_market_volume.get(market_key, 0.0),
- float(row.get("volume") or 0.0),
- )
+ ranked_rows: List[Dict[str, Any]] = []
+ for index, row in enumerate(primary_rows[: filters["limit"]], start=1):
+ ranked_rows.append(
+ {
+ **row,
+ "rank": index,
+ }
+ )
- avg_edge = None
- if primary_rows:
- edge_values = [
- float(row.get("edge_percent") or 0.0)
- for row in primary_rows
- if _safe_float(row.get("edge_percent")) is not None
- ]
- if edge_values:
- avg_edge = sum(edge_values) / len(edge_values)
+ unique_market_volume: Dict[str, float] = {}
+ for row in primary_rows:
+ market_key = str(row.get("market_key") or row.get("id") or "").strip()
+ if not market_key:
+ continue
+ unique_market_volume[market_key] = max(
+ unique_market_volume.get(market_key, 0.0),
+ float(row.get("volume") or 0.0),
+ )
- avg_confidence = None
- if primary_scores:
- avg_confidence = sum(primary_scores) / len(primary_scores)
+ avg_edge = None
+ if primary_rows:
+ edge_values = [
+ float(row.get("edge_percent") or 0.0)
+ for row in primary_rows
+ if _safe_float(row.get("edge_percent")) is not None
+ ]
+ if edge_values:
+ avg_edge = sum(edge_values) / len(edge_values)
- top_signal = ranked_rows[0] if ranked_rows else None
- payload = {
- "generated_at": datetime.utcnow().isoformat() + "Z",
- "filters": filters,
- "summary": {
+ avg_confidence = None
+ if primary_scores:
+ avg_confidence = sum(primary_scores) / len(primary_scores)
+
+ top_signal = ranked_rows[0] if ranked_rows else None
+ summary = {
"recommended_count": len(primary_rows),
"visible_count": len(ranked_rows),
"candidate_total": candidate_total,
@@ -350,10 +480,43 @@ def build_scan_terminal_payload(
"tradable_market_count": len(unique_market_volume),
"total_volume": sum(unique_market_volume.values()),
"resolved_market_type": "maxtemp",
- },
- "top_signal": top_signal,
- "rows": ranked_rows,
- }
+ }
+ payload = {
+ "generated_at": datetime.utcnow().isoformat() + "Z",
+ "filters": filters,
+ "summary": summary,
+ "top_signal": top_signal,
+ "rows": ranked_rows,
+ "status": "ready",
+ "stale": False,
+ "stale_reason": None,
+ "last_success_at": None,
+ "last_failed_at": None,
+ }
+ payload["snapshot_id"] = _build_scan_terminal_snapshot_id(
+ filters,
+ ranked_rows,
+ summary,
+ top_signal,
+ )
- _set_cached_scan_terminal_payload(filters, payload)
- return payload
+ _set_cached_scan_terminal_payload(filters, payload)
+ return payload
+ except Exception as exc:
+ error_message = str(exc)
+ logger.exception("scan terminal payload build failed: {}", error_message)
+ _set_scan_terminal_failure_state(filters, error_message=error_message)
+ success_payload = cached_entry.get("success_payload")
+ failed_at = _get_scan_terminal_cache_entry(filters).get("last_failed_at") if _get_scan_terminal_cache_entry(filters) else None
+ if isinstance(success_payload, dict) and success_payload:
+ return _build_stale_scan_terminal_payload(
+ filters=filters,
+ success_payload=success_payload,
+ error_message=error_message,
+ failed_at=failed_at,
+ )
+ return _build_failed_scan_terminal_payload(
+ filters=filters,
+ error_message=error_message,
+ failed_at=failed_at,
+ )
+ {isEn ? "Market Scan Terminal" : "市场扫描台"}
+
+ {loading
+ ? isEn
+ ? "Refreshing current market snapshot"
+ : "正在刷新当前市场快照"
+ : terminalData?.stale
+ ? isEn
+ ? "Showing the last successful snapshot"
+ : "当前显示上次成功快照"
+ : isEn
+ ? "Read-only market scan with peak-first main signal"
+ : "只读市场扫描，主信号按 EMOS 主峰优先"}
+
{isEn ? "Tradable Opportunities" : "可交易机会"}
-- {isEn - ? "Use EMOS distribution, live order book, and timing windows to isolate the one actionable signal." - : "基于当前时间、实况数据和模型预测，筛选出最具交易价值的市场。"} -
-
-
- {error ? (
+ {scanStatus === "failed" && !terminalData ? (
- {isEn
- ? resolvedView === "calendar"
- ? "Sort: Date"
- : resolvedView === "map"
- ? "Sort: City Map"
- : "Sort: Your Time"
- : resolvedView === "calendar"
- ? "排序：日期"
- : resolvedView === "map"
- ? "排序：地图"
- : "排序：用户时区时间"}
-
-
+
+ {terminalData?.stale ? (
+
+ {isEn ? "Delayed snapshot" : "延迟快照"}
+
+ ) : null}
+ {loading ? (
+
+ {isEn ? "Refreshing" : "刷新中"}
+
+ ) : null}
{isEn ? "Scan failed" : "扫描失败"}
- {error}
+ {staleReason}