fluke/devops-service/workers/bootstrap_worker.rb
2016-04-05 15:28:17 +03:00

53 lines
1.4 KiB
Ruby

require File.join(File.dirname(__FILE__), "worker")
require "lib/executors/server_executor"
require "db/mongo/models/server"
require "db/mongo/models/report"
class BootstrapWorker < Worker
# @options
# 'server_attrs': required
# 'owner': required
# 'skip_rollback': optional
# 'deploy_info': optional
# 'deployers': optional
# 'bootstrap_template': optional
# 'chef_environment': optional
# 'config': optional, whatever this parameter really means
def perform(options)
call do
owner = options.fetch('owner')
skip_rollback = options['skip_rollback']
converted_options = convert_config(options)
server = Devops::Model::Server.new(options.fetch('server_attrs'))
report = save_report(owner, server)
executor = Devops::Executor::ServerExecutor.new(server, out, current_user: owner)
executor.report = report
status = executor.two_phase_bootstrap(converted_options)
mongo.set_report_server_data(jid, server.chef_node_name, server.public_ip || server.private_ip)
status
end
end
private
def save_report(owner, server)
update_report(
"created_by" => owner,
"project" => server.project,
"deploy_env" => server.deploy_env,
"type" => Devops::Model::Report::BOOTSTRAP_TYPE
)
end
def convert_config conf
config = {}
conf.each {|k,v| config[k.is_a?(String) ? k.to_sym : k] = v}
config
end
end