fix(analytics): flush posthog events on SIGTERM before ECS task termination

Author: waleedlatif1

apps/sim/instrumentation-node.ts

@@ -147,6 +147,14 @@ async function initializeOpenTelemetry() {
       } catch (err) {
         logger.error('Error shutting down OpenTelemetry SDK', err)
       }
+
+      try {
+        const { getPostHogClient } = await import('@/lib/posthog/server')
+        await getPostHogClient()?.shutdown()
+        logger.info('PostHog client shut down successfully')
+      } catch (err) {
+        logger.error('Error shutting down PostHog client', err)
+      }
     }
 
     process.on('SIGTERM', shutdownHandler)

apps/sim/lib/posthog/server.ts

@@ -6,6 +6,10 @@ const logger = createLogger('PostHogServer')
 let _client: import('posthog-node').PostHog | null = null
 let _disabled = false
 
+export function getPostHogClient(): import('posthog-node').PostHog | null {
+  return getClient()
+}
+
 function getClient(): import('posthog-node').PostHog | null {
   if (_disabled) return null
   if (_client) return _client