Function sendBatch

packages/core/analytics/src/analytics.ts:166–188

(events: ReadonlyArray<BufferedEvent>)

      const posthogKey = config.posthogKey ?? DEFAULT_POSTHOG_KEY;

      const sendBatch = (events: ReadonlyArray<BufferedEvent>) =>
        HttpClientRequest.post(`${posthogHost}/batch/`).pipe(
          HttpClientRequest.bodyJson({
            api_key: posthogKey,
            batch: events.map((entry) => ({
              event: entry.event,
              distinct_id: distinctId,
              timestamp: entry.timestamp,
              properties: {
                ...entry.properties,
                // Anonymous events only: never materialize a person profile.
                $process_person_profile: false,
                surface: config.surface,
                channel: config.channel,
                app_version: config.version,
              },
            })),
          }),
          Effect.flatMap(http.execute),
          Effect.flatMap(HttpClientResponse.filterStatusOk),
          Effect.asVoid,
          Effect.timeout(Duration.seconds(10)),
        );

      const flush: Effect.Effect<void> = Effect.gen(function* () {
        while (true) {