fix(ipa): fix import issue with parquet-wasm package

Author: matt-condon

tools/spectral/ipa/metrics/scripts/parquet-wasm-wrapper.cjs

@@ -0,0 +1,35 @@
+/**
+ * CommonJS wrapper for parquet-wasm
+ *
+ * This wrapper allows us to use parquet-wasm 0.7.0 from ES modules in Node.js.
+ *
+ * Background: parquet-wasm 0.7.0 has package.json with "type": "module" which makes
+ * Node.js treat .js files as ES modules. However, the node build uses CommonJS syntax.
+ *
+ * Solution: Since this file has a .cjs extension, Node.js always treats it as CommonJS,
+ * allowing us to use require(). We then use createRequire() in our ES module to load this wrapper.
+ *
+ * See: https://github.com/kylebarron/parquet-wasm/issues/798
+ */
+
+const path = require('path');
+const fs = require('fs');
+
+// Read and eval the parquet-wasm node build
+// We use eval because require() won't work due to the "type": "module" in package.json
+const parquetWasmPath = path.resolve(
+  __dirname,
+  '../../../../../node_modules/parquet-wasm/node/parquet_wasm.js',
+);
+
+const code = fs.readFileSync(parquetWasmPath, 'utf8');
+const moduleExports = {};
+const moduleObj = { exports: moduleExports };
+
+// Execute the code in a function scope with CommonJS globals
+const fn = new Function('exports', 'require', 'module', '__filename', '__dirname', code);
+fn(moduleExports, require, moduleObj, parquetWasmPath, path.dirname(parquetWasmPath));
+
+// Re-export everything
+module.exports = moduleObj.exports;
+

tools/spectral/ipa/metrics/scripts/runMetricCollection.js

@@ -2,12 +2,19 @@ import fs from 'node:fs';
 import path from 'path';
 import { spawnSync } from 'child_process';
 import spectral from '@stoplight/spectral-core';
-import { Table, writeParquet, WriterPropertiesBuilder } from 'parquet-wasm/esm/parquet_wasm.js';
 import { tableFromJSON, tableToIPC } from 'apache-arrow';
 import config from '../config.js';
 import { runMetricCollectionJob } from '../metricCollection.js';
+import { createRequire } from 'module';
 
 const { Spectral } = spectral;
+
+// Use createRequire to load our CommonJS wrapper for parquet-wasm
+// This allows us to use parquet-wasm 0.7.0 from Node.js ESM
+// See parquet-wasm-wrapper.cjs for details
+const require = createRequire(import.meta.url);
+const { Compression, Table, writeParquet, WriterPropertiesBuilder } = require('./parquet-wasm-wrapper.cjs');
+
 const args = process.argv.slice(2);
 const oasFilePath = args[0];
 
@@ -53,19 +60,42 @@ runMetricCollectionJob(
   new Spectral()
 )
   .then((results) => {
-    console.log('Writing results');
-    const table = tableFromJSON(results.metrics);
-    const wasmTable = Table.fromIPCStream(tableToIPC(table, 'stream'));
-    const parquetUint8Array = writeParquet(
-      wasmTable,
-      new WriterPropertiesBuilder().setCompression(2).build() // 2 = GZIP compression
-    );
-    fs.writeFileSync(config.defaultMetricCollectionResultsFilePath, parquetUint8Array);
-    fs.writeFileSync(path.join(config.defaultOutputsDir, 'warning-count.txt'), results.warnings.count.toString());
-
-    fs.writeFileSync(
-      path.join(config.defaultOutputsDir, 'warning-violations.json'),
-      JSON.stringify(results.warnings.violations, null, 2)
-    );
+    console.log('Writing results to parquet file...');
+
+    try {
+      console.log('Converting metrics to Arrow table...');
+      const table = tableFromJSON(results.metrics);
+
+      console.log('Converting Arrow table to WASM table...');
+      const wasmTable = Table.fromIPCStream(tableToIPC(table, 'stream'));
+
+      console.log('Writing parquet file with GZIP compression...');
+      const parquetUint8Array = writeParquet(
+        wasmTable,
+        new WriterPropertiesBuilder().setCompression(Compression.GZIP).build()
+      );
+
+      console.log(`Saving parquet file to: ${config.defaultMetricCollectionResultsFilePath}`);
+      fs.writeFileSync(config.defaultMetricCollectionResultsFilePath, parquetUint8Array);
+
+      console.log('Writing warning count...');
+      fs.writeFileSync(path.join(config.defaultOutputsDir, 'warning-count.txt'), results.warnings.count.toString());
+
+      console.log('Writing warning violations...');
+      fs.writeFileSync(
+        path.join(config.defaultOutputsDir, 'warning-violations.json'),
+        JSON.stringify(results.warnings.violations, null, 2)
+      );
+
+      console.log('Metric collection completed successfully!');
+    } catch (error) {
+      console.error('Error writing results:', error.message);
+      console.error('Stack trace:', error.stack);
+      process.exit(1);
+    }
   })
-  .catch((error) => console.error(error.message));
+  .catch((error) => {
+    console.error('Error during metric collection:', error.message);
+    console.error('Stack trace:', error.stack);
+    process.exit(1);
+  });