Contents

require "json"
require "multi_json"
require "sinatra"
require "sinatra/json"
require File.dirname(__FILE__) + '/queue'

queue = WorkerArmy::Queue.new

get '/' do
  job_count = queue.get_job_count || 0
  data = { :job_count => job_count }
  json data
end

post '/jobs' do
  data = JSON.parse(request.body.read)
  queue.push data if data
  json data
end

post '/callback' do
  data = JSON.parse(request.body.read)
  queue.save_result(data) if data
  json data
end

post '/generic_callback' do
  data = JSON.parse(request.body.read)
  status = { :status => 'ok' }
  json status
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
worker-army-0.2.0	lib/worker_army/web.rb