外の道具で引く窓を巡回ごとに持ち、変更履歴を回で絞れるようにする

フィードの「前回より後」の基準が収集ぜんたいの前回だったので、別の巡回が
走った時刻でその窓が食われていた。1 時間おきに溜める回でも、直前に整理が
走っていれば見るのは数分ぶんで、あいだに配信されたものはどの回も溜めない。
整理の側でも噛み合わない —— 4 時間ごとに回るのに、差し込まれる見出しは
直前の回からのぶんしかない。基準をその巡回の前回に変える({recent} と同じ読み方)。

変更履歴は回ごとの間隔が桁違いなので、新しい順に並べるだけでは短い回が
長い回を押し流す。1 時間ごとの回が 24 行を占めると、4 時間ごとに整理する回の
差分が 1 日ぶんも残らない。回で絞れるようにし、選択肢は控えの側から引く ——
定義の巡回から作ると、名前を変えた回の行が目の前に出ているのに選べない。

AI を呼ばない回には相手を控えない。既定の相手を書いていたせいで、機械で
引いた回が「その相手に頼んだ回」として履歴に並んでいた。

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

Author: claude

CLAUDE.md

@@ -580,7 +580,13 @@ GeoNames 全世界地名辞典 = `geonames`(いずれも 348 言語版・195 か
         (名簿と肉付けを分けるのと同じ形)。**区画は見ない**(機械で引く回と同じ理由)。
         **進み具合にも触らない** —— 次にどこから読むかは道具の側が決める
         (`feeds.SINCE_LAST_RUN`)。出典ごとにタグを書けるので、ニュースと記事と論文が
-        同じところに溜まっても、後から分けて取り出せる
+        同じところに溜まっても、後から分けて取り出せる。
+        **「前回より後」の基準はその巡回の前回**(`main._harvest`。`{recent}` と
+        同じ読み方)—— 収集の前回を基準にすると、**別の巡回が走った時刻でその窓が
+        食われる**。1 時間おきに溜める回でも、直前に整理が走っていれば見るのは
+        数分ぶんだけで、あいだに配信されたものはどの回も溜めないまま流れていく
+        (整理の側でも噛み合わない —— 4 時間ごとに回るのに、差し込まれる見出しは
+        直前の回からのぶんしかない)
       - **消したものは墓場に残す**(`Collection.graves`)。**足す回はそこにあるものを
         連れ戻さない**。消す回と足す回は別々に走るので、これが無いと消したものが
         戻ってくる —— 足すほうは「いま名簿にいるか」しか見られず、**なぜ居ないのかは
@@ -653,7 +659,16 @@ GeoNames 全世界地名辞典 = `geonames`(いずれも 348 言語版・195 か
       残すのは巡回ごとに変えられるから** —— 「じっくりだけ荒れている」が相手のせいか
       考える量のせいかは、並べて初めて見分けられる。**「既定にまかせる」は名前に
       開いて残す**(`main._default_backend_name`)—— 空欄のままだと、後から読む人には
-      そのとき既定がどれだったのか確かめようがない
+      そのとき既定がどれだったのか確かめようがない。**AI を呼ばない回には誰も書かない**
+      (`collect.asks_ai`)—— 既定の相手を書いておくと、機械で引いた回・外の道具で
+      引いた回が「その相手に頼んだ回」として履歴に並ぶ(画面にも相手を出さない、と
+      決めているのと同じ話)
+    - **回で絞って読める**(`collect_log.recent(sweep=…)` /
+      `GET /v1/collect/changes?sweep=…` / 画面の「どの回を見るか」)。
+      間隔は回ごとに桁違いなので、新しい順に並べるだけでは**短い回が長い回を押し流す**
+      —— 1 時間ごとに見出しを溜める回が 24 行を占めれば、4 時間ごとに整理する回の
+      差分は 1 日ぶんも残らない。**選択肢は控えの側から引く**(`collect_log.sweeps`)
+      —— 定義の巡回から作ると、名前を変えた回や消した回の行が目の前に出ているのに選べない
     - **直した件数は足した件数と別に控える**(`last_updated`)。整理の回は足すものが
       無くても大量に直っていることがあり、追加だけ見ていると「何もしなかった」ように読める
       (`material` は数えていたのに、定義へ書き戻すところで落としていた)

app/collect.py

@@ -2356,6 +2356,18 @@ def uses_extract(item: Collection, sweep=None) -> bool:
     return bool((sweep is not None and sweep.use_extract) or not item.cursor)
 
 
+def asks_ai(item: Collection, sweep=None) -> bool:
+    """この回は AI に頼むか。**判断は 1 か所に持つ**(`uses_extract` と同じ理由)。
+
+    機械で引く回も外の道具で引く回も AI を呼ばない。**呼ばない回の相手を控えに
+    残さない**ために要る —— 残すと、後から読む人には「この回は AI で走っている」と
+    見える(画面にも相手を出さない、と決めているのと同じ話)。
+    """
+    if uses_extract(item, sweep):
+        return False
+    return not (sweep is not None and sweep.use_feed)
+
+
 def stream_docs(
     item: Collection,
     previous,

app/collect_log.py

@@ -193,8 +193,15 @@ def record(
         log.warning("collect run log write failed: %r", e)
 
 
-def recent(name: str | None = None, limit: int = 50) -> list[dict]:
-    """直近の実行を新しい順に。`name` を渡すとその収集だけ。記録が無ければ空。"""
+def recent(
+    name: str | None = None, limit: int = 50, sweep: str | None = None,
+) -> list[dict]:
+    """直近の実行を新しい順に。`name` を渡すとその収集だけ。記録が無ければ空。
+
+    **`sweep` で回を絞れる。** 同じ収集の中でも回ごとに間隔が桁違いなので、
+    絞れないと**短い回の行が長い回の行を押し流す** —— 1 時間ごとに見出しを溜める回と
+    4 時間ごとに整理する回が並ぶと、新しい順に 30 件では整理の差分がほとんど残らない。
+    """
     path = db_path()
     if path is None or not path.exists():
         return []
@@ -204,9 +211,15 @@ def recent(name: str | None = None, limit: int = 50) -> list[dict]:
         " backend, model, effort, ms FROM collect_runs"
     )
     args: list = []
+    where = []
     if name:
-        sql += " WHERE name = ?"
+        where.append("name = ?")
         args.append(name)
+    if sweep:
+        where.append("sweep = ?")
+        args.append(sweep)
+    if where:
+        sql += " WHERE " + " AND ".join(where)
     sql += " ORDER BY id DESC LIMIT ?"
     args.append(max(1, min(limit, MAX_ROWS)))
     rows: list[dict] = []
@@ -223,6 +236,30 @@ def recent(name: str | None = None, limit: int = 50) -> list[dict]:
     return rows
 
 
+def sweeps(name: str | None = None) -> list[str]:
+    """履歴に出てくる回の名前を、新しく走った順に。絞り込みの選択肢に使う。
+
+    **控えの側から引く**(定義の巡回を並べない)—— 名前を変えた回や消した回の行は
+    履歴に残っているので、定義から作ると**目の前に出ている行を選べない**。
+    """
+    path = db_path()
+    if path is None or not path.exists():
+        return []
+    sql = "SELECT sweep, MAX(id) AS last FROM collect_runs WHERE sweep <> ''"
+    args: list = []
+    if name:
+        sql += " AND name = ?"
+        args.append(name)
+    sql += " GROUP BY sweep ORDER BY last DESC"
+    with suppress(sqlite3.Error):
+        conn = _connect(path)
+        try:
+            return [str(r["sweep"]) for r in conn.execute(sql, tuple(args))]
+        finally:
+            conn.close()
+    return []
+
+
 def forget(name: str) -> None:
     """収集を消したときに、その履歴も落とす。
 

app/main.py

@@ -398,19 +398,23 @@ async def draft_collection_prompt(
     return draft
 
 
-async def _harvest(item) -> dict | None:
-    """外向きの道具(`app/feeds.py`)を回して、参考の素材を取る。
+async def _harvest(item, sweep=None) -> dict | None:
+    """外向きの道具(`app/feeds.py`)を回して、素材を取る。
 
     **落ちても収集は止めない。** これは参考であって情報源ではなく、AI は自分でも
     調べる —— 1 本の不調で収集ごと止めるほうが損。取れなかった数は素材の中で伝える。
+
+    **「前回より後」の基準はその巡回の前回**(`{recent}` と同じ読み方)。収集の
+    前回を基準にすると、**別の巡回が走った時刻でその窓が食われる** —— 見出しを
+    溜める回が 1 時間おきでも、その直前に整理が走っていれば見るのは数分ぶんだけで、
+    あいだに配信されたものはどの回も溜めないまま流れていく。整理の側でも噛み合わない
+    (4 時間ごとに回るのに、差し込まれる見出しは直前の回からのぶんしかない)。
     """
     spec = feeds.normalize(item.feed)
     if spec is None:
         return None
-    # 「前回より後」の基準は収集の最後の実行。**巡回ごとには持たない** ——
-    # 道具は外から拾うためのもので、区画を回る巡回とは噛み合わない(付けるなら
-    # 集める側の収集で、そちらは巡回を分けない)
-    return await feeds.fetch(spec, item.last_run_at)
+    since = (sweep.last_run_at if sweep is not None else None) or item.last_run_at
+    return await feeds.fetch(spec, since)
 
 
 async def _collect_items(
@@ -556,14 +560,16 @@ async def _collect_material(name: str, sources: dict) -> str:
     # **誰に頼んだ回かも控える。** 巡回ごとに相手を変えられるので、回の名前だけでは
     # 何で走ったのか読めない。**「既定にまかせる」は名前に開いて残す** ——
     # 空欄のまま残すと、後から読む人には既定がどれだったのか確かめようがない
-    # (相手の一覧は設定しだいで変わる)
+    # (相手の一覧は設定しだいで変わる)。
+    # **AI を呼ばない回には誰も書かない**(`collect.asks_ai`)—— 既定の相手を
+    # 書いておくと、機械で引いた回が「その相手に頼んだ回」として履歴に並ぶ
     who = {
         "backend": sweep.backend or _default_backend_name(),
         "model": sweep.model or "",
         "effort": sweep.effort or "",
-    }
+    } if collect.asks_ai(item, sweep) else {"backend": "", "model": "", "effort": ""}
     try:
-        feed = await _harvest(item)
+        feed = await _harvest(item, sweep)
         # **差し込むぶんだけ取り出す。** 区画で切ってあれば、その区画のぶんだけ ——
         # 全部を持つと、区画で切った意味がメモリの側から消える
         for_prompt = await asyncio.to_thread(
@@ -678,7 +684,7 @@ async def collect_preview(name: str, sources: dict, sweep_name: str | None = Non
     # **下見は 1 区画だけ。** 何区画でも見られるが、下見は「この指示文でどうなるか」を
     # 見るためのもので、1 区画あれば分かる(そのぶん安く、待たされない)
     keys = partitioning.pick(ledger, sweep.name, 1)
-    feed = await _harvest(item)
+    feed = await _harvest(item, sweep)
     for_prompt = await asyncio.to_thread(collect.prompt_docs, item, previous, keys, None)
     items, next_cursor, note = await _collect_items(
         item, for_prompt, sources, keys, sweep, None, feed
@@ -2037,17 +2043,22 @@ async def collect_preview_now(
 def collect_changes(
     name: str | None = Query(None, description="収集の名前。省略すると全部の収集"),
     limit: int = Query(50, ge=1, le=500),
+    sweep: str | None = Query(None, description="巡回の名前。省略すると全部の回"),
 ):
     """**直近どこに修正が入ったか**(`app/collect_log.py`)。
 
     定義側の控え(`last_added` など)は**最新の 1 回で上書きされる**ので、
     「減り続けているのか、ある日だけ荒れたのか」はここでしか読めない。
 
+    **回で絞れる**(`sweep`)。間隔は回ごとに桁違いなので、新しい順に並べるだけでは
+    短い回が長い回を押し流す —— 1 時間ごとの回が並びを埋めると、4 時間ごとの回の
+    差分が残らない。
+
     **記録の置き場(`CHIEZO_STATE_DIR`)が無ければ空で返す。** 404 にすると、
     控えを持たない構成で読む側が毎回エラーを踏む(`/v1/collect/sources` と同じ判断)。
     """
     collect.require_enabled()
-    return {"changes": collect_log.recent(name, limit)}
+    return {"changes": collect_log.recent(name, limit, sweep)}
 
 
 @app.get("/v1/collect/{name}/partition")

app/views/admin.py

@@ -1020,27 +1020,57 @@ def _collect_running_html(name: str | None = None) -> str:
     )
 
 
-def _collect_changes_html(limit: int = 30, name: str | None = None) -> str:
+def _changes_filter_html(name: str | None, sweep: str | None) -> str:
+    """「どの回を見るか」の切り替え。**回が 1 本しかなければ出さない**(選ぶ先が無い)。
+
+    押した先はこの節へ戻す(`#changes`)—— 長い面の途中にある表なので、
+    絞り込んだ結果が画面の外に出ていると、押しても何も起きていないように見える。
+    """
+    names = collect_log.sweeps(name)
+    if len(names) < 2:
+        return ""
+    base = f"/admin/collect/{quote(name)}" if name else "/admin/memory"
+    links = [("すべて", None), *((one, one) for one in names)]
+    out = []
+    for label, value in links:
+        href = f"{base}?sweep={quote(value)}#changes" if value else f"{base}#changes"
+        out.append(
+            f"<strong>{esc(label)}</strong>" if value == sweep
+            else f'<a href="{esc(href)}">{esc(label)}</a>'
+        )
+    return f'<p class="muted">どの回を見るか: {" / ".join(out)}</p>'
+
+
+def _collect_changes_html(
+    limit: int = 30, name: str | None = None, sweep: str | None = None,
+) -> str:
     """直近どこに修正が入ったか(`app/collect_log.py`)。
 
     **表の「前回」列とは別に要る。** あちらは最新の 1 回で上書きされるので、
     6 時間ごとに回る収集なら朝には昨夜の 1 回しか残っていない。減り続けているのか、
     ある日だけ荒れたのかは、並べて初めて読める。
 
+    **回で絞れるようにする。** 間隔は回ごとに桁違いなので、新しい順に並べるだけでは
+    **短い回が長い回を押し流す** —— 1 時間ごとの回が 24 行を占めれば、4 時間ごとの
+    回の差分は 1 日ぶんも残らない。読みたいのは「整理が何を直したか」のほうなのに。
+
     **控えの置き場が無ければ、何も出さずに理由だけ出す** —— 空の表を出すと
     「まだ動いていない」と読めてしまう(実際は記録していないだけ)。
     """
     if collect_log.db_path() is None:
         return (
-            '<details><summary>直近の変更</summary>'
+            '<details id="changes"><summary>直近の変更</summary>'
             '<p class="muted">変更履歴は記録していません。'
             "<code>CHIEZO_STATE_DIR</code> を設定すると残ります。</p></details>"
         )
-    changes = collect_log.recent(name, limit=limit)
+    picker = _changes_filter_html(name, sweep)
+    changes = collect_log.recent(name, limit=limit, sweep=sweep)
     if not changes:
         return (
-            '<details><summary>直近の変更</summary>'
-            '<p class="muted">まだ 1 回も走っていません。</p></details>'
+            f'<details id="changes" open><summary>直近の変更</summary>{picker}'
+            '<p class="muted">'
+            + ("その回はまだ走っていません。" if sweep else "まだ 1 回も走っていません。")
+            + "</p></details>"
         )
     rows = []
     for row in changes:
@@ -1107,7 +1137,8 @@ def _collect_changes_html(limit: int = 30, name: str | None = None) -> str:
             f'<td>{summary}{note}</td><td>{row["total"]:,} 件{detail}</td></tr>'
         )
     return f"""
-<details open><summary>直近の変更</summary>
+<details id="changes" open><summary>直近の変更</summary>
+{picker}
 <table>
 <thead><tr><th>いつ</th>{"" if name else "<th>収集</th>"}<th>どの回</th><th>頼んだ相手</th>
 <th>かかった</th><th>変化</th><th>焼いた後</th></tr></thead>
@@ -1274,7 +1305,9 @@ def _collect_detail_html(item, disabled: str, sources: dict | None = None) -> st
     )
 
 
-def _collect_html(sources: dict[str, Source], disabled: str) -> str:
+def _collect_html(
+    sources: dict[str, Source], disabled: str, sweep: str | None = None,
+) -> str:
     """収集(AI に集めさせて溜めていく)の節。
 
     **出すのは「間隔・次にいつ走るか・いま何件」の 3 つ**。無人で回る層なので、
@@ -1384,7 +1417,7 @@ def _collect_html(sources: dict[str, Source], disabled: str) -> str:
     return f"""
 {table}
 {_collect_running_html()}
-{_collect_changes_html()}
+{_collect_changes_html(sweep=sweep)}
 <details><summary>収集を追加する</summary>
 <form method="post" action="/admin/collect/create" class="collect-form">
 <p><label>name(ソース名になる。英小文字・数字・_)<br>
@@ -1786,7 +1819,10 @@ def _running_html(running: list[dict]) -> str:
 
 
 @router.get("/admin/memory", response_class=HTMLResponse)
-def admin_memory(request: Request):
+def admin_memory(
+    request: Request,
+    sweep: str | None = Query(None, description="直近の変更を、この回のぶんだけに絞る"),
+):
     sources: dict[str, Source] = request.app.state.sources
     job = _fetch_trigger_status()
     disabled = run_buttons_disabled(job)
@@ -1925,7 +1961,7 @@ def schema_cell(version: int) -> str:
 </details>
 
 <h2 id="collect">集める(AI に集めさせて溜める)</h2>
-{_collect_html(sources, disabled)}
+{_collect_html(sources, disabled, sweep)}
 
 <h2 id="consolidation">短期記憶から移す(固化)</h2>
 {_memory_html(sources, disabled)}
@@ -2843,7 +2879,11 @@ def _preview_page_html(name: str, result: dict | None, error: str) -> str:
 
 
 @router.get("/admin/collect/{name}", response_class=HTMLResponse)
-def admin_collect_detail(request: Request, name: str):
+def admin_collect_detail(
+    request: Request,
+    name: str,
+    sweep: str | None = Query(None, description="直近の変更を、この回のぶんだけに絞る"),
+):
     """収集 1 つぶんの面。**一覧から名前を押すとここへ来る**。
 
     **一覧の中で開かない。** 折り畳みの中に押し込んでいた頃は、開くたびに表が縦へ
@@ -2883,7 +2923,7 @@ def admin_collect_detail(request: Request, name: str):
 </table>
 {_collect_detail_html(item, disabled, request.app.state.sources)}
 {_collect_running_html(name)}
-{_collect_changes_html(name=name)}
+{_collect_changes_html(name=name, sweep=sweep)}
 <p class="muted"><a href="/admin/memory#collect">集める の一覧へ戻る</a></p>
 """
     return HTMLResponse(content=page_shell(name, body))