class Fleck::Consumer::Response
Attributes
body[RW]
errors[RW]
headers[RW]
id[RW]
status[RW]
Public Class Methods
new(request_id)
click to toggle source
# File lib/fleck/consumer/response.rb, line 8 def initialize(request_id) @id = request_id logger.progname += " #{@id}" @status = 200 @errors = [] @headers = {} @body = nil @rejected = false @requeue = false @deprecated = false end
Public Instance Methods
deprecated!()
click to toggle source
# File lib/fleck/consumer/response.rb, line 34 def deprecated! @deprecated = true end
deprecated?()
click to toggle source
# File lib/fleck/consumer/response.rb, line 38 def deprecated? @deprecated end
not_found(msg = nil)
click to toggle source
# File lib/fleck/consumer/response.rb, line 42 def not_found(msg = nil) @status = 404 @errors << 'Resource Not Found' @errors << msg if msg end
reject!(requeue: false)
click to toggle source
# File lib/fleck/consumer/response.rb, line 21 def reject!(requeue: false) @rejected = true @requeue = requeue end
rejected?()
click to toggle source
# File lib/fleck/consumer/response.rb, line 26 def rejected? return @rejected end
render_error(status, msg = [])
click to toggle source
# File lib/fleck/consumer/response.rb, line 48 def render_error(status, msg = []) @status = status.to_i if msg.is_a?(Array) @errors += msg else @errors << msg end end
requeue?()
click to toggle source
# File lib/fleck/consumer/response.rb, line 30 def requeue? return @requeue end
to_json(filter: false)
click to toggle source
# File lib/fleck/consumer/response.rb, line 57 def to_json(filter: false) data = { "status" => @status, "errors" => @errors, "headers" => @headers, "body" => @body, "deprecated" => @deprecated } data.filter! if filter return Oj.dump(data, mode: :compat) rescue => e logger.error e.inspect + "\n" + e.backtrace.join("\n") return Oj.dump({ "status" => 500, "errors" => ['Internal Server Error', 'Failed to dump the response to JSON'] }, mode: :compat) end
to_s()
click to toggle source
# File lib/fleck/consumer/response.rb, line 76 def to_s return "#<#{self.class} #{self.to_json(filter: true)}>" end