class JWTSessions::StoreAdapters::MemoryStoreAdapter
Attributes
storage[R]
Public Class Methods
new(**options)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 8 def initialize(**options) raise ArgumentError, "Memory store doesn't support any options" if options.any? @storage = Hash.new do |h, k| h[k] = Hash.new { |hh, kk| hh[kk] = {} } end end
Public Instance Methods
all_refresh_tokens(namespace)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 58 def all_refresh_tokens(namespace) namespace_keys = namespace.nil? ? storage.keys : [namespace] namespace_keys.each_with_object({}) do |namespace_key, acc| select_keys(storage[namespace_key]["refresh"], acc) end end
destroy_access(uid)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 70 def destroy_access(uid) storage[""]["access"].delete(uid) end
destroy_refresh(uid, namespace)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 66 def destroy_refresh(uid, namespace) storage[namespace.to_s]["refresh"].delete(uid) end
fetch_access(uid)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 15 def fetch_access(uid) access_token = value_if_not_expired(uid, "access", "") access_token.empty? ? {} : { csrf: access_token[:csrf] } end
fetch_refresh(uid, namespace, first_match = false)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 25 def fetch_refresh(uid, namespace, first_match = false) if first_match storage.keys.each do |namespace_key| val = value_if_not_expired(uid, "refresh", namespace_key) return val unless val.empty? end {} else value_if_not_expired(uid, "refresh", namespace.to_s) end end
persist_access(uid, csrf, expiration)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 20 def persist_access(uid, csrf, expiration) access_token = { csrf: csrf, expiration: expiration } storage[""]["access"].store(uid, access_token) end
persist_refresh(uid:, access_expiration:, access_uid:, csrf:, expiration:, namespace: "")
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 37 def persist_refresh(uid:, access_expiration:, access_uid:, csrf:, expiration:, namespace: "") update_refresh_fields( uid, namespace.to_s, csrf: csrf, access_expiration: access_expiration, access_uid: access_uid, expiration: expiration ) end
update_refresh(uid:, access_expiration:, access_uid:, csrf:, namespace: "")
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 48 def update_refresh(uid:, access_expiration:, access_uid:, csrf:, namespace: "") update_refresh_fields( uid, namespace.to_s, csrf: csrf, access_expiration: access_expiration, access_uid: access_uid ) end
Private Instance Methods
select_keys(keys_hash, acc)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 86 def select_keys(keys_hash, acc) keys_hash.keys.each do |uid| value = keys_hash[uid] if value[:expiration] && value[:expiration] < Time.now.to_i keys_hash.delete(key) else acc[uid] = value end end acc end
update_refresh_fields(key, namespace, fields)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 81 def update_refresh_fields(key, namespace, fields) updated_refresh = value_if_not_expired(key, "refresh", namespace).merge(fields) storage[namespace]["refresh"].store(key, updated_refresh) end
value_if_not_expired(key, token_type, namespace)
click to toggle source
# File lib/jwt_sessions/store_adapters/memory_store_adapter.rb, line 76 def value_if_not_expired(key, token_type, namespace) storage[namespace][token_type].reject! { |_, value| value[:expiration] && value[:expiration] < Time.now.to_i } storage[namespace][token_type][key] || {} end