Class: EndPointBlank::Writers::ResponseWriter

Inherits:
Object
  • Object
show all
Includes:
DelayedWriter, Shared, Singleton
Defined in:
lib/end_point_blank/writers/response_writer.rb

Constant Summary

Constants included from DelayedWriter

DelayedWriter::MAX_QUEUE_SIZE, DelayedWriter::WARN_THROTTLE_SECONDS

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Shared

#app_name, #apply_masking, #configuration, #env, #env_name, #request_uuid, #source_application_environment_id

Methods included from DelayedWriter

#direct_writer, #enqueue, #log_warning, #pop_additional, #queue, #start_threads

Constructor Details

#initialize ⇒ ResponseWriter

Returns a new instance of ResponseWriter.



14
15
16
17
 
# File 'lib/end_point_blank/writers/response_writer.rb', line 14

def initialize
  @url = EndPointBlank::Configuration.instance.responses_url
  start_threads
end

Instance Attribute Details

#url ⇒ Object (readonly)

Returns the value of attribute url.



12
13
14
 
# File 'lib/end_point_blank/writers/response_writer.rb', line 12

def url
  @url
end

Class Method Details

.write(status:, headers: {}, body: nil, data: {}) ⇒ Object 



19
20
21
 
# File 'lib/end_point_blank/writers/response_writer.rb', line 19

def self.write(status:, headers: {}, body: nil, data: {})
  instance.write(status:, headers:, body:, data:)
end

Instance Method Details

#payload(status:, headers:, body:, data: {}) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/end_point_blank/writers/response_writer.rb', line 23

def payload(status:, headers:, body:, data: {})
  request = ::EndPointBlank::Rack::EnvStore.request
  env = ::EndPointBlank::Rack::EnvStore.get
  headers = ::EndPointBlank::Rack::Headers.extract
  version = request ? Commands::VersionFinder.new.find(request) : nil
  route = request ? Commands::RoutePatternFinder.find(request) : nil

  {
      app_name: app_name,
      env: env_name,
      uuid: request_uuid(env),
      status: status,
      headers: headers,
      body: truncate(normalize_body(body)),
      sent_at: Time.now.utc.iso8601(3),
      route: route,
      data: data,
      source_application_environment_id: source_application_environment_id
  }
end

#write(status:, headers: {}, body: nil, data: {}) ⇒ Object 



44
45
46
 
# File 'lib/end_point_blank/writers/response_writer.rb', line 44

def write(status:, headers: {}, body: nil, data: {})
  enqueue(apply_masking(payload(status:, headers:, body:, data:), :response))
end