From 3b7e838188671ae1b2d0ddc02773b4fe6105f3c2 Mon Sep 17 00:00:00 2001
From: Julius Marminge <julius0216@outlook.com>
Date: Wed, 1 Apr 2026 00:27:52 -0700
Subject: [PATCH] migrate Effect.fn in
 apps/server/src/telemetry/Layers/AnalyticsService.ts

Co-authored-by: codex <codex@users.noreply.github.com>
---
 .../src/telemetry/Layers/AnalyticsService.ts  | 57 ++++++++++---------
 1 file changed, 29 insertions(+), 28 deletions(-)

diff --git a/apps/server/src/telemetry/Layers/AnalyticsService.ts b/apps/server/src/telemetry/Layers/AnalyticsService.ts
index 297776f9db..06ecfd0237 100644
--- a/apps/server/src/telemetry/Layers/AnalyticsService.ts
+++ b/apps/server/src/telemetry/Layers/AnalyticsService.ts
@@ -70,34 +70,35 @@ const makeAnalyticsService = Effect.gen(function* () {
       }),
     );
 
-  const sendBatch = (events: ReadonlyArray<BufferedAnalyticsEvent>) =>
-    Effect.gen(function* () {
-      if (!telemetryConfig.enabled || !identifier) return;
-
-      const payload = {
-        api_key: telemetryConfig.posthogKey,
-        batch: events.map((event) => ({
-          event: event.event,
-          distinct_id: identifier,
-          properties: {
-            ...event.properties,
-            $process_person_profile: false,
-            platform: process.platform,
-            wsl: process.env.WSL_DISTRO_NAME,
-            arch: process.arch,
-            t3CodeVersion: version,
-            clientType,
-          },
-          timestamp: event.capturedAt,
-        })),
-      };
-
-      yield* HttpClientRequest.post(`${telemetryConfig.posthogHost}/batch/`).pipe(
-        HttpClientRequest.bodyJson(payload),
-        Effect.flatMap(httpClient.execute),
-        Effect.flatMap(HttpClientResponse.filterStatusOk),
-      );
-    });
+  const sendBatch = Effect.fn("sendBatch")(function* (
+    events: ReadonlyArray<BufferedAnalyticsEvent>,
+  ) {
+    if (!telemetryConfig.enabled || !identifier) return;
+
+    const payload = {
+      api_key: telemetryConfig.posthogKey,
+      batch: events.map((event) => ({
+        event: event.event,
+        distinct_id: identifier,
+        properties: {
+          ...event.properties,
+          $process_person_profile: false,
+          platform: process.platform,
+          wsl: process.env.WSL_DISTRO_NAME,
+          arch: process.arch,
+          t3CodeVersion: version,
+          clientType,
+        },
+        timestamp: event.capturedAt,
+      })),
+    };
+
+    yield* HttpClientRequest.post(`${telemetryConfig.posthogHost}/batch/`).pipe(
+      HttpClientRequest.bodyJson(payload),
+      Effect.flatMap(httpClient.execute),
+      Effect.flatMap(HttpClientResponse.filterStatusOk),
+    );
+  });
 
   const flush: AnalyticsServiceShape["flush"] = Effect.gen(function* () {
     while (true) {