includable / cli

const output = require('./output')

const Container = require('./containers/Container')

const fs = require('fs')

const io = require('socket.io-client')

const tmp = require('tmp')

const pkg = require('../package.json')

const path = require('path')

const chalk = require('chalk')

const moment = require('moment')

const request = require('./util').request

const child = require('./util/ChildProcess')

const Module = require('./containers/Module')

const archiver = require('archiver')

const filesize = require('file-size')

module.exports = {

  uploadFile: function (containerToken, event, path, cb, spinner) {

    var r = request(containerToken + '/fs', {

      'action': event,

      'name': path

    }, {

      'Content-Type': 'multipart/form-data'

    })

    if (event === 'add' || event === 'change' || event === 'zipBall') {

      r = r.attach('file', path)

    }

    var self = this

    return r.end(function (response) {

      if (response.body && response.body === 'Error: invalid container') {

        Container.clean()

        var func = spinner || output.err

        func('Container ' + containerToken + ' does not exist anymore. We cleaned your local environment, so that you can start with a clean container.')

        process.exit()

      }

      if (cb) {

        cb(response.body || '')

        return

      }

      if (response.body) {

        if (response.body.indexOf('Error:') === 0) {

          output.err(response.body)

        } else {

          self.logSyncMessage(response.body)

        }

      }

    })

  },

  logMessage: function (data, ret) {

    var message =

      chalk.bold(chalk[data.color](data.component)) + ' ' +

      data.message

    if ('time' in data) {

      if (data.time === 'now') {

        data.time = (new Date()).getTime() / 1000

      }

      message += ' ' + chalk.dim(moment(data.time * 1000).format('hh:mm:ss'))

    }

    if (ret) {

      return message

    }

    return output.log(message)

  },

  logSyncMessage: function (message, ret) {

    return this.logMessage({

      component: 'Sync',

      color: 'green',

      message: message,

      time: 'now'

    }, !!ret)

  },

  createInitialZip: function (dir, containerToken, envr, cb) {

    if (fs.existsSync(path.join(dir, 'vendor'))) {

      output.warn('Ignoring directory \'vendor\'')

    }

    if (fs.existsSync(path.join(dir, 'node_modules'))) {

      output.warn('Ignoring directory \'node_modules\'')

    }

    if (fs.existsSync(path.join(dir, 'web/node_modules'))) {

      output.warn('Ignoring directory \'web/node_modules\'')

    }

    var zipName = tmp.tmpNameSync({})

    var spinner = output.wait(this.logSyncMessage('Creating initial zipball', true))

    var zipFile = fs.createWriteStream(zipName)

    var self = this

    zipFile.on('close', function () {

      // Upload file to api.sadev.io

      fs.stat(zipName, function (err, stat) {

        if (err) {

          spinner('Error creating zipball')

          process.exit()

        }

        spinner()

        var size = filesize(stat.size).human('si')

        var stopSpinner = output.wait(self.logSyncMessage('Uploading initial zipball (' + size + ')', true))

        try {

          self.uploadFile(containerToken, 'zipBall', zipName, function (responseBody) {

            fs.unlink(zipName, function () {})

            if (responseBody.indexOf('OK') !== 0) {

              stopSpinner(responseBody || 'Could not connect to server (empty response)')

              process.exit()

            }

            stopSpinner(true)

            cb()

          }, spinner)

        } catch (e) {

          stopSpinner(e.message)

        }

      })

    })

    var archive = archiver('zip', {

      store: true

    })

    archive.on('error', function (err) {

      output.err(err)

    })

    archive.pipe(zipFile)

    archive.glob(path.join(dir, '**'), {

      ignore: ['.inc/**', '.git/**', 'node_modules', 'web/node_modules', 'node_modules/**', 'web/node_modules/**', 'vendor/**', '.gitignore', '.jshintrc']

    })

    archive.finalize()

  },

  startChildProcess: function (type, callback, basePath) {

  startWebSocket: function (containerToken) {

    var socket = io('http://ws.sadev.io/')

    var self = this

    socket.on('connect', function () {

      socket.emit('room', 'SADEV:' + containerToken)

      socket.emit('room', 'BROADCAST')

      socket.emit('room', pkg.name + '/' + pkg.version)

      socket.emit('clientInfo', pkg)

    })

    socket.on('log', function (data) {

      if (!('color' in data)) {

        if (data.component === 'Logger') {

          data.color = 'yellow'

        } else {

          data.color = 'blue'

        }

      }

      self.logMessage(data)

    })

    socket.on('disconnect', function () {

      socket.close()

      setTimeout(function () {

        self.startWebSocket(containerToken)

      }, 200)

    })

    socket.open()

  }

}