Werkzeug Redis Session Store

redis_session_store.py

# -*- coding: utf-8 -*-
"""
Created on 09/11/2011
@author: Carlo Pires <[email protected]>
"""
import tnetstring
from werkzeug.contrib.sessions import SessionStore

SESSION_TIMEOUT = 60*60*24*7 # 7 weeks in seconds

class RedisSessionStore(SessionStore):
    """
    SessionStore that saves session to redis
    """
    def __init__(self, redis, key_template='session:%s', generate_salt=None):

        if not generate_salt:
            from users import get_config
            generate_salt = get_config().users_secret

        SessionStore.__init__(self)
        self.redis = redis
        self.key_template = key_template
        self.generate_salt = generate_salt

    def new(self):
        """Generate a new session."""
        return self.session_class({}, self.generate_key(self.generate_salt), True)

    def get_session_key(self, sid):
        if isinstance(sid, unicode):
            sid = sid.encode('utf-8')
        return self.key_template % sid

    def save(self, session):
        key = self.get_session_key(session.sid)
        if self.redis.set(key, tnetstring.dumps(dict(session))):
            return self.redis.expire(key, SESSION_TIMEOUT)

    def delete(self, session):
        key = self.get_session_key(session.sid)
        return self.redis.delete(key)

    def get(self, sid):
        if not self.is_valid_key(sid):
            return self.new()
        
        key = self.get_session_key(sid)
        saved = self.redis.get(key)
        if saved:
            data = tnetstring.loads(saved)
            return self.session_class(data, sid, False)

    def list(self):
        """
        Lists all sessions in the store.
        """
        session_keys = self.redis.keys(self.key_template[:-2] + '*')
        return [s[len(self.key_template)-2:] for s in session_keys]