Method send

src/telemetry/index.ts:468–515

Returns the lines that did NOT make it out (to be re-queued).

(lines: BufferLine[], timeoutMs: number)

  /** Returns the lines that did NOT make it out (to be re-queued). */
  private async send(lines: BufferLine[], timeoutMs: number): Promise<BufferLine[]> {
    const config = this.readConfig();
    if (!config) return [];
    const events = lines.map((line) =>
      'ev' in line
        ? { event: line.ev, ts: line.ts, props: line.props }
        : {
            event: 'usage_rollup',
            ts: `${line.d}T12:00:00.000Z`,
            props: {
              kind: line.k,
              name: line.n,
              count: line.c,
              error_count: line.e,
              ...(line.cn ? { client_name: line.cn } : {}),
              ...(line.cv ? { client_version: line.cv } : {}),
            },
          },
    );
    const envelope = {
      machine_id: config.machine_id,
      codegraph_version: this.packageVersion(),
      os: process.platform,
      arch: process.arch,
      node_major: parseInt(process.versions.node.split('.')[0] ?? '0', 10),
      ci: this.env.CI !== undefined && this.env.CI !== '' && this.env.CI !== '0' && this.env.CI !== 'false',
      schema_version: SCHEMA_VERSION,
    };
    const endpoint = this.env.CODEGRAPH_TELEMETRY_ENDPOINT || TELEMETRY_ENDPOINT;
    for (let i = 0; i < events.length; i += MAX_EVENTS_PER_REQUEST) {
      const chunk = events.slice(i, i + MAX_EVENTS_PER_REQUEST);
      const body = JSON.stringify({ ...envelope, events: chunk });
      this.debug(`POST ${endpoint} (${chunk.length} events)`);
      try {
        // Any response — 204, 4xx, anything — is final. No retries.
        await this.fetchImpl(endpoint, {
          method: 'POST',
          headers: { 'content-type': 'application/json' },
          body,
          signal: AbortSignal.timeout(timeoutMs),
        });
      } catch (err) {
        this.debug(`send failed: ${String(err)}`);
        return lines.slice(i); // network failure: re-queue this chunk + the rest
      }
    }
    return [];
  }

  private packageVersion(): string {
    try {