Sha256: be5c45f56ac7b60cf1bcc6e69d3ec72a6c849393a05abb5511a1b835aa0d7a25
Contents?: true
Size: 979 Bytes
Versions: 5
Compression:
Stored size: 979 Bytes
Contents
require 'json'
require 'rack'
module RailsCloudTasks
module Rack
class Tasks
class << self
def call(env)
request = ::Rack::Request.new(env)
job = extract_job(request)
RailsCloudTasks::Instrumentation.transaction_name!(
"RailsCloudTasks/#{job['job_class']}/perform_now"
)
ActiveJob::Base.execute(job)
response(200, {})
rescue Rack::InvalidPayloadError => e
response(400, { error: e.cause.message })
rescue StandardError => e
response(500, { error: e.message })
end
private
def extract_job(request)
body = request.body.read
JSON.parse(body).fetch('job')
rescue JSON::ParserError, KeyError
raise Rack::InvalidPayloadError
end
def response(status, body)
[status, { 'Content-Type' => 'application/json' }, [body.to_json]]
end
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems