BATCAVE/ffstatus/redisstorage.py

#!/usr/bin/python
# -*- coding: utf-8 -*-

import json
import logging
import redis

from .basestorage import BaseStorage


class RedisStorage(BaseStorage):
    """Redis-backed storage"""

    FIELDSUFFIX_TYPE = '__TYPE'

    def __init__(self,
                 redis_host='127.0.0.1', redis_port=6379, redis_password=None):
        self.logger = logging.getLogger('RedisStorage')

        self.logger.debug('Connecting to REDIS database at %s on port %d.',
                          redis_host, redis_port)
        self.db = redis.StrictRedis(host=redis_host, port=redis_port,
                                    password=redis_password)
        self.logger.info('Connected to REDIS database with %d entries.',
                         self.db.dbsize())

    def save(self):
        self.db.save()

    def get_node(self, id):
        return self.get_node_data(id)

    def get_all_nodes_raw(self):
        keys = self.db.keys('node_*')
        nodes = {}
        for key in keys:
            node_id = key[5:]
            node = self.get_node_data(node_id)
            nodes[node_id] = node
        return nodes

    def set_node_data(self, key, data):
        if data is None or len(data) == 0:
            self.db.delete('node_' + key)
            return

        thedata = {}
        for item in data:
            payload = data[item]
            if isinstance(payload, basestring):
                thedata[item] = data[item]
                thedata[item + self.FIELDSUFFIX_TYPE] = 'str'
            elif isinstance(payload, int):
                thedata[item] = str(data[item])
                thedata[item + self.FIELDSUFFIX_TYPE] = 'int'
            elif isinstance(payload, float):
                thedata[item] = str(data[item])
                thedata[item + self.FIELDSUFFIX_TYPE] = 'float'
            else:
                thedata[item] = json.dumps(data[item])
                thedata[item + self.FIELDSUFFIX_TYPE] = 'json'
        self.db.hmset('node_' + key, thedata)

    def get_node_data(self, key):
        node = {}
        thedata = self.db.hgetall('node_' + key)
        if thedata is None:
            return None

        for item in thedata:
            if item.endswith(self.FIELDSUFFIX_TYPE):
                continue

            fieldtype = thedata.get(item + self.FIELDSUFFIX_TYPE, 'str')
            payload = thedata[item]

            if fieldtype == 'json':
                node[item] = json.loads(payload)
            elif fieldtype == 'int':
                node[item] = int(payload)
            elif fieldtype == 'float':
                node[item] = float(payload)
            else:
                node[item] = payload

        return node

    def get_vpn_keys(self):
        keys = [key[4:] for key in self.db.keys('vpn_*')]
        return keys

    def get_vpn_item(self, key, create=False):
        self.check_vpn_key(key)
        rawdata = self.db.get('vpn_' + key)
        if rawdata is None:
            if not create:
                return None
            self.store_vpn_item(key, {'active': {}, 'last': {}})
            rawdata = self.db.get('vpn_' + key)
        data = json.loads(rawdata)
        return data

    def store_vpn_item(self, key, data):
        self.check_vpn_key(key)
        self.db.set('vpn_' + key, json.dumps(data))