Function sendErrorEventToTinybird

shared/events.ts:94–121

(
    event: TinybirdErrorEvent,
    tinybirdIngestUrl: string,
    tinybirdIngestToken: string,
    log: Logger,
)

}

export async function sendErrorEventToTinybird(
    event: TinybirdErrorEvent,
    tinybirdIngestUrl: string,
    tinybirdIngestToken: string,
    log: Logger,
): Promise<void> {
    const body = JSON.stringify(removeUnset(event));

    try {
        const response = await fetch(tinybirdIngestUrl, {
            method: "POST",
            headers: {
                Authorization: `Bearer ${tinybirdIngestToken}`,
                "Content-Type": "application/x-ndjson",
            },
            body,
            signal: AbortSignal.timeout(5000),
        });

        if (!response.ok) {
            log.warn("Tinybird error event ingest failed: status={status}", {
                status: response.status,
            });
        }
    } catch (error) {
        log.warn("Tinybird error event ingest failed: {error}", { error });
    }
}

export function getTinybirdDatasourceIngestUrl(
    referenceIngestUrl: string,