fluke/devops-service/workers/bootstrap_worker.rb

require File.join(File.dirname(__FILE__), "worker")

require "lib/executors/server_executor"
require "providers/provider_factory"
require "db/mongo/models/server"
require "db/mongo/models/report"

class BootstrapWorker < Worker

  def perform(options)
    provider_name = options.fetch('provider_name')
    server_attrs = options.fetch('server_attrs')
#    bootstrap_template = options.fetch('bootstrap_template')
    owner = options.fetch('owner')
    options = convert_config(options)

    call(provider_name) do |provider, out, file|
      server = Devops::Model::Server.new(server_attrs)
      report = save_report(file, owner, server)

=begin
      options = {
        bootstrap_template: bootstrap_template
      }
=end
      executor = Devops::Executor::ServerExecutor.new(server, out)
      executor.report = report
      status = executor.two_phase_bootstrap(options)
      mongo.set_report_server_data(jid, server.chef_node_name, server.public_ip || server.private_ip)
      status
    end
  end

  private

  def save_report(file, owner, server)
    report_data = {
      "file" => file,
      "_id" => jid,
      "created_by" => owner,
      "project" => server.project,
      "deploy_env" => server.deploy_env,
      "type" => Devops::Model::Report::BOOTSTRAP_TYPE
    }
    report = Devops::Model::Report.new(report_data)
    mongo.save_report(report)
    report
  end
end