cal.pub0.org/packages/lib/telemetry.ts

116 lines
3.5 KiB
TypeScript

import type { NextApiRequest, NextApiResponse } from "next";
import type { CollectOpts, EventHandler } from "next-collect";
import { useCollector } from "next-collect/client";
// Importing types so we're not directly importing next/server
import type { NextRequest, NextResponse } from "next/server";
import { CONSOLE_URL } from "./constants";
export const telemetryEventTypes = {
pageView: "page_view",
apiCall: "api_call",
bookingConfirmed: "booking_confirmed",
bookingCancelled: "booking_cancelled",
importSubmitted: "import_submitted",
login: "login",
embedView: "embed_view",
embedBookingConfirmed: "embed_booking_confirmed",
onboardingFinished: "onboarding_finished",
onboardingStarted: "onboarding_started",
signup: "signup",
team_created: "team_created",
website: {
pageView: "website_page_view",
},
};
export function collectPageParameters(
route?: string,
extraData: Record<string, unknown> = {}
): Record<string, unknown> {
const host = document.location.host;
const docPath = route ?? "";
return {
page_url: route,
doc_encoding: document.characterSet,
url: document.location.protocol + "//" + host + (docPath ?? ""),
...extraData,
};
}
const reportUsage: EventHandler = async (event, { fetch }) => {
const ets = telemetryEventTypes;
if ([ets.bookingConfirmed, ets.embedBookingConfirmed].includes(event.eventType)) {
const key = process.env.CALCOM_LICENSE_KEY;
const url = `${CONSOLE_URL}/api/deployments/usage?key=${key}&quantity=1`;
try {
return fetch(url, { method: "POST", mode: "cors" });
} catch (e) {
console.error(`Error reporting booking for key: '${key}'`, e);
return Promise.resolve();
}
} else {
return Promise.resolve();
}
};
export const nextCollectBasicSettings: CollectOpts = {
drivers: [
process.env.CALCOM_LICENSE_KEY && process.env.NEXT_PUBLIC_IS_E2E !== "1" ? reportUsage : undefined,
process.env.CALCOM_TELEMETRY_DISABLED === "1" || process.env.NEXT_PUBLIC_IS_E2E === "1"
? undefined
: {
type: "jitsu",
opts: {
key: "s2s.2pvs2bbpqq1zxna97wcml.esb6cikfrf7yn0qoh1nj1",
server: "https://t.calendso.com",
},
},
process.env.TELEMETRY_DEBUG && { type: "echo", opts: { disableColor: true } },
],
eventTypes: [
{ "*.ttf": null },
{ "*.webmanifest": null },
{ "*.json": null },
{ "*.svg": null },
{ "*.map": null },
{ "*.png": null },
{ "*.gif": null },
{ "/api/collect-events": null },
{ "/api*": null },
{ "/img*": null },
{ "/favicon*": null },
{ "/*": telemetryEventTypes.pageView },
],
};
export const extendEventData = (
req: NextRequest | NextApiRequest,
res: NextResponse | NextApiResponse,
original: any
) => {
const onVercel =
typeof req.headers?.get === "function"
? !!req.headers.get("x-vercel-id")
: !!(req.headers as any)?.["x-vercel-id"];
const pageUrl = original?.page_url || req.url || undefined;
const cookies = req.cookies as { [key: string]: any };
return {
title: "",
ipAddress: "",
queryString: "",
page_url: pageUrl,
licensekey: process.env.CALCOM_LICENSE_KEY,
isTeamBooking:
original?.isTeamBooking === undefined
? pageUrl?.includes("team/") || undefined
: original?.isTeamBooking,
referrer: "",
onVercel,
isAuthorized: !!cookies["next-auth.session-token"] || !!cookies["__Secure-next-auth.session-token"],
utc_time: new Date().toISOString(),
};
};
export const useTelemetry = useCollector;