Module: ActiveSupport::Cache::Strategy::LocalCache

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 85

def cleanup(options = nil) # :nodoc:
  return super unless cache = local_cache
  cache.clear(options)
  super
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 79

def clear(options = nil) # :nodoc:
  return super unless cache = local_cache
  cache.clear(options)
  super
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 108

def decrement(name, amount = 1, options = nil) # :nodoc:
  return super unless local_cache
  value = bypass_local_cache { super }
  if options
    write_cache_value(name, value, raw: true, **options)
  else
    write_cache_value(name, value, raw: true)
  end
  value
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 162

def delete_entry(key, **)
  local_cache.delete_entry(key) if local_cache
  super
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 91

def delete_matched(matcher, options = nil) # :nodoc:
  return super unless cache = local_cache
  cache.clear(options)
  super
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 97

def increment(name, amount = 1, options = nil) # :nodoc:
  return super unless local_cache
  value = bypass_local_cache { super }
  if options
    write_cache_value(name, value, raw: true, **options)
  else
    write_cache_value(name, value, raw: true)
  end
  value
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 181

def local_cache
  LocalCacheRegistry.cache_for(local_cache_key)
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 177

def local_cache_key
  @local_cache_key ||= "#{self.class.name.underscore}_local_cache_#{object_id}".gsub(/[\/-]/, "_").to_sym
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 73

def middleware
  @middleware ||= Middleware.new(
    "ActiveSupport::Cache::Strategy::LocalCache",
    local_cache_key)
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 134

def read_multi_entries(names, **options)
  return super unless local_cache

  keys_to_names = names.index_by { |name| normalize_key(name, options) }

  local_entries = local_cache.read_multi_entries(keys_to_names.keys)
  local_entries.transform_keys! { |key| keys_to_names[key] }
  local_entries.transform_values! do |payload|
    deserialize_entry(payload, **options)&.value
  end
  missed_names = names - local_entries.keys

  if missed_names.any?
    local_entries.merge!(super(missed_names, **options))
  else
    local_entries
  end
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 120

def read_serialized_entry(key, raw: false, **options)
  if cache = local_cache
    hit = true
    entry = cache.fetch_entry(key) do
      hit = false
      super
    end
    options[:event][:store] = cache.class.name if hit && options[:event]
    entry
  else
    super
  end
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 189

def use_temporary_local_cache(temporary_cache)
  save_cache = LocalCacheRegistry.cache_for(local_cache_key)
  begin
    LocalCacheRegistry.set_cache_for(local_cache_key, temporary_cache)
    yield
  ensure
    LocalCacheRegistry.set_cache_for(local_cache_key, save_cache)
  end
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 67

def with_local_cache(&block)
  use_temporary_local_cache(LocalStore.new, &block)
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 167

def write_cache_value(name, value, **options)
  name = normalize_key(name, options)
  cache = local_cache
  if value
    cache.write_entry(name, serialize_entry(new_entry(value, **options), **options))
  else
    cache.delete_entry(name)
  end
end

# File 'activesupport/lib/active_support/cache/strategy/local_cache.rb', line 153

def write_serialized_entry(key, payload, **)
  if return_value = super
    local_cache.write_entry(key, payload) if local_cache
  else
    local_cache.delete_entry(key) if local_cache
  end
  return_value
end