root = File.join(File.dirname(__FILE__), "..")
$LOAD_PATH.push root unless $LOAD_PATH.include? root

require "sidekiq"
require "sidekiq/api"

require "db/mongo/mongo_connector"

class Worker
  include Sidekiq::Worker

  def convert_config conf
    config = {}
    conf.each {|k,v| config[k.is_a?(String) ? k.to_sym : k] = v}
    logger.debug "Config: #{config.inspect}"
    config
  end

  def mongo_connector config
    mongo = MongoConnector.new(config[:mongo_db], config[:mongo_host], config[:mongo_port], config[:mongo_user], config[:mongo_password])
    logger.debug "Mongo connector: #{mongo.inspect}"
    mongo
  end

  def set_status id, status
    Sidekiq.redis {|con| con.hset "devops", id, status}
  end

end