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

  def perform(options)
    server_attrs = options.fetch('server_attrs')
    owner = options.fetch('owner')

    call() do |out, file|
      project = mongo.project(server_attrs["project"])
      env = project.deploy_env(server_attrs["deploy_env"])
      report = save_report(file, project, env, owner)

      e = Devops::Executor::ServerExecutor.new(nil, out)
      e.project = project
      e.report = report
      e.deploy_env = env
      server_attrs["created_by"] = owner
      e.create_server(server_attrs)
    end
  end

  private

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

end