Contents

class Fanforce::Worker

  LOADED_AT = Time.now

  @@iron = {}
  @@redis = {}
  @@log = Logger.new($stdout)

  def self.iron_token
    @@iron[:token] || ENV['IRON_TOKEN']
  end

  def self.iron_project_id
    @@iron[:project_id] || ENV['IRON_PROJECT_ID']
  end

  def self.iron_mq
    require 'iron_mq'
    @@iron[:mq] ||= IronMQ::Client.new(:token => @@iron[:token], :project_id => @@iron[:project_id])
  end

  def self.redis_url_errorlog
    @@redis[:url_errorlog] || ENV['REDIS_URL_ERRORLOG'] || (raise 'No REDIS_URL_ERRORLOG found in ENV')
  end

  def self.set_config(obj)
    @@iron[:token] = obj[:iron_token] if obj[:iron_token]
    @@iron[:project_id] = obj[:iron_project_id] if obj[:iron_project_id]
    @@redis[:url_errorlog] = obj[:redis_url_errorlog] if obj[:redis_url_errorlog]
  end

  def self.log
    @@log
  end

  ##########################################################################################

  def self.enqueue(queue_id, params, options={})
    raise 'Params being sent to the queue must be a Hash' if !params.is_a?(Hash)

    retries = (options[:retries].present?) ? options.delete(:retries) : 0
    iron_mq.queue(queue_id).post({params: params, retries: retries}.to_json, options)
  end

  def self.run(worker_data, min_execution_time=300, &code_block)
    require_relative 'runner'
    Runner.new(worker_data, min_execution_time, &code_block)
  end

end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
fanforce-worker-0.31.0	lib/fanforce/worker/worker.rb
fanforce-worker-0.30.0	lib/fanforce/worker/worker.rb
fanforce-worker-0.21.1	lib/fanforce/worker/worker.rb