metabuilder/scripts/fix-workflow-parameters.js

#!/usr/bin/env node

/**
 * Fix Workflow Parameters Script
 *
 * Flattens nested parameters in already-migrated workflows that have
 * deeply nested structure due to the migration script wrapping parameters
 * multiple times.
 *
 * Usage:
 *   node scripts/fix-workflow-parameters.js              # Fix all workflows
 *   node scripts/fix-workflow-parameters.js --dry-run    # Preview changes
 */

const fs = require('fs/promises');
const path = require('path');
const { glob } = require('glob');

/**
 * Flatten nested parameters structure
 * Handles cases where parameters are wrapped multiple times with node-level attributes
 * (name, typeVersion, position) that got merged into the parameters object
 */
function flattenParameters(obj, depth = 0) {
  // Safety check for infinite recursion
  if (depth > 10) {
    console.warn(`Max recursion depth reached, stopping at depth ${depth}`);
    return obj;
  }

  // If it's not an object or is an array, return as-is
  if (typeof obj !== 'object' || obj === null || Array.isArray(obj)) {
    return obj;
  }

  // Get keys
  const keys = Object.keys(obj);

  // If we have node-level attributes (name/typeVersion/position) at parameter level,
  // these were incorrectly merged in. Extract from nested 'parameters' field.
  if ((keys.includes('name') || keys.includes('typeVersion') || keys.includes('position')) &&
      keys.includes('parameters')) {
    // Skip the node-level attributes and use the nested parameters
    return flattenParameters(obj.parameters, depth + 1);
  }

  // If ONLY key is 'parameters' and value is an object, unwrap and recurse
  if (keys.length === 1 && keys[0] === 'parameters' && typeof obj.parameters === 'object' && obj.parameters !== null) {
    return flattenParameters(obj.parameters, depth + 1);
  }

  // Otherwise, recursively flatten all values
  const result = {};
  for (const [key, value] of Object.entries(obj)) {
    if (typeof value === 'object' && value !== null && !Array.isArray(value)) {
      result[key] = flattenParameters(value, depth);
    } else {
      result[key] = value;
    }
  }
  return result;
}

/**
 * Check if a node has nested parameters that need flattening
 * Parameters structure should NOT contain name, typeVersion, position at the parameter level
 */
function hasNestedParameters(node) {
  const params = node.parameters || {};
  const keys = Object.keys(params);

  // Parameters should never contain name, typeVersion, or position
  // Those are node-level attributes, not parameter attributes
  if (keys.includes('name') || keys.includes('typeVersion') || keys.includes('position')) {
    return true;
  }

  // Check for recursive parameters nesting
  if (keys.includes('parameters') && typeof params.parameters === 'object') {
    return true;
  }

  return false;
}

/**
 * Fix a single workflow
 */
async function fixWorkflow(filePath, dryRun) {
  const content = await fs.readFile(filePath, 'utf-8');
  const workflow = JSON.parse(content);

  let fixedCount = 0;

  // Fix each node's parameters
  if (Array.isArray(workflow.nodes)) {
    for (const node of workflow.nodes) {
      if (hasNestedParameters(node)) {
        node.parameters = flattenParameters(node.parameters);
        fixedCount++;
      }
    }
  }

  // Write back if changes were made and not a dry run
  if (fixedCount > 0 && !dryRun) {
    const newContent = JSON.stringify(workflow, null, 2) + '\n';
    await fs.writeFile(filePath, newContent, 'utf-8');
  }

  return { fixed: fixedCount > 0, nodeCount: fixedCount };
}

/**
 * Find all workflow files
 */
async function findWorkflowFiles() {
  const patterns = [
    'packagerepo/backend/workflows/*.json',
    'workflow/examples/**/*.json',
    'packages/*/workflow/*.json',
  ];

  const files = [];
  for (const pattern of patterns) {
    const matched = await glob(pattern, { cwd: process.cwd() });
    files.push(...matched);
  }

  return [...new Set(files)]; // Remove duplicates
}

/**
 * Main function
 */
async function main() {
  const dryRun = process.argv.includes('--dry-run');
  const cwd = process.cwd();

  console.log(`\n🔧 Fixing Workflow Parameters${dryRun ? ' (DRY RUN)' : ''}`);
  console.log(`📁 Working directory: ${cwd}\n`);

  try {
    // Find workflows
    const workflowFiles = await findWorkflowFiles();
    if (workflowFiles.length === 0) {
      console.log('⚠️  No workflow files found');
      return;
    }

    console.log(`Found ${workflowFiles.length} workflow files\n`);

    let totalFixed = 0;
    let totalNodes = 0;
    const fixedFiles = [];

    // Process each workflow
    for (const file of workflowFiles) {
      try {
        const { fixed, nodeCount } = await fixWorkflow(file, dryRun);
        if (fixed) {
          totalFixed++;
          totalNodes += nodeCount;
          fixedFiles.push(file);
          console.log(`✓ ${path.basename(file)}: Fixed ${nodeCount} nodes`);
        }
      } catch (error) {
        console.error(`✗ Error processing ${file}:`, error instanceof Error ? error.message : String(error));
      }
    }

    console.log(`\n${'='.repeat(60)}`);
    console.log(`Summary:`);
    console.log(`  Workflows fixed: ${totalFixed}/${workflowFiles.length}`);
    console.log(`  Total nodes fixed: ${totalNodes}`);
    console.log(`${'='.repeat(60)}`);

    if (dryRun) {
      console.log('\n📋 DRY RUN - No changes were written');
      console.log('Run without --dry-run to apply fixes\n');
    } else if (totalFixed > 0) {
      console.log('\n✅ All workflows fixed successfully!\n');
    }
  } catch (error) {
    console.error('Error:', error instanceof Error ? error.message : String(error));
    process.exit(1);
  }
}

main();