execKeepAlive.js

// @flow

const childProcess = require('child_process')

const argv = process.argv

main()

function pad(num, size) {
  let s = num + ''
  while (s.length < size) {
    s = '0' + s
  }
  return s
}

async function main() {
  let code = 0
  try {
    if (argv.length === 4) {
      code = await callAsync(argv[2], argv[3])
    } else if (argv.length === 3) {
      code = await callAsync(argv[2])
    }
  } catch (e) {
    console.log(e)
  }
  process.exit(code)
}

async function callAsync(cmdString, pipeCmd = '') {
  return new Promise((resolve, reject) => {
    const cmdArray = cmdString.split(' ')
    const pipeArray = pipeCmd.split(' ')
    let outCmd
    let inCmd
    if (pipeCmd) {
      inCmd = childProcess.spawn(cmdArray[0], cmdArray.slice(1))
      outCmd = childProcess.spawn(pipeArray[0], pipeArray.slice(1))
    } else {
      outCmd = childProcess.spawn(cmdArray[0], cmdArray.slice(1))
    }
    let timeoutId

    const resetT = () => {
      if (timeoutId) {
        clearTimeout(timeoutId)
      }
      timeoutId = setTimeout(() => {
        const date = new Date(Date.now())
        const year = date.getFullYear()
        const month = pad(date.getMonth() + 1, 2)
        const day = pad(date.getDate(), 2)
        const hour = pad(date.getHours(), 2)
        const mins = pad(date.getMinutes(), 2)

        console.log(`${year}-${month}-${day}-${hour}:${mins} Waiting...`)
        resetT()
      }, 60000)
    }

    if (inCmd) {
      inCmd.stdout.on('data', data => {
        outCmd && outCmd.stdin.write(data)
      })
      inCmd.stderr.on('data', data => {
        console.log(data.toString())
      })
      inCmd.on('close', code => {
        if (code === 0) {
          console.log(`process exited with code ${code}`)
          outCmd && outCmd.stdin.end()
        } else {
          resolve(code)
        }
      })
    }

    outCmd.stdout.on('data', data => {
      console.log(data.toString())
      resetT()
    })

    outCmd.stderr.on('data', data => {
      console.log(data.toString())
      resetT()
    })

    outCmd.on('close', code => {
      if (code === 0) {
        console.log(`process exited with code ${code}`)
        if (timeoutId) {
          clearTimeout(timeoutId)
        }
        resolve(code)
      } else {
        resolve(code)
      }
    })
    resetT()
  })
}