メモリストアの棚卸しが半分しか返らない — path_prefix セグメント一致への移行

# 変更前。これで /projects/alpha/... も /projects/alpha_archive/... も拾えていた
memories = client.beta.memory_stores.memories.list(
    memory_store_id=store_id,
    path_prefix="/projects/alpha",   # ← 末尾スラッシュが無い
    view="basic",
    betas=["managed-agents-2026-04-01"],
)

from anthropic import Anthropic
 
client = Anthropic()  # ANTHROPIC_API_KEY は環境変数から
BETAS = ["managed-agents-2026-04-01", "agent-memory-2026-07-22"]
 
 
def normalize_prefix(prefix: str) -> str:
    """path_prefix は必ず末尾スラッシュで終える。ルートは "/" に統一。"""
    if not prefix.startswith("/"):
        prefix = "/" + prefix
    if not prefix.endswith("/"):
        prefix = prefix + "/"
    return prefix
 
 
def list_all_memories(store_id: str, prefix: str = "/") -> list[dict]:
    """
    prefix 配下のメモリを全件返す。
    - 返却順に依存しない（呼び出し側で必ずソートする）
    - depth は 0/1/省略のみ許されるため、木は自分で再帰的に歩く
    """
    prefix = normalize_prefix(prefix)
    collected: list[dict] = []
    cursor: str | None = None
 
    while True:
        page = client.beta.memory_stores.memories.list(
            memory_store_id=store_id,
            path_prefix=prefix,
            depth=1,          # 直下の子だけを取り、サブツリーは再帰で辿る
            view="basic",     # メタデータのみ。本文は必要な時だけ retrieve
            after_id=cursor,
            betas=BETAS,
        )
        for item in page.data:
            if item.type == "memory_prefix":
                # ディレクトリ相当のノード。1 段掘り下げる
                collected.extend(list_all_memories(store_id, item.path))
            else:
                collected.append({"id": item.id, "path": item.path})
 
        if not getattr(page, "has_more", False):
            break
        cursor = page.last_id
 
    # サーバ順は保証されないので、比較・差分のために自前で安定ソートする
    collected.sort(key=lambda m: m["path"])
    return collected

def list_project_including_archive(store_id: str, project: str) -> list[dict]:
    """プロジェクト本体とアーカイブを、意図的に別プレフィックスとして合算する。"""
    live = list_all_memories(store_id, f"/projects/{project}/")
    archive = list_all_memories(store_id, f"/projects/{project}_archive/")
    return live + archive

def safe_correct(store_id: str, memory_id: str, new_content: str) -> bool:
    current = client.beta.memory_stores.memories.retrieve(
        memory_store_id=store_id, memory_id=memory_id, betas=BETAS,
    )
    try:
        client.beta.memory_stores.memories.update(
            memory_store_id=store_id,
            memory_id=memory_id,
            content=new_content,
            precondition={
                "type": "content_sha256",
                "content_sha256": current.content_sha256,
            },
            betas=BETAS,
        )
        return True
    except Exception:
        # ハッシュ不一致 = 誰か（多くはエージェント自身）が先に書いた。
        # 黙って上書きせず、再読込して判断し直す
        return False