cli.coffee

require('cson-config').load()
relativeDate = require 'relative-date'
request = require 'request'
config = process.config
util = require 'util'
repl = require 'repl'
net  = require 'net'
git  = require './lib/git'
Api = require './lib/api'

args = process.argv[2..]

api = new Api config

cmdList = {}

cmd = (name, cb) ->
	cmdList[name] = cb



cmd 'ps:restart', (args, done) ->
	api.get "apps/#{config.git.name}/#{config.git.branch}/ps/restart", (data) ->
		# util.log util.inspect data
		runCommand 'ps', null, done


cmd 'releases', (args, done) ->
	api.get "apps/#{config.git.name}/#{config.git.branch}/releases", (releases) ->
		console.log '[Empty list]' if releases.length is 0

		for release in releases
			date = relativeDate new Date release.timestamp
			console.log " v#{release.version}\t#{date}"
		done()


cmd 'logs', (args, done) ->
	# api.on 'data', (data) ->
	# 	process.stdout.write data
	#
# http://node2.lxc.nag.ccl/apps/mrdka.git/master/build/logs

	repo = config.git.name.replace /\.git$/, ''
	api.getStream "apps/#{repo}/#{config.git.branch}/*/tail", (res) ->
		console.log 'xx'
		res.on 'data', (d) ->
			console.log data

		res.on 'error', (err) ->
			console.log err

		res.on 'end', () ->
			done()


cmd 'ps', (args, done) ->
	api.get "apps/#{config.git.name}/#{config.git.branch}/ps", (processes) ->
		processes = processes.sort (a, b) ->
			a.opts.worker > b.opts.worker

		console.log '[Empty list]' if processes.length is 0

		for process in processes
			date = relativeDate new Date process.time
			console.log " [#{process.opts.worker}] #{date}\t #{process.opts.cmd}\t #{process.state}\t #{process.dynoData?.toadwartId}"

		done()
		# util.log util.inspect process


cmd 'ps:scale', (args, done) ->
	unless args.length
		api.get "apps/#{config.git.name}/#{config.git.branch}/ps/scale", (processes) ->
			util.log util.inspect processes
			for process in processes
				date = relativeDate new Date process.time
				console.log " [#{process.opts.worker}] #{date}\t #{process.opts.cmd}"
			done()
	else
		scales = {}
		for arg in args
			[name, count] = arg.split '='
			scales[name] = count
		api.post "apps/#{config.git.name}/#{config.git.branch}/ps/scale", scales: scales, (out) ->
			unless out or out.started
				util.log util.inspect out
			done()


cmd 'ps:stop', (args, done) ->
	api.get "apps/#{config.git.name}/#{config.git.branch}/ps/stop", (data) ->
		if data.status is 'ok'
			console.log 'All processes stopped'
		else
			util.log util.inspect data
		done()


cmd 'run', (args, done)->
	# TODO do api
	cmd = process.argv[3..]
	c =
		command: cmd.join ' '
		env:
			COLUMNS: process.stdout.getWindowSize()[0]
			LINES: process.stdout.getWindowSize()[1]


	options =
		uri: "http://#{config.apiHost}/apps/#{config.git.name}/#{config.git.branch}/ps/"
		method: 'POST'
		json: c

	request options, (err, res, body) ->
		# console.log err, body
		return console.log err.stack if err
		return console.log body.error.message if body.error

		# console.log 'xxx', body
		# r = try JSON.parse body
		# return done body unless r

		uri = body.rendezvousURI
		util.log uri
		[_, _, host, port]= uri.match /(.*):\/\/(.*):(\d+)/


		# host = '10.11.1.13'
		# port = 6000

		util.log "Connecting to #{host}:#{port}"
		console.log ''

		# return

		sock = net.connect port, host
		# process.stdin.pause()
		process.stdin.pipe sock
		sock.pipe process.stdout

		sock.on 'connect', ->
			process.stdin.setRawMode yes
			# process.stdin.resume()

		sock.on 'close', done = ->
			process.stdin.setRawMode no
			process.stdin.pause()
			sock.removeListener 'close', done

		process.stdin.on 'end', ->
			sock.destroy()
			console.log()
			done()

		process.stdin.on 'data', (b) ->
			if b.length == 1 && b[0] == 4
				process.stdin.emit('end')


command = args[0]

runCommand = (command, args, done) ->
	if cmdList[command]
		cmdList[command].call null, args, done
	else if command.length is 0
		done()
	else
		console.log "Unknown command: #{command}\n"
		console.log "  #{key}" for key of cmdList
		done()


run = () ->
	if command
		return runCommand command, args[1..], () ->

	r = repl.start
		prompt: "gummi> "
		input: process.stdin
		output: process.stdout
		writer: () ->
			return ''
		eval: (cmd, context, filename, callback) ->
			cmd = cmd.substr(1).slice(0,-2)
			args = cmd.split ' '
			runCommand args[0], args[1..], () ->
				callback(null, '')

	r.complete = (line, cb) ->
		completions = []
		re = new RegExp "^#{line.replace /\ /g, ''}", "i"

		for cmd, f of cmdList
			completions.push cmd if cmd.match re

		cb null, [completions, line]

	for cmd, _ of cmdList
		r.context[cmd] = 1


git.getRepo (err, name, branch) ->
	debug = require('debug') 'git'
	if err
		console.log err
		process.exit 0

	config.git = {}
	config.git.name = name
	config.git.branch = branch
	debug "name: #{name}, branch: #{branch}"
	run()