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