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)

          ActiveJob::Base.execute(job)

          response(200, { error: nil })
        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

1 entries across 1 versions & 1 rubygems

Version	Path
rails-cloud-tasks-0.0.1	lib/rails_cloud_tasks/rack/tasks.rb