fluke/devops-service/workers/stack_sync_worker.rb

require "providers/provider_factory"
require "commands/stack"
require "db/mongo/models/stack/stack_factory"
require "db/mongo/models/report"

class StackSyncWorker < Worker
  include StackCommands

  # besides options came from JobStarter we need:
  #   :provider
  #   :stack_id
  def perform(options)
    call(options['config'], options['provider'], options['dir']) do |provider, out, file|
      mongo = Devops::Db.connector
      stack = mongo.stack(options['stack_id'])
      o = {
        "file" => file,
        "_id" => jid,
        "created_by" => options['owner'],
        "project" => stack.project,
        "deploy_env" => stack.deploy_env,
        "type" => ::Devops::Model::Report::STACK_TYPE
      }
      mongo.save_report(::Devops::Model::Report.new(o))

      status = sync_stack_till_not_in_progress_proc.call(out, stack, mongo)
      status
    end
  end
end

WorkersStorage.add_worker(sync_stack_till_not_in_progress: StackSyncWorker)