Dynamics-memory

flowchart LR
    U("主 Agent<br/>OpenCode") -->|"① 会话事件"| BR["memory-bridge.ts<br/>插件桥"]
    BR -->|"POST /observe"| SVC["sidecar<br/>:17872"]
    SVC --> L0[("L0 证据库<br/>只增不删 · FTS")]
    SVC -.->|"② 信号入队"| Q[["任务机<br/>SQLite 持久交接"]]
    Q -->|"③ --file 文件通道"| H["Hauler<br/>抽候选"]
    H -->|"④ 候选 + 来源"| S["Selector<br/>五路裁决"]
    U -.->|"表达不满"| REV["Reviewer<br/>诊断 + 版本化规则"]
    REV -.->|"持久规则回喂"| H
    S -->|"CREATE"| ENG["记忆引擎<br/>三池动力学"]
    S -->|"CONFLICT"| HR{"human_reviews<br/>待人工审核"}
    HR -->|"accept_new / keep_old"| ENG
    S -->|"REJECT"| X(("不入库"))
    BR -->|"⑤ GET /recall"| SVC
    SVC -->|"⑥ relevant-memories 注入"| U
    BR -->|"⑦ POST /feedback"| SVC
    SVC -->|"useful-hit → V 值结算"| ENG

    classDef agent fill:#FFF3E0,stroke:#E8963C,color:#7A4A00
    classDef core fill:#E8F4FD,stroke:#2B8CBF,color:#0B4F6C
    classDef store fill:#F5F5F5,stroke:#9E9E9E,color:#424242
    classDef risk fill:#FDECEF,stroke:#D65F7F,color:#8A2444
    class H,S,REV agent
    class ENG,SVC core
    class L0,Q store
    class HR,X risk

flowchart TB
    subgraph T["transport/ · 传输"]
        HTTP["HTTP 服务 · auth · dto<br/>bootstrap 组装 · review CLI"]
    end
    subgraph SV["service/ · 门面"]
        SVC["MemoryService<br/>observe · recall · feedback · propose · resolve · 人审<br/>预算准入 · 因果界 · telemetry"]
    end
    subgraph DP["dispatch/ · 调度"]
        W["DispatchWorker<br/>+ 语义循环"]
        EF["effects 效果事务<br/>容量收口 · 完整回滚"]
        POL["policy 策略表<br/>SEM 5/5 · WF 5/5 · INV 2/3"]
    end
    subgraph AG["agents/ · 角色"]
        TRIO["Hauler · Selector · Reviewer"]
        OCR["OpenCodeRunner 文件通道<br/>+ 调用上下文封存"]
    end
    subgraph SEM["semantics/ · 语义"]
        SP["SemanticsProvider 双通路<br/>judge · relevant_set · consolidate"]
    end
    subgraph CO["core/ · 引擎（无 LLM）"]
        ENG["三池动力学 · ingest 去重<br/>张力与裁决 · 巩固蒸馏 · plan_capacity"]
    end
    subgraph ST["store/ · 存储"]
        EDB[("L0 证据库")]
        TDB[("任务库 + checkpoint")]
        SCH["schema 三库身份版本"]
    end
    EXT["OpenCode CLI 真进程"]
    LLM["LLM / Embedding"]

    HTTP --> SVC
    SVC --> W
    W --> TRIO
    TRIO --> OCR --> EXT
    W --> EF
    EF --> ENG
    ENG --> SP --> LLM
    SVC --> EDB
    EF --> TDB
    SCH -.- EDB
    SCH -.- TDB

    classDef layer fill:#FAFAFA,stroke:#BDBDBD,color:#424242
    class T,SV,DP,AG,SEM,CO,ST layer

stateDiagram-v2
    direction TB
    [*] --> C: CREATE / reflection 入池
    state "C 候选池（cap 200）" as C
    state "M 常用池（cap 8 · 检索主力）" as M
    state "A 冷归档池（cap 2000）" as A

    C --> M: V 超过 θp 且有容量
    M --> C: V 跌破 θd（θp>θd 滞回防抖）
    C --> A: 闲置 / 容量收口迁出
    A --> C: EXIST 复活 / 低先验召回
    M --> A: 旧版退役（加指针 + 时间戳）
    A --> [*]: 无保护版本 FIFO 物理回收

stateDiagram-v2
    direction LR
    [*] --> pending: enqueue（同 key 合并去重）
    pending --> running: claim（租约 + 版本 CAS）
    running --> ready: 产物落库（可重放）
    running --> pending: 失败退避（计数保持）
    ready --> applying: 领取（apply_attempts+1）
    applying --> done: 效果事务提交
    applying --> ready: 应用失败退避（产物保留）
    running --> dead: 重试耗尽（上限见策略表）
    pending --> dead: 过期恢复后耗尽
    done --> [*]

flowchart LR
    S["Selector 裁 CONFLICT"] --> PIN["目标 pin 保护<br/>落 human_reviews"]
    PIN --> HUM{"人工审核<br/>独立 token"}
    HUM -->|"accept_new"| NEW["新版本入库<br/>旧版退役指向新版本"]
    HUM -->|"keep_old"| OLD["候选拒绝<br/>旧版保留解除 pin"]
    NEW --> T["张力消解"]
    OLD --> T

    classDef risk fill:#FDECEF,stroke:#D65F7F,color:#8A2444
    classDef ok fill:#E8F5E9,stroke:#43A047,color:#1B5E20
    class S,PIN,HUM risk
    class NEW,OLD,T ok