Merge branch 'main' into deepme987/feat/missing-node-telemetry

Align frontend event name with backend convention: both now use
node_missing (was missing_nodes_detected). Matches node_usage pattern.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

src/platform/telemetry/initTelemetry.ts

@@ -25,13 +25,15 @@ export async function initTelemetry(): Promise<void> {
       { MixpanelTelemetryProvider },
       { GtmTelemetryProvider },
       { ImpactTelemetryProvider },
-      { PostHogTelemetryProvider }
+      { PostHogTelemetryProvider },
+      { ClickHouseTelemetryProvider }
     ] = await Promise.all([
       import('./TelemetryRegistry'),
       import('./providers/cloud/MixpanelTelemetryProvider'),
       import('./providers/cloud/GtmTelemetryProvider'),
       import('./providers/cloud/ImpactTelemetryProvider'),
-      import('./providers/cloud/PostHogTelemetryProvider')
+      import('./providers/cloud/PostHogTelemetryProvider'),
+      import('./providers/cloud/ClickHouseTelemetryProvider')
     ])
 
     const registry = new TelemetryRegistry()
@@ -39,6 +41,7 @@ export async function initTelemetry(): Promise<void> {
     registry.registerProvider(new GtmTelemetryProvider())
     registry.registerProvider(new ImpactTelemetryProvider())
     registry.registerProvider(new PostHogTelemetryProvider())
+    registry.registerProvider(new ClickHouseTelemetryProvider())
 
     setTelemetryRegistry(registry)
   })()

src/platform/telemetry/providers/cloud/ClickHouseTelemetryProvider.ts

@@ -0,0 +1,45 @@
+import { api } from '@/scripts/api'
+
+import type { TelemetryProvider, WorkflowImportMetadata } from '../../types'
+
+/**
+ * ClickHouse Telemetry Provider - Cloud Build Implementation
+ *
+ * Sends observability events to the cloud backend's ClickHouse pipeline
+ * via POST /api/internal/cloud_analytics. Currently tracks missing node
+ * data when users open/import workflows with unsupported nodes.
+ *
+ * This provider is separate from Mixpanel because ClickHouse is the
+ * canonical store for post-hoc analytics (per observability philosophy).
+ *
+ * CRITICAL: OSS Build Safety
+ * This file is tree-shaken away in OSS builds (DISTRIBUTION unset).
+ */
+export class ClickHouseTelemetryProvider implements TelemetryProvider {
+  trackWorkflowImported(metadata: WorkflowImportMetadata): void {
+    this.reportMissingNodes(metadata)
+  }
+
+  trackWorkflowOpened(metadata: WorkflowImportMetadata): void {
+    this.reportMissingNodes(metadata)
+  }
+
+  private reportMissingNodes(metadata: WorkflowImportMetadata): void {
+    if (metadata.missing_node_count <= 0) return
+
+    api
+      .fetchApi('/internal/cloud_analytics', {
+        method: 'POST',
+        headers: { 'Content-Type': 'application/json' },
+        body: JSON.stringify({
+          event_name: 'node_missing',
+          event_data: {
+            missing_class_types: metadata.missing_node_types,
+            missing_count: metadata.missing_node_count,
+            source: metadata.open_source ?? 'unknown'
+          }
+        })
+      })
+      .catch(() => {})
+  }
+}