Method claimQueue

src/telemetry/index.ts:422–444

* Atomically claim the queue for sending (rename). Concurrent processes * can't double-send; a crash mid-send leaves a claim file that * `recoverStaleClaims` merges back after an hour.

()

   * `recoverStaleClaims` merges back after an hour.
   */
  private claimQueue(): { claimPath: string; lines: BufferLine[] } | null {
    const claimPath = path.join(this.dir, `telemetry-queue.sending.${process.pid}.jsonl`);
    try {
      fs.renameSync(this.queuePath, claimPath);
    } catch {
      return null; // no queue, or another process just claimed it
    }
    const lines: BufferLine[] = [];
    try {
      for (const raw of fs.readFileSync(claimPath, 'utf8').split('\n')) {
        if (!raw.trim()) continue;
        try {
          const parsed = JSON.parse(raw) as BufferLine;
          if (parsed && typeof parsed === 'object' && parsed.v === SCHEMA_VERSION) lines.push(parsed);
        } catch {
          /* skip corrupt line */
        }
      }
    } catch {
      /* unreadable claim — treat as empty; file removed by caller */
    }
    return { claimPath, lines };
  }

  private recoverStaleClaims(): void {
    try {