Contents

require 'redis'

# Redis session storage for Rails, and for Rails only. Derived from
# the MemCacheStore code, simply dropping in Redis instead.
#
# Options:
#  :key     => Same as with the other cookie stores, key name
#  :secret  => Encryption secret for the key
#  :host    => Redis host name, default is localhost
#  :port    => Redis port, default is 6370
#  :db      => Database number, defaults to 0. Useful to separate your session storage from other data
#  :key_prefix  => Prefix for keys used in Redis, e.g. myapp-. Useful to separate session storage keys visibly from others
#  :expire_after => A number in seconds to set the timeout interval for the session. Will map directly to expiry in Redis

class RedisSessionStore < ActionController::Session::AbstractStore

  def initialize(app, options = {})
    # Support old :expires option
    options[:expire_after] ||= options[:expires]

    super

    @default_options = {
      :namespace => 'rack:session',
      :host => 'localhost',
      :port => '6379',
      :db => 0,
      :key_prefix => ""
    }.update(options)

    @pool = Redis.new(@default_options)
    @mutex = Mutex.new

    super
  end

  private
    def prefixed(sid)
      "#{@default_options[:key_prefix]}#{sid}"
    end
    
    def get_session(env, sid)
      sid ||= generate_sid
      begin
        data = @pool.call_command([:get, prefixed(sid)])
        session = data.nil? ? {} : Marshal.load(data)
      rescue Errno::ECONNREFUSED
        session = {}
      end
      [sid, session]
    end

    def set_session(env, sid, session_data)
      options = env['rack.session.options']
      expiry  = options[:expire_after] || nil
      @pool.set(prefixed(sid), Marshal.dump(session_data), expiry)
      return true
    rescue Errno::ECONNREFUSED
      return false
    end
  
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
redis-session-store-0.1.4	lib/redis-session-store.rb