Class: Zaikio::JWTAuth::DirectoryCache

Inherits:
Object
  • Object
show all
Defined in:
lib/zaikio/jwt_auth/directory_cache.rb

Defined Under Namespace

Classes: UpdateJob

Constant Summary collapse

BadResponseError = 
Class.new(StandardError)

Class Method Summary collapse

Class Method Details

.fetch(directory_path, options = {}) ⇒ Object

Retrieve some data from the Hub, reachable at ‘directory_path`. Attempts to retrieve data from a cache first (usually Redis, if configured). Caching can be skipped by setting an `:invalidate` option, or if the cached data is stale it will be refetched from the Hub anyway. Please note that this method can return `nil` if there is no cache available and the Hub is giving error responses or failures.

Examples:

Fetching revoked access token information


DirectoryCache.fetch("api/v1/revoked_access_tokens.json")


31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/zaikio/jwt_auth/directory_cache.rb', line 31

def fetch(directory_path, options = {})
  cache = begin
    Zaikio::JWTAuth.configuration.cache.read("zaikio::jwt_auth::#{directory_path}")
  rescue StandardError => e
    Zaikio::JWTAuth.configuration.logger
                   .warn("Error reading DirectoryCache(#{directory_path}) from Cache, falling "\
                         "back to API: #{e.inspect}")
    nil
  end

  return reload_or_enqueue(directory_path) unless cache

  json = Oj.load(cache)

  if options[:invalidate] || cache_expired?(json, options[:expires_after])
    reload_or_enqueue(directory_path)
  end || json["data"]
end

.reset(directory_path) ⇒ Object 



59
60
61
 
# File 'lib/zaikio/jwt_auth/directory_cache.rb', line 59

def reset(directory_path)
  Zaikio::JWTAuth.configuration.cache.delete("zaikio::jwt_auth::#{directory_path}")
end

.update(directory_path, options = {}) ⇒ Object 



50
51
52
53
54
55
56
57
 
# File 'lib/zaikio/jwt_auth/directory_cache.rb', line 50

def update(directory_path, options = {})
  data = fetch(directory_path, options)
  data = yield(data)
  Zaikio::JWTAuth.configuration.cache.write("zaikio::jwt_auth::#{directory_path}", {
    fetched_at: Time.now.to_i,
    data: data
  }.to_json)
end