export async function loadConfigFiles()

in src/config-loader.ts [14:88]

• 54 lines of code
• 7 McCabe index (conditional complexity)

export async function loadConfigFiles(inputPattern: string): Promise<Metric[]> {
  core.info('Loading configuration files from: ' + inputPattern)

  const patterns = inputPattern
    .split('\n')
    .map(s => s.replace(/^!\s+/, '!').trim())
    .filter(x => x !== '')
    .join('\n')

  const files = []
  const globber = await glob.create(patterns)
  for await (const file of globber.globGenerator()) {
    files.push(file)
    core.info(`Using configuration file: ${file}`)
  }

  if (files.length === 0) {
    throw new ArgumentError(`No configuration files found`)
  }

  const configs = []

  for (const file of files) {
    core.info(`Parsing : ${file}`)
    configs.push(await parseConfigFile(file))
  }

  // First deep merge all of the config objects into a single object
  // Then flatten the merged object
  core.info('Merging loaded configuration')

  const mergedMetrics = configs.map(config => config.metrics).flat()

  const duplicateMetrics = mergedMetrics.reduce((acc, metric) => {
    const { id } = metric
    acc[id] = (acc[id] || 0) + 1
    return acc
  }, {})

  const duplicates = mergedMetrics.filter(
    metric => duplicateMetrics[metric.id] > 1
  )

  if (duplicates.length > 0) {
    const duplicateIds = duplicates.map(metric => metric.id).join(', ')
    const message = `Metric is defined multiple times which is not allowed: ${duplicateIds}`
    core.error(message)
    throw new ArgumentError(message)
  }

  const schemaValidationResults = mergedMetrics.map(m => {
    return { id: m.id, ...validator.validate(m, metricsSchema) }
  })

  const failedValidations = schemaValidationResults.filter(
    r => r.errors.length > 0
  )

  if (failedValidations.length > 0) {
    const message = failedValidations
      .map(r => {
        const details = r.errors
          .map(e => `${e.property}: ${e.message}`)
          .join('\n')
        return `Schema validation failed for metric: ${r.id}. It should follow the schema defined in the schema file https://github.com/Azure/online-experimentation-deploy-metrics/tree/main/schema/Metrics.v2.0.0.schema.json. Errors: ${details}`
      })
      .join('\n')

    core.error(message)
    throw new ArgumentError(message)
  }

  core.info(`Found ${mergedMetrics.length} metrics in configuration files`)
  return mergedMetrics
}