Sustained event burst invalidates the same key twice #1462

   19  export const SETTLE_MS = 300;
   20  
   21  /** 全图 overview 要数遍整个库：推送期间几秒重数一次就够了（#1296） */
   22  export const OVERVIEW_SETTLE_MS = 3_000;
   23  
   24  /**
   25   * 把一阵失效合并成一次：`push` 只记键，静默 `settleMs` 后一起交给 `invalidate`，
   26   * 同一个键及其前缀只失效一次；`flush` 给卸载与重连用，攒着的刷掉而不是丢掉。
   27   * 抽成纯函数是为了能测；订阅那层只是把事件名映射到键。
   28   */
   29  export function createInvalidationCoalescer(
   30    invalidate: (key: QueryKey) => void,
   31    settleMs: number,
   32  ) {
   33    const pending = new Map<string, QueryKey>();
   34    let timer: ReturnType<typeof setTimeout> | null = null;
   35    const flush = () => {
   36      if (timer !== null) {
   37        clearTimeout(timer);
   38        timer = null;
   39      }
   40      const keys = [...pending.values()];
   41      pending.clear();
   42      for (const key of keys) {
   43        // 正常 graph 事件可能已排了 ["graph", kbId, "neighborhood"]，重连又补上 ["graph", kbId]：
   44        // 前缀已经覆盖后者，不能取消刚开始的请求再重取一遍。
   45        if (keys.some((prefix) => prefix.length < key.length && partialMatchKey(key, prefix))) continue;
   46        invalidate(key);
   47      }
   48    };
   49    const push = (...keys: QueryKey[]) => {
   50      for (const key of keys) pending.set(JSON.stringify(key), key);
   51      if (timer === null) timer = setTimeout(flush, settleMs);
   52    };
   53    return { push, flush };
   54  }
   55  
   56  export function useKbEvents(kbId: string | undefined) {
   57    const queryClient = useQueryClient();
   58  
   59    useEffect(() => {