Contents

require 'forwardable'
Dir[Thron.root.join('lib', 'thron', 'gateway', '*.rb')].each { |f| require f }

module Thron
  class User
    extend Forwardable
    
    def_delegators :@access_gateway, *Gateway::AccessManager::routes.keys

    def self.session_gateways
      @session_gateways ||= Gateway::constants.select do |name|
        Gateway.const_get(name) < Gateway::Session
      end
    end

    def self.delegate_to_gateways
      self.session_gateways.each do |name|
        gateway = Gateway.const_get(name)
        def_delegators "@gateways[:#{name}]", *(gateway.routes::keys + gateway.paginator_methods)
      end
    end

    delegate_to_gateways
    
    attr_reader :token_id, :gateways

    def initialize
      @access_gateway = Gateway::AccessManager::new
    end 

    def login(options)
      @access_gateway.login(options).tap do |response|
        @token_id = @access_gateway.token_id
        refresh_gateways
      end
    end

    def logout
      return unless logged?
      @token_id = @access_gateway.token_id = nil
      @gateways = nil
    end

    def disguise(options)
      response = su(options)
      response.body[:id].tap do |token_id|
        return response.error unless token_id
        original_token, @token_id = @token_id, token_id
        refresh_gateways
        yield if block_given?
        @token_id = original_token 
        refresh_gateways
      end
    end

    def logged?
      !!@token_id
    end

    private 
    
    def initialize_gateways
      self.class.session_gateways.reduce({}) do |acc, name|
        acc[name] = Gateway.const_get(name)::new(token_id: @token_id); acc
      end
    end

    def refresh_gateways
      return unless logged?
      return (@gateways = initialize_gateways) unless @gateways
      @access_gateway.token_id = @token_id
      @gateways.each do |name, gateway|
        gateway.token_id = @token_id
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
thron-0.7.0	lib/thron/user.rb