#{msgs_labels.zip(qc.num_messages.values_at(*msgs_labels)).map{|ab| "#{ab[0]}:#{ab[1].to_s.ljust(4)} "}.join}#{msgs_labels.zip(qc.num_messages.values_at(*msgs_labels)).map { |ab| "#{ab[0]}:#{ab[1].to_s.ljust(4)} " }.join}#{params.inspect} from form, and #{result} from QueueMgr"
redirect "/q/#{js_data['name']}"
end
@@ -136,12 +135,12 @@ def flash_now(type, msg)
# This creates and starts a queue
result = RQ::QueueMgrClient.delete_queue(params['queue_name'])
flash :notice, "We got #{params.inspect} from form, and #{result} from QueueMgr"
- redirect "/"
+ redirect '/'
end
get '/q.txt' do
content_type 'text/plain', :charset => 'utf-8'
- erb :queue_list, :layout => false, :locals => {:queues => RQ::QueueMgrClient.queues}
+ erb :queue_list, :layout => false, :locals => { :queues => RQ::QueueMgrClient.queues }
end
get '/q.json' do
@@ -149,23 +148,23 @@ def flash_now(type, msg)
end
get '/q/:name' do
- if params[:name].index(".txt")
+ if params[:name].index('.txt')
content_type 'text/plain', :charset => 'utf-8'
- return erb :queue_txt, :layout => false, :locals => { :qc => RQ::QueueClient.new(params[:name].split(".txt").first) }
- elsif params[:name].index(".json")
+ return erb :queue_txt, :layout => false, :locals => { :qc => RQ::QueueClient.new(params[:name].split('.txt').first) }
+ elsif params[:name].index('.json')
if '.json' == params[:name][-5..-1]
- return erb :queue_json, :layout => false, :locals => { :qc => RQ::QueueClient.new(params[:name].split(".json").first) }
+ return erb :queue_json, :layout => false, :locals => { :qc => RQ::QueueClient.new(params[:name].split('.json').first) }
end
end
if not RQ::QueueMgrClient.running?
- throw :halt, [503, "503 - QueueMgr not running"]
+ throw :halt, [503, '503 - QueueMgr not running']
end
begin
qc = RQ::QueueClient.new(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
ok, config = qc.get_config
@@ -174,20 +173,20 @@ def flash_now(type, msg)
get '/q/:name/done.json' do
if not RQ::QueueMgrClient.running?
- throw :halt, [503, "503 - QueueMgr not running"]
+ throw :halt, [503, '503 - QueueMgr not running']
end
begin
qc = RQ::QueueClient.new(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
limit = 10
if params['limit']
limit = params['limit'].to_i
end
- result = qc.messages({'state' => 'done', 'limit' => limit})
+ result = qc.messages( 'state' => 'done', 'limit' => limit )
"#{result.to_json}"
end
@@ -195,7 +194,7 @@ def flash_now(type, msg)
begin
qc = RQ::QueueClient.new(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
overrides = RQ::Overrides.new(params['name'])
@@ -211,22 +210,22 @@ def flash_now(type, msg)
end
# Normalize some values
- if prms.has_key? 'post_run_webhook' and prms['post_run_webhook'].is_a? String
+ if prms.key? 'post_run_webhook' and prms['post_run_webhook'].is_a? String
# clean webhook input of any spaces
# Ruby split..... so good!
prms['post_run_webhook'] = prms['post_run_webhook'].split ' '
end
- if prms.has_key? 'count'
+ if prms.key? 'count'
prms['count'] = prms['count'].to_i
end
- if prms.has_key? 'max_count'
+ if prms.key? 'max_count'
prms['max_count'] = prms['max_count'].to_i
end
begin
qc = get_queueclient(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
the_method = prms.fetch("_method", 'commit')
@@ -237,11 +236,11 @@ def flash_now(type, msg)
elsif the_method == 'commit'
result = qc.create_message(prms)
else
- throw :halt, [400, "400 - Invalid method param"]
+ throw :halt, [400, '400 - Invalid method param']
end
- if result == [ "fail", "oper_status: DOWN"]
- throw :halt, [503, "503 - Service Unavailable - Operationally Down"]
+ if result == ['fail', 'oper_status: DOWN']
+ throw :halt, [503, '503 - Service Unavailable - Operationally Down']
end
if api_call == 'json'
@@ -279,10 +278,10 @@ def flash_now(type, msg)
begin
qc = get_queueclient(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
- ok, config = qc.get_config()
+ ok, config = qc.get_config
config.to_json
end
@@ -299,13 +298,13 @@ def flash_now(type, msg)
begin
qc = get_queueclient(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
- ok, msg = qc.get_message({ 'msg_id' => msg_id })
+ ok, msg = qc.get_message( 'msg_id' => msg_id )
if ok != 'ok'
- throw :halt, [404, "404 - Message ID not found"]
+ throw :halt, [404, '404 - Message ID not found']
end
if fmt == :html
@@ -315,7 +314,7 @@ def flash_now(type, msg)
erb :message, :locals => { :q_name => qc.name, :msg_id => msg_id, :msg => msg }
end
else
- #content_type 'application/json'
+ # content_type 'application/json'
msg.to_json
end
end
@@ -327,27 +326,26 @@ def flash_now(type, msg)
begin
qc = get_queueclient(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
- ok, state = qc.get_message_state({ 'msg_id' => msg_id })
+ ok, state = qc.get_message_state( 'msg_id' => msg_id )
if ok != 'ok'
- throw :halt, [404, "404 - Message ID not found"]
+ throw :halt, [404, '404 - Message ID not found']
end
- [ state ].to_json
+ [state].to_json
end
-
post '/q/:name/:msg_id/clone' do
begin
qc = get_queueclient(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
- res = qc.clone_message({ 'msg_id' => params[:msg_id] })
+ res = qc.clone_message( 'msg_id' => params[:msg_id] )
if not res
throw :halt, [500, "500 - Couldn't clone message. Internal error."]
@@ -356,7 +354,7 @@ def flash_now(type, msg)
throw :halt, [500, "500 - Couldn't clone message. #{res.inspect}."]
end
- flash :notice, "Message cloned successfully"
+ flash :notice, 'Message cloned successfully'
redirect "/q/#{params[:name]}"
end
@@ -364,10 +362,10 @@ def flash_now(type, msg)
begin
qc = get_queueclient(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
- res = qc.run_message({ 'msg_id' => params[:msg_id] })
+ res = qc.run_message( 'msg_id' => params[:msg_id] )
if not res
throw :halt, [500, "500 - Couldn't run message. Internal error."]
@@ -376,7 +374,7 @@ def flash_now(type, msg)
throw :halt, [500, "500 - Couldn't run message. #{res.inspect}."]
end
- flash :notice, "Message in run successfully"
+ flash :notice, 'Message in run successfully'
redirect "/q/#{params[:name]}/#{params[:msg_id]}"
end
@@ -385,54 +383,53 @@ def flash_now(type, msg)
begin
qc = get_queueclient(params[:name])
rescue RQ::RqQueueNotFound
- throw :halt, [404, "404 - Queue not found"]
+ throw :halt, [404, '404 - Queue not found']
end
# Sample of what params look like
# {"name"=>"test", "filedata"=>{:type=>"image/jpeg", :head=>"Content-Disposition: form-data; name=\"data\"; filename=\"studio3.jpg\"\r\nContent-Type: image/jpeg\r\n", :tempfile=>#