CLOUDP-294461: [Product Metrics/Observability] Implement Metric Collection workflow

Author: yelizhenden-mdb

package.json

@@ -1,6 +1,7 @@
 {
     "name": "mongodb-openapi",
     "description": "MongoDB repository with OpenAPI specification",
+    "type": "module",
     "scripts": {
         "format": "npx prettier . --write",
         "format-check": "npx prettier . --check",

tools/spectral/ipa/metrics/metricCollection.js

@@ -0,0 +1,50 @@
+import spectral from '@stoplight/spectral-core';
+import { fileURLToPath } from 'node:url';
+import * as fs from 'node:fs';
+import * as path from 'node:path';
+import { loadOpenAPIFile, extractTeamOwnership, loadRuleset, loadCollectorResults, getSeverityPerRule, merge } from './utils.js';
+const { Spectral } = spectral;
+
+//TBD
+const oasFile = '../../../../openapi/v2.json';
+const dirname = path.dirname(fileURLToPath(import.meta.url));
+const collectorResultsFile = path.join(dirname, '../ipa-collector-results-combined.log');
+
+
+async function runMetricCollectionJob() {
+  try {
+    console.log('Loading OpenAPI file...');
+    const oasContent = loadOpenAPIFile(oasFile);
+
+    console.log('Extracting team ownership data...');
+    const ownershipData = extractTeamOwnership(oasContent);
+
+    console.log('Initializing Spectral...');
+    const spectral = new Spectral();
+    const rulesetPath = path.join(dirname, '../ipa-spectral.yaml');
+    const ruleset = await loadRuleset(rulesetPath, spectral);
+
+    console.log('Getting rule severities...');
+    const ruleSeverityMap = getSeverityPerRule(ruleset);
+
+    console.log('Running Spectral analysis...');
+    const spectralResults = await spectral.run(oasContent);
+
+    console.log('Loading collector results...');
+    const collectorResults = loadCollectorResults(collectorResultsFile);
+
+    console.log('Merging results...');
+    const mergedResults = merge(spectralResults, ownershipData, collectorResults, ruleSeverityMap);
+
+    console.log('Metric collection job complete.');
+    return mergedResults;
+  } catch (error) {
+    console.error('Error during metric collection:', error.message);
+    throw error;
+  }
+}
+
+
+runMetricCollectionJob()
+  .then((results) => fs.writeFileSync('results.log', JSON.stringify(results)))
+  .catch((error) => console.error(error.message));

tools/spectral/ipa/metrics/utils.js

@@ -0,0 +1,110 @@
+import fs from 'node:fs';
+import {
+  bundleAndLoadRuleset
+} from '@stoplight/spectral-ruleset-bundler/with-loader';
+import { EntryType } from './collector.js';
+
+export function loadOpenAPIFile(filePath) {
+  try {
+    const content = fs.readFileSync(filePath, 'utf8');
+    return JSON.parse(content);
+  } catch (error) {
+    throw new Error(`Failed to load OpenAPI file: ${error.message}`);
+  }
+}
+
+export function getSeverityPerRule(ruleset) {
+  const rules = ruleset.rules || {};
+  const map = {};
+  for (const [name, ruleObject] of Object.entries(rules)) {
+    map[name] = ruleObject.definition.severity;
+  }
+  return map;
+}
+
+export async function loadRuleset(rulesetPath, spectral) {
+  try {
+    const ruleset = await bundleAndLoadRuleset(rulesetPath, { fs, fetch });
+    await spectral.setRuleset(ruleset);
+    return ruleset;
+  } catch (error) {
+    throw new Error(`Failed to load ruleset: ${error.message}`);
+  }
+}
+
+export function extractTeamOwnership(oasContent) {
+  const ownerTeams = {};
+  const paths = oasContent.paths || {};
+
+  for (const [path, pathItem] of Object.entries(paths)) {
+    for (const [, operation] of Object.entries(pathItem)) {
+      const ownerTeam = operation['x-xgen-owner-team'];
+
+      if (ownerTeam) {
+        if (!ownerTeams[path]) {
+          ownerTeams[path] = ownerTeam;
+        } else if (ownerTeams[path] !== ownerTeam) {
+          console.warn(`Conflict on path ${path}: ${ownerTeams[path]} vs ${ownerTeam}`);
+        }
+      }
+    }
+  }
+
+  return ownerTeams;
+}
+
+export function loadCollectorResults(collectorResultsFilePath) {
+  try {
+    const content = fs.readFileSync(collectorResultsFilePath, 'utf8');
+    const contentParsed = JSON.parse(content);
+    return {
+      [EntryType.VIOLATION]: contentParsed[EntryType.VIOLATION],
+      [EntryType.ADOPTION]: contentParsed[EntryType.ADOPTION],
+      [EntryType.EXCEPTION]: contentParsed[EntryType.EXCEPTION],
+    };
+  } catch (error) {
+    throw new Error(`Failed to load Collector Results file: ${error.message}`);
+  }
+}
+
+function getIPAFromIPARule(ipaRule) {
+  const pattern = /IPA-\d{3}/;
+  const match = ipaRule.match(pattern);
+  if (match) {
+    return match[0];
+  }
+}
+
+export function merge(spectralResults, ownershipData, collectorResults, ruleSeverityMap) {
+  const results = [];
+
+  function addEntry(entryType, adoptionStatus) {
+    for (const entry of collectorResults[entryType]) {
+      const existing = results.find((result) =>
+        result.component_id === entry.componentId && result.ipa_rule === entry.ruleName
+      );
+
+      if (existing) {
+        console.warn('Duplicate entries found', existing);
+        continue;
+      }
+
+      results.push({
+        component_id: entry.componentId,
+        ipa_rule: entry.ruleName,
+        ipa: getIPAFromIPARule(entry.ruleName),
+        severity_level: ruleSeverityMap[entry.ruleName],
+        adoption_status: adoptionStatus,
+        exception_reason: entryType === EntryType.EXCEPTION ? entry.exceptionReason : null,
+        owner_team: entry.ownerTeam || null,
+        timestamp: new Date().toISOString(),
+      });
+    }
+  }
+
+  addEntry(EntryType.VIOLATION, 'violated');
+  addEntry(EntryType.ADOPTION, 'adopted');
+  addEntry(EntryType.EXCEPTION, 'exempted');
+
+  return results;
+}