chore: add observability

Author: maxprilutskiy

packages/cli/package.json

@@ -103,6 +103,7 @@
     "p-limit": "^6.2.0",
     "php-array-reader": "^2.1.2",
     "plist": "^3.1.0",
+    "posthog-node": "^4.11.2",
     "prettier": "^3.4.2",
     "properties-parser": "^0.6.0",
     "slugify": "^1.6.6",

packages/cli/src/cli/cmd/i18n.ts

@@ -18,6 +18,7 @@ import { cacheChunk, deleteCache, getNormalizedCache } from "../utils/cache";
 import updateGitignore from "../utils/update-gitignore";
 import createProcessor from "../processor";
 import { withExponentialBackoff } from "../utils/exp-backoff";
+import trackEvent from "../utils/observability";
 
 export default new Command()
   .command("i18n")
@@ -61,6 +62,7 @@ export default new Command()
     }
 
     let hasErrors = false;
+    let authId: string | null = null;
     try {
       ora.start("Loading configuration...");
       const i18nConfig = getConfig();
@@ -73,8 +75,14 @@ export default new Command()
 
       ora.start("Connecting to Lingo.dev Localization Engine...");
       const auth = await validateAuth(settings);
+      authId = auth.id;
       ora.succeed(`Authenticated as ${auth.email}`);
 
+      trackEvent(authId, "cmd.i18n.start", {
+        i18nConfig,
+        flags,
+      });
+
       let buckets = getBuckets(i18nConfig!);
       if (flags.bucket?.length) {
         buckets = buckets.filter((bucket: any) => flags.bucket!.includes(bucket.type));
@@ -393,11 +401,20 @@ export default new Command()
         if (flags.verbose) {
           ora.info("Cache file deleted.");
         }
+        trackEvent(auth.id, "cmd.i18n.success", {
+          i18nConfig,
+          flags,
+        });
       } else {
         ora.warn("Localization completed with errors.");
       }
     } catch (error: any) {
       ora.fail(error.message);
+
+      trackEvent(authId || "unknown", "cmd.i18n.error", {
+        flags,
+        error,
+      });
       process.exit(1);
     }
   });

packages/cli/src/cli/utils/auth.ts

@@ -7,6 +7,7 @@ export type AuthenticatorParams = {
 
 export type AuthPayload = {
   email: string;
+  id: string;
 };
 
 export function createAuthenticator(params: AuthenticatorParams) {
@@ -29,6 +30,7 @@ export function createAuthenticator(params: AuthenticatorParams) {
 
           return {
             email: payload.email,
+            id: payload.id,
           };
         }
 

packages/cli/src/cli/utils/observability.ts

@@ -0,0 +1,17 @@
+import { PostHog } from "posthog-node";
+
+export default async function trackEvent(distinctId: string, event: string, properties?: Record<string, any>) {
+  if (process.env.DO_NOT_TRACK) {
+    return;
+  }
+
+  const posthog = new PostHog("phc_eR0iSoQufBxNY36k0f0T15UvHJdTfHlh8rJcxsfhfXk", {
+    host: "https://eu.i.posthog.com",
+  });
+
+  await posthog.capture({
+    distinctId,
+    event,
+    properties,
+  });
+}