Contents

class Fanforce::PluginWorker

  LOADED_AT = Time.now

  @@iron = {}
  @@redis = {}
  @@log = Logger.new($stdout)
  @@log.datetime_format = '%H:%M:%S'
  @@log.formatter = proc do |severity, datetime, prog_name, msg| "#{datetime}: #{msg}\n" end

  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)

    queue_id = Utils.iron_queue_id(queue_id)
    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)
    Runner.new(worker_data, min_execution_time, &code_block)
  end

end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
fanforce-plugin-worker-2.0.0.rc1	lib/fanforce/plugin_worker/worker.rb
fanforce-plugin-worker-1.6.0	lib/fanforce/plugin_worker/worker.rb
fanforce-plugin-worker-1.6.0.rc3	lib/fanforce/plugin_worker/worker.rb
fanforce-plugin-worker-1.6.0.rc2	lib/fanforce/plugin_worker/worker.rb
fanforce-plugin-worker-1.6.0.rc1	lib/fanforce/plugin_worker/worker.rb