Function createTinybirdClient

scripts/analytics/shared.js:139–201

(authOverride)

}

function createTinybirdClient(authOverride) {
	const auth = authOverride ?? resolveTinybirdAuth();

	const request = async (path, init = {}) => {
		const url = new URL(path, formatHost(auth.host));
		const headers = {
			Authorization: `Bearer ${auth.token}`,
			...(init.headers ?? {}),
		};
		let response;
		try {
			response = await fetch(url, { ...init, headers });
		} catch (error) {
			const err = new Error(
				`Tinybird request failed: ${error instanceof Error ? error.message : String(error)}`,
			);
			err.cause = error;
			throw err;
		}
		const text = await response.text();
		let payload = text;
		try {
			payload = text ? JSON.parse(text) : {};
		} catch {
			// keep raw text when JSON parsing fails
		}

		if (!response.ok) {
			const message = payload?.error || payload?.message || response.statusText;
			const err = new Error(
				`Tinybird request failed (${response.status}): ${message}`,
			);
			err.status = response.status;
			err.payload = payload;
			throw err;
		}

		return payload;
	};

	const getResource = async (resourcePath, { allowNotFound = false } = {}) => {
		try {
			return await request(resourcePath);
		} catch (error) {
			if (allowNotFound && error.status === 404) return null;
			throw error;
		}
	};

	return {
		host: formatHost(auth.host),
		token: auth.token,
		userToken: auth.userToken,
		workspaceId: auth.workspaceId,
		workspaceName: auth.workspaceName,
		tinybPath: auth.tinybPath,
		request,
		getDatasource: (name, options) =>