Sha256: 3b7f737c25815eb027dc493624eb7209996c7c136179b15d424c6854acc2b494
Contents?: true
Size: 1.06 KB
Versions: 6
Compression:
Stored size: 1.06 KB
Contents
require 'json'
require 'rack'
module RailsCloudTasks
module Rack
class Jobs
class << self
def call(env)
job_class = extract_job_class(env)
RailsCloudTasks::Instrumentation.transaction_name!(
"RailsCloudTasks/#{job_class}/perform_now"
)
request = ::Rack::Request.new(env)
job_args = extract_args(request)
job_class.perform_now(*job_args)
response(200, {})
rescue Rack::InvalidPayloadError => e
response(422, { error: e.message })
end
private
def extract_job_class(env)
env.dig('action_dispatch.request.path_parameters', :job_class)
.constantize
end
def extract_args(request)
body = request.body.read
JSON.parse(body) || []
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
6 entries across 6 versions & 1 rubygems