fluke/devops-service/workers/create_server_worker.rb

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

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

class CreateServerWorker < Worker

  # options must contain 'server_attrs', 'owner'
  def perform(options)
    call do
      owner = options.fetch('owner')
      server_attrs = options.fetch('server_attrs').merge('created_by' => owner)

      project = mongo.project(server_attrs['project'])
      env = project.deploy_env(server_attrs['deploy_env'])
      report = save_report(project, env, owner)

      executor(project, env, report).create_server(server_attrs)
    end
  end

  private

  def executor(project, env, report)
    Devops::Executor::ServerExecutor.new(nil, out).tap do |executor|
      executor.project = project
      executor.deploy_env = env
      executor.report = report
    end
  end

  def save_report(project, env, owner)
    update_report(
      "created_by" => owner,
      "project" => project.id,
      "deploy_env" => env.identifier,
      "type" => Devops::Model::Report::SERVER_TYPE
    )
  end

end