fix(wasm): preserve sdk info in telemetry data during flush

bounded_flush_logs was overwriting telemetry_data from the resolve
logger (which contains sdk info) with the delta snapshot from the
Telemetry module (which always has sdk: None). This caused sdk_id
to never appear in VictoriaMetrics.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: nicklasl

openfeature-provider/js/proto/test-only.proto

@@ -9,9 +9,22 @@ message WriteFlagLogsRequest {
   repeated bytes flag_resolve_info = 4;
 }
 
+message Sdk {
+  oneof sdk {
+    SdkId id = 1;
+    string custom_id = 2;
+  }
+  string version = 3;
+}
+
+enum SdkId {
+  SDK_ID_UNSPECIFIED = 0;
+  SDK_ID_JS_LOCAL_SERVER_PROVIDER = 22;
+}
+
 message TelemetryData {
   // Information about the SDK/provider
-  // Sdk sdk = 2;
+  Sdk sdk = 2;
 
   ResolveLatency resolve_latency = 4;
   repeated ResolveRate resolve_rate = 5;

openfeature-provider/js/src/WasmResolver.test.ts

@@ -2,8 +2,8 @@ import { beforeEach, describe, expect, it, vi } from 'vitest';
 import { UnsafeWasmResolver, WasmResolver } from './WasmResolver';
 import { readFileSync } from 'node:fs';
 import { ResolveProcessRequest } from './proto/confidence/wasm/wasm_api';
-import { ResolveReason } from './proto/confidence/flags/resolver/v1/types';
-import { WriteFlagLogsRequest } from './proto/test-only';
+import { ResolveReason, SdkId } from './proto/confidence/flags/resolver/v1/types';
+import { SdkId as TestSdkId, WriteFlagLogsRequest } from './proto/test-only';
 
 const moduleBytes = readFileSync(__dirname + '/../../../wasm/confidence_resolver.wasm');
 const stateBytes = readFileSync(__dirname + '/../../../wasm/resolver_state.pb');
@@ -138,6 +138,31 @@ describe('basic operation', () => {
           expect(total).toBeGreaterThan(0);
         }
       });
+
+      it('should include sdk info in telemetry data', () => {
+        const requestWithSdk: ResolveProcessRequest = {
+          deferredMaterializations: {
+            ...RESOLVE_REQUEST.deferredMaterializations!,
+            sdk: {
+              id: SdkId.SDK_ID_JS_LOCAL_SERVER_PROVIDER,
+              version: '1.0.0',
+            },
+          },
+        };
+        wasmResolver.resolveProcess(requestWithSdk);
+
+        const decoded = WriteFlagLogsRequest.decode(wasmResolver.flushLogs());
+        const telemetry = decoded.telemetryData;
+
+        expect(telemetry).toBeDefined();
+        // SDK info must be preserved alongside telemetry metrics
+        expect(telemetry!.sdk).toBeDefined();
+        expect(telemetry!.sdk!.id).toBe(TestSdkId.SDK_ID_JS_LOCAL_SERVER_PROVIDER);
+        expect(telemetry!.sdk!.version).toBe('1.0.0');
+        // Telemetry metrics should also be present
+        expect(telemetry!.resolveRate.length).toBeGreaterThan(0);
+        expect(telemetry!.resolveLatency).toBeDefined();
+      });
     });
   });
 });

wasm/rust-guest/src/lib.rs

@@ -188,7 +188,12 @@ wasm_msg_guest! {
 
     fn bounded_flush_logs(_request:Void) -> WasmResult<WriteFlagLogsRequest> {
         let mut req = RESOLVE_LOGGER.checkpoint();
-        req.telemetry_data = Some(TELEMETRY.delta_snapshot(&LAST_FLUSHED));
+        let mut telemetry = TELEMETRY.delta_snapshot(&LAST_FLUSHED);
+        // Preserve SDK info from resolve logger (delta_snapshot doesn't track it)
+        if let Some(existing_td) = &req.telemetry_data {
+            telemetry.sdk = existing_td.sdk.clone();
+        }
+        req.telemetry_data = Some(telemetry);
         ASSIGN_LOGGER.checkpoint_fill_with_limit(&mut req, LOG_TARGET_BYTES, false);
         Ok(req)
     }