Merge pull request #346 from QuantStrategyLab/fix/console-health-truth

fix(console): align health status and research freshness

Author: Pigbibi

tests/strategy_switch_worker_validation.mjs

@@ -2082,6 +2082,9 @@ assert.match(healthReadPayload.strategies[0].source_revision, /^https:\/\//);
 assert.deepEqual(healthReadPayload.errors, ["safe_notice"]);
 assert.ok(indexHtml.includes('id="health-count-critical"'));
 assert.ok(indexHtml.includes('data-i18n="healthCritical"'));
+assert.ok(indexHtml.includes('healthAttentionNotice'));
+assert.ok(indexHtml.includes('formatAsOfDate('));
+assert.ok(indexHtml.includes('m0ResearchBoard: "外部研究记录"'));
 
 healthPayload.generated_at = new Date().toISOString();
 healthPayload.computed_at = "2020-01-01T00:00:00.000Z";
@@ -2291,6 +2294,32 @@ const staleControlRead = await worker.fetch(
 );
 assert.equal((await staleControlRead.json()).data_status, "stale");
 
+const weekendResearchSnapshot = {
+  schema_version: "qsl_control_plane_source_snapshot.v1",
+  source_id: "uesp.weekend_research",
+  generated_at: "2026-08-29T09:21:00.000Z",
+  computed_at: "2026-08-29T09:21:00.000Z",
+  data_status: "ready",
+  candidates: [],
+  errors: [],
+};
+assert.equal(
+  __test.controlPlaneResearchSnapshotFreshness(
+    weekendResearchSnapshot,
+    300,
+    Date.parse("2026-08-31T16:40:00.000Z"),
+  ).data_status,
+  "ready",
+);
+assert.equal(
+  __test.controlPlaneResearchSnapshotFreshness(
+    weekendResearchSnapshot,
+    300,
+    Date.parse("2026-09-01T08:00:00.000Z"),
+  ).data_status,
+  "stale",
+);
+
 const controlSourcePayload = {
   schema_version: "qsl_control_plane_source_snapshot.v1",
   source_id: "uesp.tqqq_daily_research",

web/strategy-switch-console/app.js

@@ -940,19 +940,19 @@
         runtimeTargetLifecycleReasonRuntimeGuard: "运行监测需要复核",
         runtimeTargetLifecycleReasonHeartbeat: "执行心跳需要复核",
         runtimeTargetLifecycleReasonUnavailable: "监测数据不可用",
-        m0ResearchBoard: "市场研究",
-        m0ResearchLoginNotice: "登录后查看市场研究和观察记录。",
-        m0ResearchStaleNotice: "研究内容更新延迟，仅供历史参考。",
-        m0ResearchUnavailableNotice: "暂时没有可用的市场研究。",
-        m0ResearchUpstreamNotice: "部分研究内容暂不可用，请稍后重试。",
-        m0ResearchEmpty: "当前没有可展示的市场研究。",
+        m0ResearchBoard: "外部研究记录",
+        m0ResearchLoginNotice: "登录后查看外部研究记录。",
+        m0ResearchStaleNotice: "外部研究更新延迟，仅供历史参考。",
+        m0ResearchUnavailableNotice: "暂时没有可用的外部研究记录。",
+        m0ResearchUpstreamNotice: "部分外部研究暂不可用，请稍后重试。",
+        m0ResearchEmpty: "当前没有可展示的外部研究记录。",
         m0ResearchMore: "显示前 {count} 条研究观察。",
         m0ResearchMeta: "{kind} · 查看于：{viewed}",
         m0ResearchStateFreshness: "状态：{state} · 新鲜度：{freshness}",
         m0ResearchHorizons: "主要观察期：{primary} · 适用观察期：{suitable}",
         m0ResearchEvidence: "置信：{confidence} · 风格：{style} · 资料摘要：{digest}",
         m0ResearchConsistency: "当前周期分歧：{conflict} · 历史失效漂移：{drift}",
-        m0ResearchNoOrder: "查看当前研究摘要。",
+        m0ResearchNoOrder: "外部研究不影响当前策略运行。",
         adaptiveSelectionBoard: "系统建议",
         adaptiveSelectionLoginNotice: "登录后查看系统建议。",
         adaptiveSelectionStaleNotice: "建议更新延迟，仅供历史参考。",
@@ -994,6 +994,7 @@
         healthUnavailableNotice: "暂时无法读取策略状态，请稍后刷新。",
         healthUpstreamNotice: "部分策略状态暂不可用，请稍后重试。",
         healthNormalNotice: "当前没有需要关注的运行问题。",
+        healthAttentionNotice: "有 {critical} 项严重、{review} 项需要复核、{watch} 项观察；系统正在持续监测。",
         healthEmpty: "当前分类下没有策略。",
         healthStatusHealthy: "健康",
         healthStatusWatch: "观察",
@@ -1007,7 +1008,7 @@
         healthRecommendationWatch: "系统正在继续观察。",
         healthRecommendationReview: "请查看诊断详情，等待系统复核完成。",
         healthRecommendationCritical: "请查看诊断详情，并暂缓相关变更。",
-        healthDetail: "最近检查：{date}",
+        healthDetail: "数据截至：{date}",
         healthScoreLabel: "健康度",
         diagnosticDetails: "查看诊断详情",
         diagnosticDetailsHint: "仅在排查问题或查看研究记录时使用。",
@@ -1331,19 +1332,19 @@
         runtimeTargetLifecycleReasonRuntimeGuard: "runtime guard needs review",
         runtimeTargetLifecycleReasonHeartbeat: "execution heartbeat needs review",
         runtimeTargetLifecycleReasonUnavailable: "monitoring data unavailable",
-        m0ResearchBoard: "Market research",
-        m0ResearchLoginNotice: "Sign in to see market research and observations.",
-        m0ResearchStaleNotice: "Research is delayed and is provided for historical context only.",
-        m0ResearchUnavailableNotice: "Market research is temporarily unavailable.",
-        m0ResearchUpstreamNotice: "Some research content is unavailable. Please retry later.",
-        m0ResearchEmpty: "There is no market research to display.",
+        m0ResearchBoard: "External research records",
+        m0ResearchLoginNotice: "Sign in to see external research records.",
+        m0ResearchStaleNotice: "External research is delayed and is provided for historical context only.",
+        m0ResearchUnavailableNotice: "External research records are temporarily unavailable.",
+        m0ResearchUpstreamNotice: "Some external research records are unavailable. Please retry later.",
+        m0ResearchEmpty: "There are no external research records to display.",
         m0ResearchMore: "Showing the first {count} research observations.",
         m0ResearchMeta: "{kind} · viewed {viewed}",
         m0ResearchStateFreshness: "State: {state} · freshness: {freshness}",
         m0ResearchHorizons: "Primary horizon: {primary} · suitable horizons: {suitable}",
         m0ResearchEvidence: "Confidence: {confidence} · style: {style} · source digest: {digest}",
         m0ResearchConsistency: "Current horizon conflict: {conflict} · historical stale drift: {drift}",
-        m0ResearchNoOrder: "View the current research summary.",
+        m0ResearchNoOrder: "External research does not affect current strategy operation.",
         adaptiveSelectionBoard: "System suggestions",
         adaptiveSelectionLoginNotice: "Sign in to see system suggestions.",
         adaptiveSelectionStaleNotice: "Suggestions are delayed and are provided for historical context only.",
@@ -1385,6 +1386,7 @@
         healthUnavailableNotice: "Strategy status is temporarily unavailable. Refresh later.",
         healthUpstreamNotice: "Some strategy status is unavailable. Retry later.",
         healthNormalNotice: "There are no runtime issues that need attention.",
+        healthAttentionNotice: "{critical} critical, {review} to review, and {watch} under observation. Monitoring continues.",
         healthEmpty: "There are no strategies in this category.",
         healthStatusHealthy: "Healthy",
         healthStatusWatch: "Watch",
@@ -1398,7 +1400,7 @@
         healthRecommendationWatch: "The system is continuing to monitor.",
         healthRecommendationReview: "View diagnostic details while the system completes its review.",
         healthRecommendationCritical: "View diagnostic details and hold related changes for now.",
-        healthDetail: "Last checked: {date}",
+        healthDetail: "Data as of: {date}",
         healthScoreLabel: "Health",
         diagnosticDetails: "View diagnostic details",
         diagnosticDetailsHint: "Use this only to investigate an issue or review research records.",
@@ -1747,6 +1749,17 @@
       }).format(parsed);
     }
 
+    function formatAsOfDate(value) {
+      if (typeof value === "string" && /^\d{4}-\d{2}-\d{2}$/.test(value)) {
+        const parsed = new Date(`${value}T00:00:00.000Z`);
+        return new Intl.DateTimeFormat(locale(), {
+          dateStyle: "medium",
+          timeZone: "UTC",
+        }).format(parsed);
+      }
+      return formatDateTime(value);
+    }
+
     function localizedExternalText(value, fallback) {
       const text = typeof value === "string" ? value.trim() : "";
       if (!text) return fallback;
@@ -4832,6 +4845,14 @@
     function renderHealth() {
       const payload = state.health.payload;
       const summary = payload.summary || {};
+      const healthCount = (status) => Math.max(
+        Number(summary[status]) || 0,
+        payload.strategies.filter((item) => item.status === status).length,
+      );
+      const criticalCount = healthCount("critical");
+      const reviewCount = healthCount("review");
+      const watchCount = healthCount("watch");
+      const hasAttention = criticalCount + reviewCount + watchCount > 0;
       const summaryAvailable = state.auth.allowed && payload.data_status !== "unavailable";
       const summaryCount = (value) => (summaryAvailable ? String(Number(value) || 0) : "—");
       const statusText = payload.data_status === "ready"
@@ -4854,6 +4875,11 @@
         notice.textContent = t("healthStaleNotice");
       } else if (payload.data_status !== "ready") {
         notice.textContent = t("healthUnavailableNotice");
+      } else if (hasAttention) {
+        notice.textContent = t("healthAttentionNotice")
+          .replace("{critical}", String(criticalCount))
+          .replace("{review}", String(reviewCount))
+          .replace("{watch}", String(watchCount));
       } else if (payload.errors?.length) {
         notice.textContent = t("healthUpstreamNotice");
       } else {
@@ -4889,7 +4915,7 @@
         const detail = document.createElement("div");
         detail.className = "health-card__meta";
         detail.textContent = t("healthDetail")
-          .replace("{date}", formatDateTime(item.as_of));
+          .replace("{date}", formatAsOfDate(item.as_of));
         main.append(meta, title, reason, detail);
         const scoreBlock = document.createElement("div");
         scoreBlock.className = "health-card__score";

web/strategy-switch-console/app_js.js

@@ -60,9 +60,13 @@ const CONTROL_PLANE_ATTENTION_STATUSES = ["research_only", "attention_required",
 const CONTROL_PLANE_MAX_SOURCES = 100;
 const CONTROL_PLANE_MAX_BODY_BYTES = 256 * 1024;
 // The current source is a once-per-trading-day P1/P3 lane, rather than a live
-// execution heartbeat. A 36-hour boundary tolerates weekends and a delayed
-// scheduled run without presenting a daily snapshot as permanently stale.
+// execution heartbeat. Freshness therefore preserves the normal TTL, but also
+// waits for the next scheduled research window across the weekend before it
+// calls an otherwise usable Friday/Saturday snapshot stale.
 const CONTROL_PLANE_DEFAULT_STALE_TTL_SECONDS = 36 * 60 * 60;
+const CONTROL_PLANE_RESEARCH_SCHEDULE_UTC_DAYS = new Set([2, 3, 4, 5, 6]);
+const CONTROL_PLANE_RESEARCH_SCHEDULE_UTC_HOUR = 3;
+const CONTROL_PLANE_RESEARCH_DELIVERY_GRACE_MS = 4 * 60 * 60 * 1000;
 const CONTROL_PLANE_CANDIDATE_KINDS = ["individual", "portfolio", "plugin"];
 const CONTROL_PLANE_STAGES = ["P1", "P2", "P3", "P4", "P5", "P6"];
 const CONTROL_PLANE_LIFECYCLE_STATUSES = [
@@ -1722,19 +1726,12 @@ async function currentControlPlanePayload(env) {
     return emptyControlPlanePayload("snapshot_invalid");
   }
 
-  const ttlSeconds = controlPlaneStaleTtlSeconds(env);
-  const freshnessTimestamps = [snapshot.generated_at, snapshot.computed_at]
-    .filter(Boolean)
-    .map((value) => Date.parse(value));
-  const freshnessAt = freshnessTimestamps.length ? Math.min(...freshnessTimestamps) : Number.NaN;
-  const now = Date.now();
-  const futureBeyondClockSkew = Number.isFinite(freshnessAt) && freshnessAt > now + 5 * 60 * 1000;
-  const ageSeconds = futureBeyondClockSkew
-    ? Number.POSITIVE_INFINITY
-    : Number.isFinite(freshnessAt)
-      ? Math.max(0, (now - freshnessAt) / 1000)
-      : Number.POSITIVE_INFINITY;
-  if (snapshot.data_status === "ready" && ageSeconds > ttlSeconds) snapshot.data_status = "stale";
+  const freshness = controlPlaneResearchSnapshotFreshness(
+    snapshot,
+    controlPlaneStaleTtlSeconds(env),
+    Date.now(),
+  );
+  snapshot.data_status = freshness.data_status;
   return snapshot;
 }
 
@@ -2839,7 +2836,7 @@ async function aggregateControlPlaneSources(env) {
   let hasStaleSource = false;
 
   for (const source of sources) {
-    const sourceFreshness = controlPlaneSnapshotFreshness(source, ttlSeconds, now);
+    const sourceFreshness = controlPlaneResearchSnapshotFreshness(source, ttlSeconds, now);
     if (source.generated_at) timestamps.push(source.generated_at);
     if (source.computed_at) timestamps.push(source.computed_at);
     if (sourceFreshness.data_status === "ready") hasReadySource = true;
@@ -3209,6 +3206,45 @@ function controlPlaneSnapshotFreshness(snapshot, ttlSeconds, now) {
   return { data_status: dataStatus, age_seconds: Number.isFinite(ageSeconds) ? ageSeconds : null };
 }
 
+function controlPlaneResearchSnapshotFreshness(snapshot, ttlSeconds, now) {
+  if (snapshot.data_status !== "ready") {
+    return controlPlaneSnapshotFreshness(snapshot, ttlSeconds, now);
+  }
+  const timestamps = [snapshot.generated_at, snapshot.computed_at]
+    .filter(Boolean)
+    .map((value) => Date.parse(value));
+  const freshnessAt = timestamps.length ? Math.min(...timestamps) : Number.NaN;
+  const futureBeyondClockSkew = Number.isFinite(freshnessAt) && freshnessAt > now + 5 * 60 * 1000;
+  const ageSeconds = futureBeyondClockSkew
+    ? Number.POSITIVE_INFINITY
+    : Number.isFinite(freshnessAt)
+      ? Math.max(0, Math.round((now - freshnessAt) / 1000))
+      : Number.POSITIVE_INFINITY;
+  if (!Number.isFinite(freshnessAt) || futureBeyondClockSkew) {
+    return { data_status: "stale", age_seconds: null };
+  }
+
+  const ttlDeadline = freshnessAt + ttlSeconds * 1000;
+  const nextScheduledRefresh = nextControlPlaneResearchScheduleAfter(freshnessAt);
+  const scheduledDeadline = nextScheduledRefresh + CONTROL_PLANE_RESEARCH_DELIVERY_GRACE_MS;
+  const staleDeadline = Math.max(ttlDeadline, scheduledDeadline);
+  return {
+    data_status: now > staleDeadline ? "stale" : "ready",
+    age_seconds: ageSeconds,
+  };
+}
+
+function nextControlPlaneResearchScheduleAfter(freshnessAt) {
+  const scheduled = new Date(freshnessAt);
+  scheduled.setUTCMinutes(0, 0, 0);
+  scheduled.setUTCHours(CONTROL_PLANE_RESEARCH_SCHEDULE_UTC_HOUR);
+  if (scheduled.getTime() <= freshnessAt) scheduled.setUTCDate(scheduled.getUTCDate() + 1);
+  while (!CONTROL_PLANE_RESEARCH_SCHEDULE_UTC_DAYS.has(scheduled.getUTCDay())) {
+    scheduled.setUTCDate(scheduled.getUTCDate() + 1);
+  }
+  return scheduled.getTime();
+}
+
 // A recently published source must not be able to re-advertise an old
 // reconciliation candidate as current.  The private controller independently
 // verifies raw receipts, but the human console also fails closed here.
@@ -7197,6 +7233,7 @@ export const __test = {
   emptyStrategyHealthPayload,
   normalizeControlPlaneSnapshot,
   normalizeControlPlaneSourceSnapshot,
+  controlPlaneResearchSnapshotFreshness,
   emptyControlPlanePayload,
   normalizeAdaptiveSelectionSourceSnapshot,
   calculateAdaptiveSelectionDecisionDigest,