meipian-qiniu/index.js

const path = require('path')
const fs = require('fs')
const chalk = require('chalk')

const inquiry = require('./lib/inquiry')
const strike = require('./lib/strike')
const upload = require('./lib/upload')
const home = require('user-home')
const keyDir = path.resolve(home, './.qiniu')
const keyFile = path.resolve(home, './.qiniu/key.json')

function readFiles(srcDir, ext) {
  let files = []
  let names = []
  let loop = (function loop(src) {
    let dirs = fs.readdirSync(src)

    for (let temp in dirs) {
      let dir = path.join(src, dirs[temp])
      let stat = fs.statSync(dir);

      if (stat.isFile() &&
        (!(new RegExp(ext + '$').test(dirs[temp])))) {
        files.push(dir = dir.replace(/\\/g, '\/'))
        names.push(((dir.match(/(\/[^\/]+\/+)[^\/]+$/) || [])[1] || '/') + dirs[temp])
      } else if (stat.isDirectory()) {
        loop(dir)
      }
    }
  })
  loop(srcDir)
  return {
    files: files,
    names: names
  }
}

module.exports = function(bucket, src, fix, ext) {
  let infos = readFiles(src, ext)
  let handFile = function(fn) {
    let context = this
    strike.apply(context, [bucket, fix, function() {
      infos.files.map(function(value, idx) {
        upload.apply(context, [bucket, path.resolve(value), fix + infos.names[idx], fn])
      })
    }])
  }

  console.log('  ' + chalk.bgRed('  Upload number: ' + infos.files.length + ' files  '))

  if (fs.existsSync(keyFile)) {
    handFile.call(require(keyFile))
  } else {

    inquiry(function(answer) {
      handFile.call(answer, function() {
        if (answer.save) {
          fs.existsSync(keyDir) ? '' : fs.mkdirSync(path.join(home, '.qiniu'))
          fs.createWriteStream(keyFile).write(JSON.stringify(answer));
        }
      })
    })
  }
}