client.js

const {getDiff, every, detectLanguage, joinPath, run, calculateHash, coerceArray, which, mkdirp, dirname, fs, notSoSafeEval} = require('./helpers')
const {generateClientConfig} = require('./config')

module.exports = queryUrl => {
  const URL = new (require('url').URL)(queryUrl)
  let [_,token] = split('/', URL.pathname)
  let tags = process.argv[3] ? split(',', process.argv[3]) : null
  let id = process.argv[4]

  require('./ws').connect('ws://'+URL.host+'/Sync', {
    connect: emit => {},
    'config:ask': emit => {
      if (tags) emit({config: {id, platform, token, tags, hash: calculateHash(conf)}})
    },
    tags: async (emit, serverTags) => {
      if (isEmpty(serverTags)) serverTags = ['default']
      if (!tags) await generateClientConfig(serverTags, queryUrl).then(x => {
        tags = x.tags
        id = x.id
      })
      emit({config: {id, platform, token, tags, hash: calculateHash(conf)}})
    },
    config: (emit, update) => {
      const prevConf = clone(conf)
      conf = update

      const log = (service, message, json) => {
        // console.log({service, message, json})
        emit({log: {message, service, json, id}})
      }

      const inSequence = x => 
        inSequence.Q = inSequence.Q.then(x)
      inSequence.Q = Promise.resolve()

      mapObjIndexed(async (s, service) => {
        if (calculateHash(propOr({}, service, prevConf)) == calculateHash(s)) return

        for (const f of values(s.files)) {
          mkdirp.sync(dirname(f.path))

          const prev = tryCatch(fs.readFileSync, () => '')(f.path, 'utf8')

          if (calculateHash(prev) == calculateHash(f.content)) continue
          try {
            f.content = replace(/{{{(.*?)}}}/gim, (x,code) => notSoSafeEval(code), f.content)
            fs.writeFileSync(f.path, f.content)
            log(service, 'file:updated '+f.path, {status: 'inprogress', diff: getDiff(prev, f.content)})
          } catch(e) {
            log(service, 'file:updated '+f.path, {status: 'error', error: e.message, diff: getDiff(prev, f.content)})
            return
          }
        }

        await Promise.all(values(mapObjIndexed(async (install, check) => {
          if (!install.check)
            return which(check).catch(() => inSequence(() => run(install, x => log(service, install, x))))

          const {status} = await run(install.check, () => {}, true)
          if (status == 'error') return inSequence(() => run(install.install, x => log(service, install.install, x)))
        }, s.install || {})))

        if (s.command) {
          // run(split(/;|\n/, replace(/\\\n/, ' ', s.command)), x => log(service, s.command, x))
          run(s.command, x => log(service, s.command, x))
        }
      }, conf)

    }
  })
}