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