枠の推移で、返ってこなくなった窓と同名の窓を見分けられるようにする

相手が窓の id を変えると、古い id の系列はそこで止まる。止まった系列を
生きている系列と同じ顔で並べると、最後の点がそのまま現在値に見えるうえ、
並び順が上がり幅の順なので、途中で 0 に落ちた壊れた系列ほど上に来る。
provider ごとの最新の観測より古い系列に印を付け、末尾へ回す。

窓の名前は相手が決めるので、別勘定の窓が同じ名前を名乗ることがある。
名前だけでは見分けられないので、ぶつかった名前には id を添える。
片方だけ素のままにすると、どちらが素かが相手の並べ方次第になるため、
ぶつかったものはすべて添える。

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>

Author: claude

CLAUDE.md

@@ -1294,6 +1294,15 @@ GeoNames 全世界地名辞典 = `geonames`(いずれも 348 言語版・195 か
       使用率が交互に跳ね上がったり 0 に戻ったりして見える。
       **ぶつかったものは全部付け替える** —— 片方に元の名前を残すと、どちらが残るかが
       相手の並べ方次第になり、次に聞いたときに入れ替わる
+    - **同じ名前の窓は id を添えて呼び分ける**(`usage.arranged`)。名前は長さから
+      作るので、同じ長さの窓が 2 つあると見分けが付かない(実測: codex は 7 日の窓を
+      2 つ返す。別勘定で値も違う)。**ぶつかったものは全部添える** ——
+      片方だけ素のままにすると、どちらが素かが相手の並べ方次第になる
+    - **相手が返さなくなった窓は下へ回す**(`quota_trail` の `stale`)。名前が変われば
+      その線はそこで止まる。**消さずに印を付けて末尾へ** —— 消すと後から確かめ
+      ようがなくなるが、生きている線と同じ顔で並ぶと読み違える。
+      **混ざっていた頃の線は「上がったぶん」を大きく持つ**ので、直したあとも
+      一番上に居座る(実際にそう見えた)
     - **観測点ごとに、そのあいだの依頼も出す**(`calls_between`)。使用率だけでは
       「跳ねた」までしか分からず、どれを止めればよいかが決まらない。
       **区間は前の観測の直後から今の観測まで** —— 始まりを含めると、観測の

app/usage.py

@@ -33,7 +33,7 @@
 
 import asyncio
 import logging
-from dataclasses import asdict, dataclass, field
+from dataclasses import asdict, dataclass, field, replace
 from datetime import UTC, datetime, timedelta
 
 import httpx
@@ -353,27 +353,41 @@ async def refresh(provider_id: str) -> Quota:
             error=str(e),
             windows=_windows_from(stored.get("windows", [])),
         )
-    windows = ordered(windows)
+    windows = arranged(windows)
     usage_store.save_quota(spec.id, [asdict(w) for w in windows])
     return Quota(supported=True, fetched_at=_now_iso(), windows=windows)
 
 
-def ordered(windows: list[Window]) -> list[Window]:
-    """短い窓から並べる。**相手ごとに返す順が違う** —— 実測で codex は 5 時間が先、
-    antigravity は週が先だった。詰まりやすいのは短いほうなので、そこを上に出す。
+def arranged(windows: list[Window]) -> list[Window]:
+    """画面に出す形に整える —— 短い窓から並べ、**同じ名前の窓を呼び分ける**。
 
+    並びは短い順。**相手ごとに返す順が違う** —— 実測で codex は 5 時間が先、
+    antigravity は週が先だった。詰まりやすいのは短いほうなので、そこを上に出す。
     **長さの分からない窓は末尾に、元の並びのまま置く**(claude は文面から読むので
     長さを持たない)。安定な並べ替えなので、同じ長さの窓どうしの順も動かない。
+
+    **名前は長さから作るので、同じ長さの窓が 2 つあると見分けが付かない** ——
+    実測で codex は 7 日の窓を 2 つ返す(片方は別勘定で、値もまったく違う)。
+    **ぶつかったものは全部、窓の id を添えて呼び分ける** —— 片方だけ素のままに
+    すると、どちらが素のままかが相手の並べ方次第になる(ブリッジ側で id を
+    呼び分けているのと同じ判断)。
     """
-    return sorted(
+    out = sorted(
         windows,
         key=lambda w: (1, 0.0) if not w.window_minutes else (0, float(w.window_minutes)),
     )
+    seen: dict[str, int] = {}
+    for w in out:
+        seen[w.label] = seen.get(w.label, 0) + 1
+    return [
+        replace(w, label=f"{w.label}({w.id})") if seen.get(w.label, 0) > 1 else w
+        for w in out
+    ]
 
 
 def _windows_from(raw: list) -> list[Window]:
     out = [_window_from(w) for w in raw if isinstance(w, dict)]
-    return ordered([w for w in out if w is not None])
+    return arranged([w for w in out if w is not None])
 
 
 def _now_iso() -> str:

app/usage_store.py

@@ -459,7 +459,8 @@ def quota_trail(since: datetime) -> list[dict]:
         key = (r["provider"], r["window_id"])
         trail = trails.setdefault(key, {
             "provider": r["provider"], "window_id": r["window_id"],
-            "label": r["label"] or r["window_id"], "points": [], "climbed": 0.0, "resets_at": "",
+            "label": r["label"] or r["window_id"], "points": [], "climbed": 0.0,
+            "resets_at": "", "stale": False,
         })
         percent = float(r["used_percent"])
         if trail["points"] and percent > trail["points"][-1]["used_percent"]:
@@ -468,7 +469,21 @@ def quota_trail(since: datetime) -> list[dict]:
         # 見出しと明ける時刻は新しいほうを採る(窓が明けると次の時刻に変わる)
         trail["label"] = r["label"] or trail["label"]
         trail["resets_at"] = r["resets_at"] or trail["resets_at"]
-    return sorted(trails.values(), key=lambda t: (-t["climbed"], t["provider"]))
+
+    # **相手が返さなくなった窓は下へ回す**(`stale`)。窓の名前が変わったり、枠の
+    # 出し方が変わったりすると、その名前の線はそこで伸びなくなる —— 混ざったまま
+    # 伸びていた頃の線が「上がったぶん」を大きく持っていると、**直したあとも
+    # 壊れた線が一番上に居座る**(実際にそう見えた)。
+    newest: dict[str, str] = {}
+    for trail in trails.values():
+        last = trail["points"][-1]["at"]
+        newest[trail["provider"]] = max(newest.get(trail["provider"], ""), last)
+    for trail in trails.values():
+        trail["stale"] = trail["points"][-1]["at"] < newest[trail["provider"]]
+    return sorted(
+        trails.values(),
+        key=lambda t: (t["stale"], -t["climbed"], t["provider"]),
+    )
 
 
 def calls_since(provider: str, at: str) -> int:

app/views/ai_usage.py

@@ -286,6 +286,18 @@ def _trail_points_html(trail: dict) -> str:
     )
 
 
+def _stale_note(trail: dict) -> str:
+    """相手が返さなくなった窓の印。**消さずに、伸びていないことを書く。**
+
+    窓の名前が変わると、その名前の線はそこで止まる —— 消すと「あの数字は何だったのか」
+    を確かめようがなくなるが、生きている線と同じ顔で並んでいると読み違える。
+    """
+    if not trail.get("stale"):
+        return ""
+    return ('<br><span class="muted">いまは返ってこない窓'
+            "(名前が変わったか、相手が出さなくなった)</span>")
+
+
 def trail_html(request: Request | None = None) -> str:
     """枠の推移 —— いつ跳ねたかを読むところ。
 
@@ -303,9 +315,9 @@ def trail_html(request: Request | None = None) -> str:
         return (f'{head}\n<p class="muted">この窓の観測はありません'
                 "(枠を聞ける相手を呼ぶと、定時に控えはじめます)。</p>")
     body = "\n".join(
-        "<tr>"
+        f'<tr{" class=\"off\"" if t["stale"] else ""}>'
         f'<td>{esc(usage.label_of(t["provider"]))}<br>'
-        f'<span class="muted">{esc(t["label"])}</span></td>'
+        f'<span class="muted">{esc(t["label"])}</span>{_stale_note(t)}</td>'
         f'<td>{esc(_percent(t["points"][-1]["used_percent"]))}</td>'
         f'<td>{esc(_climb(t["climbed"]))}</td>'
         f"<td>{_trail_points_html(t)}</td>"

docs/ai.md

@@ -922,6 +922,18 @@ Antigravity は週が先でした。詰まりやすいのは短いほうなの
 **長さの分からない窓は末尾に、元の並びのまま**置きます（claude は文面から読むので
 長さを持ちません——ただしあちらは元から session → week の順で返ってきます）。
 
+**同じ名前の窓が 2 つ並ぶことがあります。** 名前は窓の長さから作るので、実測で
+codex が返す 2 つの 7 日の窓は見分けが付きませんでした（別勘定で、値もまったく違います）。
+ぶつかったものは**全部、窓の id を添えて呼び分けます**（`直近 7 日(secondary)` /
+`直近 7 日(primary-10080m)`）——片方だけ素のままにすると、どちらが素のままかが
+相手の並べ方次第になります。
+
+**相手が返さなくなった窓は下へ回します。** 窓の名前が変わると、その名前の線はそこで
+止まります——**消さずに「いまは返ってこない窓」と書いて末尾へ**。消すと後から
+「あの数字は何だったのか」を確かめようがなくなりますが、生きている線と同じ顔で
+並んでいると読み違えます（**混ざっていた頃の線が「上がったぶん」を大きく持っていると、
+直したあとも一番上に居座ります**——実際にそう見えました）。
+
 **窓の名前がぶつかることがあります。** 実測で codex は、長さの違う 2 つの窓を
 どちらも `primary` と名乗ってきました。名前は推移を束ねる鍵なので、そのままだと
 **別々の窓が 1 本の線に混ざり**、使用率が交互に跳ね上がったり 0 に戻ったりして

tests/test_ai_usage.py

@@ -955,7 +955,7 @@ def test_the_boundary_is_not_counted_twice(self, env):
 
 
 class TestWindowOrder:
-    """窓の並び —— 相手ごとに返す順が違うので、受け取る側で揃える。"""
+    """窓の並びと名前 —— 相手ごとに返す順が違い、名前もぶつかりうる。"""
 
     def _window(self, name: str, minutes: float | None) -> "object":
         from app.usage import Window
@@ -969,7 +969,7 @@ def test_the_short_window_comes_first(self, env):
         weekly = self._window("週", 7 * 24 * 60)
         session = self._window("5 時間", 5 * 60)
 
-        assert [w.label for w in usage.ordered([weekly, session])] == ["5 時間", "週"]
+        assert [w.label for w in usage.arranged([weekly, session])] == ["5 時間", "週"]
 
     def test_windows_without_a_length_keep_their_place_at_the_end(self, env):
         """claude は文面から読むので長さを持たない。元の並びのまま末尾へ。"""
@@ -979,7 +979,7 @@ def test_windows_without_a_length_keep_their_place_at_the_end(self, env):
         second = self._window("week", None)
         short = self._window("5 時間", 5 * 60)
 
-        assert [w.label for w in usage.ordered([first, second, short])] == [
+        assert [w.label for w in usage.arranged([first, second, short])] == [
             "5 時間", "session", "week",
         ]
 
@@ -1007,3 +1007,76 @@ def test_it_can_be_enabled_without_one(self, env):
 
         assert row["has_credential"] is False
         assert row["can_enable"] is True
+
+    def test_windows_with_the_same_name_are_told_apart(self, env):
+        """名前は長さから作るので、同じ長さの窓が 2 つあると見分けが付かない
+        —— 実測で codex は 7 日の窓を 2 つ返す(別勘定で、値もまったく違う)。
+        """
+        from app import usage
+        from app.usage import Window
+
+        pair = [
+            Window(id="secondary", label="直近 7 日", used_percent=33.0,
+                   window_minutes=7 * 24 * 60),
+            Window(id="primary-10080m", label="直近 7 日", used_percent=0.0,
+                   window_minutes=7 * 24 * 60),
+        ]
+
+        assert [w.label for w in usage.arranged(pair)] == [
+            "直近 7 日(secondary)", "直近 7 日(primary-10080m)",
+        ]
+
+    def test_a_name_that_does_not_clash_is_left_alone(self, env):
+        from app import usage
+        from app.usage import Window
+
+        one = [Window(id="primary", label="直近 5 時間", used_percent=1.0,
+                      window_minutes=300)]
+
+        assert [w.label for w in usage.arranged(one)] == ["直近 5 時間"]
+
+
+class TestAWindowThatStoppedComing:
+    """相手が返さなくなった窓は下へ回す。**消さずに、伸びていないことを示す。**"""
+
+    def test_it_sinks_below_the_live_ones(self, env):
+        import sqlite3
+        from datetime import UTC, datetime, timedelta
+
+        from app import usage_store
+
+        with make_client(env, ReplyLLM()):
+            # 混ざって大きく上がった古い線(もう伸びない)
+            usage_store.save_quota("codex", [{"id": "primary", "label": "直近 7 日",
+                                              "used_percent": 5.0}])
+            usage_store.save_quota("codex", [{"id": "primary", "label": "直近 7 日",
+                                              "used_percent": 90.0}])
+            old = (datetime.now(UTC) - timedelta(hours=2)).isoformat(timespec="seconds")
+            with sqlite3.connect(usage_store.db_path()) as conn:
+                conn.execute("UPDATE quota_samples SET at = ?", (old,))
+            # いま伸びている線
+            usage_store.save_quota("codex", [{"id": "primary-300m", "label": "直近 5 時間",
+                                              "used_percent": 3.0}])
+            trails = usage_store.quota_trail(datetime.now(UTC) - timedelta(days=1))
+
+        assert [t["window_id"] for t in trails] == ["primary-300m", "primary"]
+        assert trails[0]["stale"] is False
+        assert trails[1]["stale"] is True
+
+    def test_the_screen_says_it_is_no_longer_reported(self, env):
+        import sqlite3
+        from datetime import UTC, datetime, timedelta
+
+        from app import usage_store
+
+        with make_client(env, ReplyLLM()) as client:
+            usage_store.save_quota("codex", [{"id": "primary", "label": "直近 7 日",
+                                              "used_percent": 90.0}])
+            old = (datetime.now(UTC) - timedelta(hours=2)).isoformat(timespec="seconds")
+            with sqlite3.connect(usage_store.db_path()) as conn:
+                conn.execute("UPDATE quota_samples SET at = ?", (old,))
+            usage_store.save_quota("codex", [{"id": "primary-300m", "label": "直近 5 時間",
+                                              "used_percent": 3.0}])
+            html = client.get("/admin/ai").text
+
+        assert "いまは返ってこない窓" in html