Example of customized subscriptions

ecards.py

from collections import defaultdict

from sideboard.lib import notify, listify, threadlocal

__all__ = ['get', 'send']

ecards = defaultdict(list)


class user_subscribes(object):
    def __init__(self, func):
        self.func = func

    @property
    def subscribes(self):
        params = listify(threadlocal.get('message', {}).get('params', []))
        if isinstance(params, dict):
            return ['ecards.' + params['username']]
        else:
            return ['ecards.' + params[0]]

    def __call__(self, *args, **kwargs):
        return self.func(*args, **kwargs)


@user_subscribes
def get(username):
    return ecards[username]


def send(username, message):
    ecards[username].append(message)
    notify('ecards.' + username)