class OneApm::Agent::JavascriptInstrumentor

Constants

OA_AGENT_KEY
OA_APPLICATIONID_KEY
OA_APPLICATION_TIME_KEY
OA_BEACON_KEY
OA_ERROR_BEACON_KEY
OA_LICENSE_KEY_KEY
OA_QUEUE_TIME_KEY
OA_RUM_KEY_LENGTH
OA_SSL_FOR_HTTP_KEY
OA_TRANSACTION_NAME_KEY
OA_USER_ATTRIBUTES_KEY

Public Class Methods

new(event_listener) click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 14
def initialize(event_listener)
  event_listener.subscribe(:finished_configuring, &method(:log_configuration))
end

Public Instance Methods

add_ssl_for_http(data) click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 156
def add_ssl_for_http(data)
  ssl_for_http = OneApm::Manager.config[:'browser_monitoring.ssl_for_http']
  unless ssl_for_http.nil?
    data[OA_SSL_FOR_HTTP_KEY] = ssl_for_http
  end
end
add_user_attributes(data, txn) click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 163
def add_user_attributes(data, txn)
  return unless include_custom_parameters?(txn)

  params = event_params(txn.custom_parameters)
  json = OneApm::JSONWrapper.dump(params)
  data[OA_USER_ATTRIBUTES_KEY] = obfuscator.obfuscate(json)
end
browser_timing_config(state) click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 111
def browser_timing_config(state)
  txn = state.current_transaction
  return '' if txn.nil?

  txn.freeze_name_and_execute_if_not_ignored do
    data = data_for_js_agent(state)
    json = OneApm::JSONWrapper.dump(data)
    return html_safe_if_needed("\n<script type=\"text/javascript\">window.BWEUM||(BWEUM={});BWEUM.info=#{json}</script>")
  end

  ''
end
browser_timing_header() click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 87
def browser_timing_header
  return '' unless js_enabled_and_ready? # fast exit

  state = OneApm::TransactionState.tl_get

  return '' unless insert_js?(state) # slower exit

  bt_config = browser_timing_config(state)
  return '' if bt_config.empty?

  bt_config + browser_timing_loader
rescue => e
  OneApm::Manager.logger.debug "Failure during RUM browser_timing_header construction", e
  ''
end
browser_timing_loader() click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 103
def browser_timing_loader
  if Manager.config[:'browser_monitoring.is_js_text']
    html_safe_if_needed("\n<script type=\"text/javascript\">#{Manager.config[:js_agent_loader]}</script>")
  else
    html_safe_if_needed("\n<script type=\"text/javascript\" src=\"#{Manager.config[:js_agent_loader]}\"></script>")
  end
end
data_for_js_agent(state) click to toggle source

NOTE: Internal prototyping may override this, so leave name stable!

# File lib/one_apm/agent/javascript_instrumentor.rb, line 136
def data_for_js_agent(state)
  timings = state.timings

  data = {
    OA_BEACON_KEY           => OneApm::Manager.config[:beacon],
    OA_ERROR_BEACON_KEY     => OneApm::Manager.config[:error_beacon],
    OA_LICENSE_KEY_KEY      => OneApm::Manager.config[:browser_key],
    OA_APPLICATIONID_KEY    => OneApm::Manager.config[:application_id],
    OA_TRANSACTION_NAME_KEY => obfuscator.obfuscate(timings.transaction_name_or_unknown),
    OA_QUEUE_TIME_KEY       => timings.queue_time_in_millis,
    OA_APPLICATION_TIME_KEY => timings.app_time_in_millis,
    OA_AGENT_KEY            => OneApm::Manager.config[:js_agent_file]
  }

  add_ssl_for_http(data)
  add_user_attributes(data, state.current_transaction)

  data
end
enabled?() click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 28
def enabled?
  OneApm::Manager.config[:'rum.enabled'] && !!Manager.config[:beacon]
end
has_custom_parameters?(txn) click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 175
def has_custom_parameters?(txn)
  txn && txn.custom_parameters && !txn.custom_parameters.empty?
end
html_safe_if_needed(string) click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 179
def html_safe_if_needed(string)
  string = string.html_safe if string.respond_to?(:html_safe)
  string
end
include_custom_parameters?(txn) click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 171
def include_custom_parameters?(txn)
  has_custom_parameters?(txn) && OneApm::Manager.config[:'browser_monitoring.capture_attributes']
end
insert_js?(state) click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 61
def insert_js?(state)
  if !state.current_transaction
    OneApm::Manager.logger.debug "Not in transaction. Skipping browser instrumentation."
    false
  elsif !state.is_transaction_traced?
    OneApm::Manager.logger.debug "Transaction is not traced. Skipping browser instrumentation."
    false
  elsif !state.is_execution_traced?
    OneApm::Manager.logger.debug "Execution is not traced. Skipping browser instrumentation."
    false
  elsif state.current_transaction.ignore_enduser?
    OneApm::Manager.logger.debug "Ignore end user for this transaction is set. Skipping browser instrumentation."
    false
  else
    true
  end
rescue => e
  OneApm::Manager.logger.debug "Failure during insert_js", e
  false
end
js_enabled_and_ready?() click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 36
def js_enabled_and_ready?
  if !enabled?
    OneApm::Manager.logger.log_once(:debug, :js_agent_disabled,
                                      "JS agent instrumentation is disabled.")
    false
  elsif missing_config?(:js_agent_loader)
    OneApm::Manager.logger.log_once(:debug, :missing_js_agent_loader,
                                      "Missing :js_agent_loader. Skipping browser instrumentation.")
    false
  elsif missing_config?(:beacon)
    OneApm::Manager.logger.log_once(:debug, :missing_beacon,
                                      "Beacon configuration not received (yet?). Skipping browser instrumentation.")
    false
  elsif missing_config?(:browser_key)
    OneApm::Manager.logger.log_once(:debug, :missing_browser_key,
                                      "Browser key is not set. Skipping browser instrumentation.")
    false
  else
    true
  end
rescue => e
  OneApm::Manager.logger.debug "Failure during 'js_enabled_and_ready?'", e
  false
end
log_configuration() click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 18
def log_configuration
  OneApm::Manager.logger.debug("JS agent loader requested: #{OneApm::Manager.config[:'browser_monitoring.loader']}",
                               "JS agent loader debug: #{OneApm::Manager.config[:'browser_monitoring.debug']}",
                               "JS agent loader version: #{OneApm::Manager.config[:'browser_monitoring.loader_version']}")

  if !OneApm::Manager.config[:'rum.enabled']
    OneApm::Manager.logger.debug("Real User Monitoring is disabled for this agent. Edit your configuration to change this.")
  end
end
missing_config?(key) click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 82
def missing_config?(key)
  value = OneApm::Manager.config[key]
  value.nil? || value.empty?
end
obfuscator() click to toggle source
# File lib/one_apm/agent/javascript_instrumentor.rb, line 32
def obfuscator
  @obfuscator ||= OneApm::Agent::Obfuscator.new(OneApm::Manager.config[:license_key], OA_RUM_KEY_LENGTH)
end