feat(gelios): expand safe B2 telemetry registry

packages/external-provider-contract/test/l2-execution-plan.test.mjs

@@ -17,6 +17,10 @@ import {
   geliosProviderPackageV11,
   geliosTelemetryFieldRegistryV4,
 } from "../providers/gelios/v11/index.mjs";
+import {
+  geliosProviderPackageV14,
+  geliosTelemetryFieldRegistryV6,
+} from "../providers/gelios/v14/index.mjs";
 
 const positionsConnection = instantiateL2Connection(geliosProviderPackageV11, {
   tenantId: "tenant-compiler-fixture",
@@ -122,6 +126,25 @@ assert.equal(Object.isFrozen(positionsPlan), true);
 assert.equal(Object.isFrozen(positionsPlan.steps), true);
 assert.equal(Object.isFrozen(positionsPlan.graphBlueprint), true);
 
+const operationalConnection = instantiateL2Connection(geliosProviderPackageV14, {
+  tenantId: "tenant-compiler-fixture",
+  connectionId: "gelios-operational-telemetry-fixture",
+  collectionProfileId: "gelios.positions.current.realtime.v7",
+  providerCredentialRef: "ndc-credref:provider-compiler-fixture-0001",
+});
+const operationalPlan = compileL2ExecutionPlan(
+  geliosProviderPackageV14,
+  operationalConnection,
+  { telemetryFieldRegistry: geliosTelemetryFieldRegistryV6 },
+);
+assert.deepEqual(validateL2ExecutionPlan(operationalPlan), { ok: true, errors: [] });
+assert.equal(
+  operationalPlan.steps
+    .find((step) => step.kind === "semantic_mapping")
+    .config.telemetryProjection.entries.length,
+  45,
+);
+
 const clonedPlan = compileL2ExecutionPlan(
   structuredClone(geliosProviderPackageV11),
   structuredClone(positionsConnection),

packages/external-provider-contract/test/provider-package.test.mjs

@@ -26,6 +26,7 @@ import { geliosProviderPackageV10 } from "../providers/gelios/v10/index.mjs";
 import { geliosProviderPackageV11 } from "../providers/gelios/v11/index.mjs";
 import { geliosProviderPackageV12 } from "../providers/gelios/v12/index.mjs";
 import { geliosProviderPackageV13 } from "../providers/gelios/v13/index.mjs";
+import { geliosProviderPackageV14 } from "../providers/gelios/v14/index.mjs";
 import { normalizeDataProductDefinition } from "../../../services/external-data-plane/src/data-product-policy.mjs";
 
 const expectedFields = [
@@ -57,6 +58,7 @@ assert.deepEqual(validateProviderPackage(geliosProviderPackageV10), { ok: true,
 assert.deepEqual(validateProviderPackage(geliosProviderPackageV11), { ok: true, errors: [] });
 assert.deepEqual(validateProviderPackage(geliosProviderPackageV12), { ok: true, errors: [] });
 assert.deepEqual(validateProviderPackage(geliosProviderPackageV13), { ok: true, errors: [] });
+assert.deepEqual(validateProviderPackage(geliosProviderPackageV14), { ok: true, errors: [] });
 assert.equal(geliosProviderPackageV9.id, "gelios.provider.v9");
 assert.equal(geliosProviderPackageV9.version, "9.0.0");
 assert.equal(geliosProviderPackageV10.id, "gelios.provider.v10");
@@ -67,6 +69,8 @@ assert.equal(geliosProviderPackageV12.id, "gelios.provider.v12");
 assert.equal(geliosProviderPackageV12.version, "12.0.1");
 assert.equal(geliosProviderPackageV13.id, "gelios.provider.v13");
 assert.equal(geliosProviderPackageV13.version, "13.0.0");
+assert.equal(geliosProviderPackageV14.id, "gelios.provider.v14");
+assert.equal(geliosProviderPackageV14.version, "14.0.0");
 assert.equal(geliosProviderPackageV8.id, "gelios.provider.v8");
 
 const profileProduct = geliosProviderPackageV8.dataProducts.find((product) => product.id === "fleet.units.profile.current.v1");
@@ -181,6 +185,7 @@ assert.equal(
   "first",
 );
 assert.equal(Object.isFrozen(geliosProviderPackageV13), true);
+assert.equal(Object.isFrozen(geliosProviderPackageV14), true);
 const identityMapping = geliosProviderPackageV11.mappingContracts.find(
   (mapping) => mapping.id === "gelios.units.to.fleet.units.identity.current.v1",
 );

packages/external-provider-contract/test/telemetry-field-registry.test.mjs

@@ -11,6 +11,9 @@ import {
 import {
   geliosTelemetryFieldRegistryV2,
 } from "../providers/gelios/v9/index.mjs";
+import {
+  geliosTelemetryFieldRegistryV6,
+} from "../providers/gelios/v14/index.mjs";
 
 assert.deepEqual(validateTelemetryFieldRegistry(geliosTelemetryFieldRegistryV1), {
   ok: true,
@@ -65,6 +68,57 @@ assert.notEqual(
   digestTelemetryFieldRegistry(geliosTelemetryFieldRegistryV1),
 );
 
+assert.deepEqual(validateTelemetryFieldRegistry(geliosTelemetryFieldRegistryV6), {
+  ok: true,
+  errors: [],
+});
+const operationalProjection = compileTelemetryFieldProjection(
+  geliosTelemetryFieldRegistryV6,
+  {
+    providerPackageId: "gelios.provider.v14",
+    providerPackageVersion: "14.0.0",
+    dataProductId: "fleet.positions.current.v5",
+    surface: "data_product",
+  },
+);
+assert.equal(operationalProjection.entries.length, 45);
+assert.deepEqual(
+  operationalProjection.entries
+    .filter((entry) => ["pwr_ext", "gsm_st", "nav_st"].includes(entry.sourceKey))
+    .map((entry) => ({
+      sourceKey: entry.sourceKey,
+      readingId: entry.reading.id,
+      labelSource: entry.reading.labelSource,
+      unitSource: entry.reading.unitSource,
+    })),
+  [
+    {
+      sourceKey: "gsm_st",
+      readingId: "sensor.param.gsm_st",
+      labelSource: "registry",
+      unitSource: "none",
+    },
+    {
+      sourceKey: "nav_st",
+      readingId: "sensor.param.nav_st",
+      labelSource: "registry",
+      unitSource: "none",
+    },
+    {
+      sourceKey: "pwr_ext",
+      readingId: "sensor.param.pwr_ext",
+      labelSource: "registry",
+      unitSource: "none",
+    },
+  ],
+);
+for (const forbiddenSourceKey of ["CID", "LAC", "MCC", "MNC", "imei", "commands"]) {
+  assert.equal(
+    operationalProjection.entries.some((entry) => entry.sourceKey === forbiddenSourceKey),
+    false,
+  );
+}
+
 const observedExposed = structuredClone(geliosTelemetryFieldRegistryV1);
 observedExposed.entries.find((entry) => entry.sourceKey === "in_0").allowedSurfaces.push("foundry");
 assert.equal(