Class Tinybird

packages/web-backend/src/Tinybird/index.ts:28–287

}

export class Tinybird extends Effect.Service<Tinybird>()("Tinybird", {
	effect: Effect.gen(function* () {
		const env = serverEnv();
		const token = env.TINYBIRD_TOKEN;
		const host = env.TINYBIRD_HOST;

		const enabled = Boolean(token && host);

		yield* Effect.logDebug("Initializing Tinybird service", {
			hasToken: Boolean(token),
			hasHost: Boolean(host),
			enabled,
		});

		if (!enabled) {
			yield* Effect.logWarning(
				"Tinybird is disabled: TINYBIRD_TOKEN and/or TINYBIRD_HOST not set",
			);
		}

		const request = <T>(path: string, init?: RequestInit) => {
			if (!enabled) return Effect.succeed<TinybirdResponse<T>>({ data: [] });

			return Effect.tryPromise({
				try: async () => {
					const url = `${host}/v0${path}`;
					const response = await fetch(url, {
						...init,
						headers: {
							Authorization: `Bearer ${token}`,
							Accept: "application/json",
							"Content-Type": "application/json",
							...(init?.headers ?? {}),
						},
					});

					const textBody = await response.text();

					if (!response.ok) {
						const errorMessage =
							textBody || `Tinybird request failed (${response.status})`;
						console.error("Tinybird request failed", {
							path,
							status: response.status,
							statusText: response.statusText,
							body: textBody,
						});
						throw new Error(errorMessage);
					}

					if (!textBody) {
						console.log("Tinybird empty response", { path });
						return { data: [] } as TinybirdResponse<T>;
					}

					let parsed: unknown;
					try {
						parsed = JSON.parse(textBody);