test.js

'use strict'

var path = require('path')
var readdir = require('fs').readdir
var spawn = require('child_process').spawn

var extname = path.extname
var join = path.join

var bin = join(process.cwd(), 'node_modules/.bin')
var PATH = process.env.PATH + ':' + bin

function run (test, cb) {
  var fullPath = test.cwd ? join(test.cwd, test.file) : test.file

  test.env = Object.assign({}, process.env, test.env || {})
  test.env.PATH = PATH

  console.log('running: ' + fullPath)

  var ps = spawn('node', [ test.file ], {
    stdio: 'inherit',
    cwd: test.cwd,
    env: test.env
  })

  ps.on('error', cb)
  ps.on('close', function (code) {
    if (code !== 0) {
      const err = new Error('non-zero error code')
      err.code = 'ENONZERO'
      err.exitCode = code
      return cb(err)
    }
    cb()
  })
}

function series (tasks, cb) {
  var results = []
  var pos = 0

  function done (err, result) {
    if (err) return cb(err)
    results.push(result)

    if (++pos === tasks.length) {
      cb(null, results)
    } else {
      tasks[pos](done)
    }
  }

  setImmediate(tasks[pos], done)
}

function handlerBind (handler) {
  return function (task) {
    return handler.bind(null, task)
  }
}

function mapSeries (tasks, handler, cb) {
  series(tasks.map(handlerBind(handler)), cb)
}

var directories = [
  'test',
  'test/lambda',
  'test/integration',
  'test/integration/api-schema',
  'test/sourcemaps',
  'test/instrumentation',
  'test/instrumentation/modules',
  'test/instrumentation/modules/bluebird',
  'test/instrumentation/modules/cassandra-driver',
  'test/instrumentation/modules/fastify',
  'test/instrumentation/modules/http',
  'test/instrumentation/modules/koa-router',
  'test/instrumentation/modules/mysql',
  'test/instrumentation/modules/mysql2',
  'test/instrumentation/modules/pg'
]

mapSeries(directories, readdir, function (err, directoryFiles) {
  if (err) throw err

  var tests = [
    {
      file: 'test.js',
      cwd: 'test/start/env',
      env: {
        ELASTIC_APM_SERVICE_NAME: 'from-env'
      }
    },
    {
      file: 'test.js',
      cwd: 'test/start/file'
    }
  ]

  directoryFiles.forEach(function (files, i) {
    var directory = directories[i]
    files.forEach(function (file) {
      if (directory === 'test' && file === 'test.js') return
      if (extname(file) !== '.js') return
      if (file[0] === '_') return

      tests.push({
        file: join(directory, file)
      })
    })
  })

  mapSeries(tests, run, function (err) {
    if (err) throw err
  })
})