import { PostHog } from "posthog-node";
import { USER_ID, WORKSPACE_ID } from "./si_client.ts";
export class Analytics {
private posthog: PostHog | null = null;
private sessionId: string;
constructor() {
this.sessionId = crypto.randomUUID();
this.initializePostHog();
}
private initializePostHog() {
const apiKey = Deno.env.get("POSTHOG_API_KEY") ||
"phc_KpehlXOqtU44B2MeW6WjqR09NxRJCYEiUReA58QcAYK"; // Prod Posthog
const host = Deno.env.get("POSTHOG_HOST") || "https://e.systeminit.com";
if (apiKey) {
this.posthog = new PostHog(apiKey, { host });
}
}
private getDistinctId(): string {
return USER_ID;
}
private getWorkspaceId(): string {
return WORKSPACE_ID;
}
identifyUser() {
if (!this.posthog || !USER_ID) return;
this.posthog.identify({
distinctId: USER_ID,
properties: {
userId: USER_ID,
},
});
}
trackEvent(eventName: string, properties: Record<string, unknown> = {}) {
if (!this.posthog) return;
const event = `mcp-${eventName}`;
try {
this.posthog.capture({
distinctId: this.getDistinctId(),
event,
properties: {
$session_id: this.sessionId, // PostHog standard session property
workspace_id: this.getWorkspaceId(),
...properties,
},
});
} catch (error) {
console.error("Analytics tracking failed:", error);
}
}
trackToolUsage(toolName: string, executionTimeMs: number) {
this.trackEvent("tool_used", {
toolName,
executionTimeMs,
});
}
trackError(toolName: string, errorProperties?: Record<string, unknown>) {
this.trackEvent("tool_error", {
toolName,
...errorProperties,
});
}
trackServerStart() {
this.trackEvent("server_started");
}
trackServerEnd() {
this.trackEvent("server_ended");
if (this.posthog) {
this.posthog.shutdown();
}
}
}
export const analytics = new Analytics();
