Method fetch

packages/cloud/src/TelemetryClient.ts:102–155

(path: string, options: RequestInit, allowQueueing = true)

	}

	private async fetch(path: string, options: RequestInit, allowQueueing = true) {
		if (!this.authService.isAuthenticated()) {
			return
		}

		const token = this.authService.getSessionToken()

		if (!token) {
			console.error(`[TelemetryClient#fetch] Unauthorized: No session token available.`)
			return
		}

		const url = `${getRooCodeApiUrl()}/api/${path}`
		const fetchOptions: RequestInit = {
			...options,
			headers: {
				Authorization: `Bearer ${token}`,
				"Content-Type": "application/json",
			},
		}

		try {
			const response = await fetch(url, fetchOptions)

			if (!response.ok) {
				console.error(
					`[TelemetryClient#fetch] ${options.method} ${path} -> ${response.status} ${response.statusText}`,
				)

				// Queue for retry on server errors (5xx) or rate limiting (429)
				// Do NOT retry on client errors (4xx) except 429 - they won't succeed
				if (this.retryQueue && allowQueueing && (response.status >= 500 || response.status === 429)) {
					await this.retryQueue.enqueue(url, fetchOptions, "telemetry")
				}
			}

			return response
		} catch (error) {
			console.error(`[TelemetryClient#fetch] Network error for ${options.method} ${path}: ${error}`)

			// Queue for retry on network failures (typically TypeError with "fetch failed" message)
			// These are transient network issues that may succeed on retry
			if (
				this.retryQueue &&
				allowQueueing &&
				error instanceof TypeError &&
				error.message.includes("fetch failed")
			) {
				await this.retryQueue.enqueue(url, fetchOptions, "telemetry")
			}

			throw error
		}
	}

	public override async capture(event: TelemetryEvent) {
		if (!this.isTelemetryEnabled() || !this.isEventCapturable(event.event)) {