Sha256: 41c739036bc4f77c54f4d7bb075e3d9004e06ac69cc1c135620513d387cec3c5
Contents?: true
Size: 1.61 KB
Versions: 36
Compression:
Stored size: 1.61 KB
Contents
# frozen_string_literal: true
require_relative 'engine'
module Datadog
module AppSec
module Reactive
# Reactive Engine nested operation tracking
class Operation
attr_reader :reactive,
:parent,
:name
def initialize(name, parent = nil, reactive_engine = nil)
Datadog.logger.debug { "operation: #{name} initialize" }
@name = name
@parent = parent
@reactive = select_reactive_engine(reactive_engine, parent)
# TODO: concurrent store
# TODO: constant
Thread.current[:datadog_security_active_operation] = self
yield self if block_given?
ensure
finalize
end
# TODO: use structs instead of an arg splat
def subscribe(*addresses, &block)
reactive.subscribe(*addresses, &block)
end
def publish(address, data)
reactive.publish(address, data)
end
def finalize
Datadog.logger.debug { "operation: #{name} finalize" }
Thread.current[:datadog_security_active_operation] = parent
end
private
def select_reactive_engine(reactive, parent)
return reactive if reactive
return parent.reactive unless parent.nil?
Reactive::Engine.new
end
class << self
def active
Thread.current[:datadog_security_active_operation]
end
private
# For testing only.
def reset!
Thread.current[:datadog_security_active_operation] = nil
end
end
end
end
end
end
Version data entries
36 entries across 36 versions & 2 rubygems