class Session
constructor: ->
@token = 0
+ @verbose = true
+ @log_nest = 0
+ @log_mid = false
+
+ log_whitespace: ->
+ out = ''
+ out += '\n' if @log_mid
+ for i in [0...@log_nest]
+ out += '\t'
+ return out
+
+ log_start: (msg) ->
+ return unless @verbose
+ process.stdout.write "#{@log_whitespace()}#{msg}"
+ @log_nest += 1
+ @log_mid = true
+
+ log_end: ->
+ return unless @verbose
+ @log_nest -= 1
+ if @log_mid
+ process.stdout.write "... done\n"
+ else
+ process.stdout.write "#{@log_whitespace()}done\n"
+ @log_mid = false
api: (call, args..., callback) ->
async.waterfall [
when 0
get_token callback
when -1
- login callback
+ login.call this, callback
else
callback null, @token
(token, callback) =>
@token = token
+ @log_start [call, args...].join ' '
# commands implemented in client.coffee need "this" pointing to the session
- commands[call].call this, @token, args..., callback
+ commands[call].call this, @token, args..., (err, the_rest...) =>
+ @log_end() unless err?
+ callback err, the_rest...
], (err, result) =>
# eg /app/xxx/stats sometimes returns 404 with wrong auth token
if err?.code is 403 or err?.code is 404
else
callback err, result
-ask = (opts, callback) ->
- process.stdout.write opts.prompt
- process.stdin.setEncoding 'utf8'
- process.stdin.resume()
- process.stdin.once 'data', (line) ->
- if opts.silent
- # send ^[[A^[[2K to move the cursor up one line, then clear that line
- process.stdout.write new Buffer [27, 91, 65, 27, 91, 50, 75]
- process.stdout.write opts.prompt + "***\n"
- process.stdin.pause()
- callback null, (line.substr 0, line.length - 1)
+ ask: (opts, callback) ->
+ process.stdout.write @log_whitespace() + opts.prompt
+ process.stdin.setEncoding 'utf8'
+ process.stdin.resume()
+ process.stdin.once 'data', (line) =>
+ if opts.silent
+ # send ^[[A^[[2K to move the cursor up one line, then clear that line
+ process.stdout.write new Buffer [27, 91, 65, 27, 91, 50, 75]
+ process.stdout.write @log_whitespace() + opts.prompt + "***\n"
+ process.stdin.pause()
+ @log_mid = false
+ callback null, (line.substr 0, line.length - 1)
get_token = (callback) ->
fs.readFile token_file, 'utf8', (err, token) ->
login = (callback) ->
async.waterfall [
- (callback) -> async.series [
- (callback) -> ask prompt: 'username: ', callback
- (callback) -> ask prompt: 'password: ', silent: true, callback
+ (callback) => async.series [
+ (callback) => @ask prompt: 'username: ', callback
+ (callback) => @ask prompt: 'password: ', silent: true, callback
], callback
([username, password], callback) ->
af.login username, password, callback