Method run

lib/step/meta.js:57–113

@return {*}

(fn)

  /** @return {*} */
  run(fn) {
    this.status = 'queued'
    this.setArguments(Array.from(arguments).slice(1))
    let result
    let hasChildSteps = false

    const registerStep = step => {
      this.setMetaStep(null)
      step.setMetaStep(this)
      hasChildSteps = true
    }
    event.dispatcher.prependListener(event.step.before, registerStep)

    // Start timing
    this.startTime = Date.now()

    // Handle async and sync methods.
    if (fn.constructor.name === 'AsyncFunction') {
      result = fn
        .apply(this.context, this.args)
        .then(result => {
          this.setStatus('success')
          return result
        })
        .catch(error => {
          this.setStatus('failed')
          throw error
        })
        .finally(() => {
          this.endTime = Date.now()
          event.dispatcher.removeListener(event.step.before, registerStep)
          // Only emit events if no child steps were registered
          if (!hasChildSteps) {
            event.emit(event.step.started, this)
            event.emit(event.step.finished, this)
          }
        })
    } else {
      try {
        result = fn.apply(this.context, this.args)
        this.setStatus('success')
      } catch (error) {
        this.setStatus('failed')
        throw error
      } finally {
        this.endTime = Date.now()
        event.dispatcher.removeListener(event.step.before, registerStep)
        // Only emit events if no child steps were registered
        if (!hasChildSteps) {
          event.emit(event.step.started, this)
          event.emit(event.step.finished, this)
        }
      }
    }

    return result
  }
}