Chore: use async/await in tests

Author: mysticatea

.babelrc

@@ -1,5 +1,6 @@
 {
     "presets": ["power-assert"],
+    "plugins": ["transform-async-to-generator"],
     "only": "/test/*.js",
     "sourceMaps": "inline"
 }

bin/common/parse-cli-args.js

@@ -43,12 +43,12 @@ function createPackageConfig() {
         return retv
     }
 
-    Object.keys(process.env).forEach(key => {
+    for (const key of Object.keys(process.env)) {
         const m = PACKAGE_CONFIG_PATTERN.exec(key)
         if (m != null) {
             overwriteConfig(retv, packageName, m[1], process.env[key])
         }
-    })
+    }
 
     return retv
 }
@@ -62,7 +62,7 @@ function createPackageConfig() {
  */
 function addGroup(groups, initialValues) {
     groups.push(Object.assign(
-        {parallel: false, patterns: []},
+        { parallel: false, patterns: [] },
         initialValues || {}
     ))
 }
@@ -183,7 +183,7 @@ function parseCLIArgsCore(set, args) {    // eslint-disable-line complexity
                 if (set.singleMode) {
                     throw new Error(`Invalid Option: ${arg}`)
                 }
-                addGroup(set.groups, {parallel: true})
+                addGroup(set.groups, { parallel: true })
                 break
 
             case "--npm-path":

bin/run-p/main.js

@@ -28,7 +28,7 @@ const parseCLIArgs = require("../common/parse-cli-args")
 module.exports = function npmRunAll(args, stdout, stderr) {
     try {
         const stdin = process.stdin
-        const argv = parseCLIArgs(args, {parallel: true}, {singleMode: true})
+        const argv = parseCLIArgs(args, { parallel: true }, { singleMode: true })
         const group = argv.lastGroup
 
         if (group.patterns.length === 0) {

bin/run-s/main.js

@@ -28,7 +28,7 @@ const parseCLIArgs = require("../common/parse-cli-args")
 module.exports = function npmRunAll(args, stdout, stderr) {
     try {
         const stdin = process.stdin
-        const argv = parseCLIArgs(args, {parallel: false}, {singleMode: true})
+        const argv = parseCLIArgs(args, { parallel: false }, { singleMode: true })
         const group = argv.lastGroup
 
         if (group.patterns.length === 0) {

lib/create-header.js

@@ -38,7 +38,7 @@ module.exports = function createHeader(nameAndArgs, packageInfo, isTTY) {
     const packageVersion = packageInfo.body.version
     const scriptBody = packageInfo.body.scripts[name]
     const packagePath = packageInfo.path
-    const color = isTTY ? chalk.styles.gray : {open: "", close: ""}
+    const color = isTTY ? chalk.styles.gray : { open: "", close: "" }
 
     return `
 ${color.open}> ${packageName}@${packageVersion} ${name} ${packagePath}${color.close}

lib/create-prefix-transform-stream.js

@@ -45,11 +45,11 @@ class PrefixTransform extends stream.Transform {
      * Transforms the output chunk.
      *
      * @param {string|Buffer} chunk - A chunk to be transformed.
-     * @param {string} encoding - The encoding of the chunk.
+     * @param {string} _encoding - The encoding of the chunk.
      * @param {function} callback - A callback function that is called when done.
      * @returns {void}
      */
-    _transform(chunk, encoding, callback) {
+    _transform(chunk, _encoding, callback) {
         const prefix = this.prefix
         const nPrefix = `\n${prefix}`
         const state = this.state

lib/index.js

@@ -110,15 +110,15 @@ function parsePatterns(patternOrPatterns, args) {
 function toOverwriteOptions(config) {
     const options = []
 
-    Object.keys(config).forEach(packageName => {
+    for (const packageName of Object.keys(config)) {
         const packageConfig = config[packageName]
 
-        Object.keys(packageConfig).forEach(variableName => {
+        for (const variableName of Object.keys(packageConfig)) {
             const value = packageConfig[variableName]
 
             options.push(`--${packageName}:${variableName}=${value}`)
-        })
-    })
+        }
+    }
 
     return options
 }
@@ -249,7 +249,7 @@ module.exports = function npmRunAll(patternOrPatterns, options) {
         return Promise.resolve()
             .then(() => {
                 if (taskList != null) {
-                    return {taskList, packageInfo: null}
+                    return { taskList, packageInfo: null }
                 }
                 return readPackageJson()
             })

lib/match-tasks.js

@@ -17,7 +17,7 @@ const Minimatch = require("minimatch").Minimatch
 //------------------------------------------------------------------------------
 
 const COLON_OR_SLASH = /[:/]/g
-const CONVERT_MAP = {":": "/", "/": ":"}
+const CONVERT_MAP = { ":": "/", "/": ":" }
 
 /**
  * Swaps ":" and "/", in order to use ":" as the separator in minimatch.
@@ -46,7 +46,7 @@ function createFilter(pattern) {
     const matcher = new Minimatch(swapColonAndSlash(task))
     const match = matcher.match.bind(matcher)
 
-    return {match, task, args}
+    return { match, task, args }
 }
 
 /**
@@ -97,18 +97,18 @@ module.exports = function matchTasks(taskList, patterns) {
     const unknownSet = Object.create(null)
 
     // Take tasks while keep the order of patterns.
-    filters.forEach(filter => {
+    for (const filter of filters) {
         let found = false
 
-        candidates.forEach(candidate => {
+        for (const candidate of candidates) {
             if (filter.match(candidate)) {
                 found = true
                 taskSet.add(
                     swapColonAndSlash(candidate) + filter.args,
                     filter.task
                 )
             }
-        })
+        }
 
         // Built-in tasks should be allowed.
         if (!found && (filter.task === "restart" || filter.task === "env")) {
@@ -118,7 +118,7 @@ module.exports = function matchTasks(taskList, patterns) {
         if (!found) {
             unknownSet[filter.task] = true
         }
-    })
+    }
 
     const unknownTasks = Object.keys(unknownSet)
     if (unknownTasks.length > 0) {

lib/read-package-json.js

@@ -26,6 +26,6 @@ module.exports = function readPackageJson() {
     const path = joinPath(process.cwd(), "package.json")
     return readPkg(path).then(body => ({
         taskList: Object.keys(body.scripts || {}),
-        packageInfo: {path, body},
+        packageInfo: { path, body },
     }))
 }

lib/run-task.js

@@ -33,8 +33,8 @@ const colors = [chalk.cyan, chalk.green, chalk.magenta, chalk.yellow, chalk.red]
 function selectColor(taskName) {
     let hash = 0
 
-    for (const i in taskName) {
-        hash = ((hash << 5) - hash) + taskName.charCodeAt(i)
+    for (const c of taskName) {
+        hash = ((hash << 5) - hash) + c
         hash |= 0
     }
 
@@ -124,7 +124,7 @@ module.exports = function runTask(task, options) {
         const stdinKind = detectStreamKind(stdin, process.stdin)
         const stdoutKind = detectStreamKind(stdout, process.stdout)
         const stderrKind = detectStreamKind(stderr, process.stderr)
-        const spawnOptions = {stdio: [stdinKind, stdoutKind, stderrKind]}
+        const spawnOptions = { stdio: [stdinKind, stdoutKind, stderrKind] }
 
         // Print task name.
         if (options.printName && stdout != null) {
@@ -164,10 +164,10 @@ module.exports = function runTask(task, options) {
             stdin.pipe(cp.stdin)
         }
         if (stdoutKind === "pipe") {
-            cp.stdout.pipe(stdout, {end: false})
+            cp.stdout.pipe(stdout, { end: false })
         }
         if (stderrKind === "pipe") {
-            cp.stderr.pipe(stderr, {end: false})
+            cp.stderr.pipe(stderr, { end: false })
         }
 
         // Register
@@ -177,7 +177,7 @@ module.exports = function runTask(task, options) {
         })
         cp.on("close", (code) => {
             cp = null
-            resolve({task, code})
+            resolve({ task, code })
         })
     })