module Tablesalt::ThreadAccessor::Management

Public Instance Methods

clean_thread_context(logger: nil, namespace: nil) { || ... } click to toggle source

Cleans up ThreadAccessor state after given block executes

@param :logger [Logger] Optional; A logger instance that implements the method :warn to send warning messages to @yield Required; Yields no variables to the given block

# 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) click to toggle source
# 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