Class: Julewire::Rails::RequestCompletion

Inherits:
Object
  • Object
show all
Defined in:
lib/julewire/rails/request_completion.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(configuration:, execution_handle:, instrumenter_handle:, env:, request:, request_error:) ⇒ RequestCompletion

Returns a new instance of RequestCompletion.



20
21
22
23
24
25
26
27
 
# File 'lib/julewire/rails/request_completion.rb', line 20

def initialize(configuration:, execution_handle:, instrumenter_handle:, env:, request:, request_error:)
  @configuration = configuration
  @execution_handle = execution_handle
  @instrumenter_handle = instrumenter_handle
  @env = env
  @request = request
  @request_error = request_error
end

Class Method Details

.finish_instrumentation(instrumenter_handle) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
 
# File 'lib/julewire/rails/request_completion.rb', line 7

def finish_instrumentation(instrumenter_handle)
  instrumenter_handle&.finish
rescue StandardError
  nil
ensure
  begin
    ::ActiveSupport::LogSubscriber.flush_all!
  rescue StandardError
    nil
  end
end

Instance Method Details

#attach(response) ⇒ Object 



29
30
31
32
33
34
35
36
37
 
# File 'lib/julewire/rails/request_completion.rb', line 29

def attach(response)
  status, headers, body = response
  timeout_token = nil
  finish_once = completion_callback { RequestSummaryTimeoutScheduler.cancel(timeout_token) }
  install_response_finished_callback(finish_once)
  timeout_token = install_completion_timeout
  body = ContextBodyProxy.new(body, handle: @execution_handle, on_close: -> { finish_once.call(nil) })
  response.frozen? ? [status, headers, body] : response.tap { it[2] = body }
end