Module: Tablesalt::ThreadAccessor::Management

Included in:
Tablesalt::ThreadAccessor
Defined in:
lib/tablesalt/thread_accessor/management.rb

Instance Method Summary collapse

Instance Method Details

#clean_thread_context(logger: nil, namespace: nil) { ... } ⇒ Object

Cleans up ThreadAccessor state after given block executes

Parameters:

  • :logger (Logger) —

    Optional; A logger instance that implements the method :warn to send warning messages to

Yields:

  • Required; Yields no variables to the given block



19
20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/tablesalt/thread_accessor/management.rb', line 19

def clean_thread_context(logger: nil, namespace: nil)
  if store(namespace).present?
    if logger.nil?
      puts "WARNING: ThreadAccessor variables set outside ThreadAccessor context: #{store(namespace).keys.join(", ")}"
    else
      logger.warn("ThreadAccessor variables set outside ThreadAccessor context: #{store(namespace).keys.join(", ")}")
    end
  end

  yield
ensure
  store(namespace).clear
end

#store(namespace = nil) ⇒ Object

Raises:

  • (ArgumentError) 


6
7
8
9
10
11
12
13
 
# File 'lib/tablesalt/thread_accessor/management.rb', line 6

def store(namespace = nil)
  raise ArgumentError, "cannot request a namespaced store from a namespaced accessor" if namespace.present? && self::THREAD_ACCESSOR_STORE_NAMESPACE.present?

  namespace = self::THREAD_ACCESSOR_STORE_NAMESPACE if namespace.nil?

  stores = Thread.current[Tablesalt::ThreadAccessor::THREAD_ACCESSOR_STORE_THREAD_KEY] ||= {}
  stores[namespace] ||= ThreadStore.new
end