chore: upd observability (#1678)

Author: vrcprl

.changeset/fix-tracking-event-pairs.md

@@ -0,0 +1,5 @@
+---
+"lingo.dev": patch
+---
+
+Fix inconsistent event tracking in CLI to ensure start/success/error events are always paired correctly for accurate health metrics

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

@@ -93,6 +93,10 @@ export default new Command()
   .action(async function (options) {
     updateGitignore();
 
+    await trackEvent(null, "cmd.i18n.start", {
+      rawOptions: options,
+    });
+
     const ora = Ora();
     let flags: ReturnType<typeof parseFlags>;
 
@@ -109,6 +113,7 @@ export default new Command()
         errorCount: 1,
         stage: "flag_validation",
       });
+      await new Promise((resolve) => setTimeout(resolve, 50));
       throw parseError;
     }
 
@@ -148,11 +153,6 @@ export default new Command()
         ora.succeed(`Authenticated as ${auth.email}`);
       }
 
-      await trackEvent(authId, "cmd.i18n.start", {
-        i18nConfig,
-        flags,
-      });
-
       let buckets = getBuckets(i18nConfig!);
       if (flags.bucket?.length) {
         buckets = buckets.filter((bucket: any) =>
@@ -579,6 +579,7 @@ export default new Command()
           localeCount: targetLocales.length,
           processedSuccessfully: true,
         });
+        await new Promise((resolve) => setTimeout(resolve, 50));
       } else {
         ora.warn("Localization completed with errors.");
         await trackEvent(authId, "cmd.i18n.error", {
@@ -590,6 +591,7 @@ export default new Command()
             i18nConfig!,
           ),
         });
+        await new Promise((resolve) => setTimeout(resolve, 50));
       }
     } catch (error: any) {
       ora.fail(error.message);
@@ -623,6 +625,7 @@ export default new Command()
         errorCount: errorDetails.length + 1,
         previousErrors: createPreviousErrorContext(errorDetails),
       });
+      await new Promise((resolve) => setTimeout(resolve, 50));
     }
   });
 

packages/cli/src/cli/cmd/run/index.ts

@@ -173,8 +173,10 @@ export default new Command()
         config: ctx.config,
         flags: ctx.flags,
       });
+      await new Promise((resolve) => setTimeout(resolve, 50));
     } catch (error: any) {
       await trackEvent(authId, "cmd.run.error", {});
+      await new Promise((resolve) => setTimeout(resolve, 50));
       // Play sad sound if sound flag is enabled
       if (args.sound) {
         await playSound("failure");

packages/cli/src/cli/cmd/status.ts

@@ -636,6 +636,7 @@ export default new Command()
         totalWordsToTranslate,
         authenticated: !!authId,
       });
+      await new Promise((resolve) => setTimeout(resolve, 50));
       exitGracefully();
     } catch (error: any) {
       ora.fail(error.message);
@@ -644,6 +645,7 @@ export default new Command()
         error: error.message,
         authenticated: !!authId,
       });
+      await new Promise((resolve) => setTimeout(resolve, 50));
       process.exit(1);
     }
   });

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

@@ -6,7 +6,7 @@ import { getRepositoryId } from "./repository-id";
 const POSTHOG_API_KEY = "phc_eR0iSoQufBxNY36k0f0T15UvHJdTfHlh8rJcxsfhfXk";
 const POSTHOG_HOST = "eu.i.posthog.com";
 const POSTHOG_PATH = "/i/v0/e/";
-const REQUEST_TIMEOUT_MS = 1000;
+const REQUEST_TIMEOUT_MS = 3000;
 const TRACKING_VERSION = "2.0";
 
 function determineDistinctId(providedId: string | null | undefined): {