Contents

# frozen_string_literal: true

module KeycloakRack
  # A caching resolver that wraps around {KeycloakRack::KeyFetcher} to cache its result
  # for {KeycloakRack::Config#cache_ttl} seconds (default: 1.day)
  #
  # @api private
  class KeyResolver
    include Import[config: "keycloak-rack.config", fetcher: "keycloak-rack.key_fetcher"]

    delegate :cache_ttl, to: :config

    # @!attribute [r] cached_public_key_retrieved_at
    # @return [ActiveSupport::TimeWithZone]
    attr_reader :cached_public_key_retrieved_at

    # @!attribute [r] cached_public_keys
    # @return [Dry::Monads::Success({ Symbol => <{ Symbol => String }> })]
    # @return [Dry::Monads::Failure]
    attr_reader :cached_public_keys

    def initialize(**)
      super

      @cached_public_keys = Dry::Monads.Failure("nothing fetched yet")
      @cached_public_key_retrieved_at = 1.year.ago
    end

    # @see KeycloakRack::PublicKeyResolver#find_public_keys
    # @return [Dry::Monads::Success({ Symbol => Object })]
    # @return [Dry::Monads::Failure(Symbol, String)]
    def find_public_keys
      fetch! if should_refetch?

      @cached_public_keys
    end

    def has_failed_fetch?
      @cached_public_keys.failure?
    end

    def has_outdated_cache?
      Time.current > @cached_public_key_expires_at
    end

    # @return [void]
    def refresh!
      fetch!
    end

    def should_refetch?
      has_failed_fetch? || has_outdated_cache?
    end

    private

    # @return [void]
    def fetch!
      @cached_public_keys = fetcher.find_public_keys
      @cached_public_key_retrieved_at = Time.current
      @cached_public_key_expires_at = @cached_public_key_retrieved_at + cache_ttl.seconds
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
keycloak_rack-1.1.1	lib/keycloak_rack/key_resolver.rb
keycloak_rack-1.1.0	lib/keycloak_rack/key_resolver.rb
keycloak_rack-1.0.0	lib/keycloak_rack/key_resolver.rb