+
+# This uses a pair of apps to get a seamless upgrades. ie the site is never
+# down, and connections that are open at the time of upgrade are given 10
+# seconds to close.
+#
+# Requirements:
+#
+# 1. There must be two apps with the same name except one has an underscore at
+# the end and the other doesn't.
+#
+# 2. One of these apps must be running, and must have the domain names mapped
+# to it.
+#
+# 3. The other must be stopped, and must not have the domain names mapped to
+# it. (just it's *.af.com address.)
+#
+# Pass the app name without the underscore at the end, and app_publish_seamless
+# will figure out which is which
+commands.app_publish_seamless = (token, app_name, zip_file, callback) ->
+ async.auto {
+ info1: (cb) => @api 'app_info', app_name, cb
+ info2: (cb) => @api 'app_info', app_name + '_', cb
+ infos: ['info1', 'info2', (cb, args) ->
+ # FIXME check for other requirements and bail if not met
+ if args.info1.state is 'STOPPED'
+ cb null, new: args.info1, old: args.info2
+ else
+ cb null, new: args.info2, old: args.info1
+ ]
+ push: ['infos', (cb, args) =>
+ @api 'app_update_files', args.infos.new.name, zip_file, cb
+ ]
+ copy_uris: ['push', 'infos', (cb, args) =>
+ # There's a bug in the server where you can't set new uris and
+ # start the app in the same app_set_info call
+ for u in args.infos.old.uris
+ args.infos.new.uris.push u unless u.substr(-6) is '.af.cm'
+ @api 'app_set_info', args.infos.new.name, args.infos.new, cb
+ ]
+ new_info_again: ['copy_uris', 'infos', (cb, args) =>
+ @api 'app_info', args.infos.new.name, cb
+ ]
+ start_new: ['new_info_again', (cb, args) =>
+ args.new_info_again.state = 'STARTED'
+ @api 'app_set_info', args.new_info_again.name, args.new_info_again, cb
+ ]
+ hide_old: ['start_new', 'infos', (cb, args) =>
+ just_af = []
+ for u in args.infos.old.uris
+ just_af.push u if u.substr(-6) is '.af.cm'
+ args.infos.old.uris = just_af
+ @api 'app_set_info', args.infos.old.name, args.infos.old, cb
+ ]
+ wait_for_old_connections: ['hide_old', (cb) =>
+ seconds = 10
+ log_id = @log_start "waiting #{seconds} seconds for connections to old instance to finish"
+ timeout seconds * 1000, =>
+ @log_end(log_id)
+ cb()
+ ]
+ old_info_again: ['hide_old', 'infos', (cb, args) =>
+ @api 'app_info', args.infos.old.name, cb
+ ]
+ stop_old: ['wait_for_old_connections', 'old_info_again', (cb, args) =>
+ args.old_info_again.state = 'STOPPED'
+ @api 'app_set_info', args.old_info_again.name, args.old_info_again, cb
+ ]
+ # TODO when we get into sending manifests, we may need to update_files to infos.old.name too
+ }, callback
+
+app_set_state = (token, app_name, state, callback) ->