Sha256: cb9b323729779912d9ecf43a930120aebc5aee3e012a07c8eb4d450c925c8984
Contents?: true
Size: 1.61 KB
Versions: 16
Compression:
Stored size: 1.61 KB
Contents
require 'determinator/tracking/tracker'
require 'determinator/tracking/context'
module Determinator
module Tracking
class << self
attr_reader :endpoint_env_vars
def instance
Thread.current[:determinator_tracker]
end
def start!(type)
Thread.current[:determinator_tracker] = Tracker.new(type)
end
def finish!(endpoint:, error:, **attributes)
return false unless started?
request = instance.finish!(endpoint: endpoint, error: error, **attributes)
clear!
report(request)
request
end
def clear!
Thread.current[:determinator_tracker] = nil
end
def started?
!!instance
end
def track(id, guid, feature, determination)
return false unless started?
instance.track(id, guid, feature, determination)
end
def on_request(&block)
@on_request = block
end
def report(request)
return unless @on_request
@on_request.call(request)
end
def get_context(&block)
@get_context = block
end
def context
return unless @get_context
@get_context.call
rescue
nil
end
def clear_hooks!
@on_request = nil
@get_context = nil
end
def endpoint_env_vars=(vars)
@endpoint_env_vars = Array(vars)
end
def collect_endpoint_info(parts)
endpoint = Array(Determinator::Tracking.endpoint_env_vars).map{ |v| ENV[v] }
endpoint += Array(parts)
endpoint.reject{ |p| p.nil? || p == ''}.join(' ')
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems