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