Method flushNow

src/telemetry/index.ts:277–312

* Drain in-memory state to the buffer, then send completed-day rollups and * lifecycle events. Bounded by `timeoutMs`; leftovers stay buffered for the * next process. Awaited only where latency is invisible (install/init).

(timeoutMs: number = DEFAULT_FLUSH_TIMEOUT_MS)

   * next process. Awaited only where latency is invisible (install/init).
   */
  async flushNow(timeoutMs: number = DEFAULT_FLUSH_TIMEOUT_MS): Promise<void> {
    if (!this.isEnabled()) return;
    try {
      this.persistSync();
      this.recoverStaleClaims();
      const claim = this.claimQueue();
      if (!claim) return;
      const { claimPath, lines } = claim;
      const today = this.utcDay();
      const sendable: BufferLine[] = [];
      const keep: BufferLine[] = [];
      for (const line of lines) {
        if ('ev' in line) sendable.push(line);
        else if (line.d < today) sendable.push(line);
        else keep.push(line);
      }
      let failed: BufferLine[] = [];
      if (sendable.length > 0) {
        // Consent gate: the one-time notice precedes the FIRST bytes that
        // ever leave the machine (and mints the machine id). Recording only
        // buffers locally, so it stays silent — this lets the installer show
        // its explicit consent toggle before any notice can fire, instead of
        // the preAction usage count pre-empting it. An explicit installer/CLI
        // choice sets first_run_notice_shown and suppresses this permanently.
        this.firstRunNotice();
        failed = await this.send(sendable, timeoutMs);
      }
      // Whatever didn't go out returns to the queue (append — writers may
      // have created a fresh queue file while we held the claim).
      const back = [...failed, ...keep];
      if (back.length > 0) this.appendLines(back);
      try { fs.rmSync(claimPath, { force: true }); } catch { /* fail silent */ }
    } catch {
      /* fail silent */
    }
  }

  /**
   * Periodic flush for long-lived processes (MCP daemon / serve). Unref'd so