<reponame>klem4/panacea<gh_stars>1-10
# coding: utf-8

import panacea.config as conf
from panacea.schemes import CacheScheme, CacheConf
from panacea import tools

logger = tools.get_logger()


class CacheEngine(object):
    u"""
    движок кеширующего механизма
    """

    def __init__(self, request, response):
        self.request = request
        self.response = response
        self.urlconf = tools.resolve_path(request)
        self.scheme = None

    def process_caching(self):
        u"""
        кешируем результат выполнения запроса
        в соответствии с указанной схемой
        """

        # получим ключ, по которому будет
        # сохранен контент ответа api
        panacea_key = self.scheme.generate_store_key(self.request)
        self.store_schemes(panacea_key)

    def store_schemes(self, _key):
        """
        кешируем конткнт ответа от api под ключем key
        по всех схемам, описанных в конфиге для данного урла
        """
        # контент, который будем сохранять
        _content = self.response.content

        # пройдем по списку всех моделей,
        # которые связаны с данной схемой кеширования
        for model_conf in self.scheme.model_confs:
            cache_conf = CacheConf(model_conf, self.urlconf)

            # время жизни ключа для данной модели в рамках схемы
            _ttl = self.scheme.ttl
            # модель, к которой привязываем инвалидацию
            _model = cache_conf.model
            # dnf на основании query-set модели, на котором основываем валидацию
            _dnf = cache_conf._dnf

            # сохраняем данные в redis!
            tools.cache_thing(_model, _key, _content , _dnf, _ttl)

    def allow_caching(self):
        u"""
        проверяем, необходимо ли кешированть
        данный запрос
        """

        # кеширование отключено глобально
        if not conf.get('PCFG_ENABLED', default=False):
            return

        for checker_name in ('method', 'status_code', 'content_type', 'scheme'):
            method_name = 'chk_%s' % checker_name
            if hasattr(self, method_name):
                checker_method = getattr(self, 'chk_%s' % checker_name)
                if not checker_method():
                    return
            else:
                logger.error("handler not found: %s" % method_name)
                return

        return True

    def chk_method(self):
        u"""
        кешируем только GET-запросы
        """
        return self.request.method == 'GET'

    def chk_status_code(self):
        u"""
        кешируем только ответы с определенынми статусами
        """
        return self.response.status_code in conf.get('PCFG_ALLOWED_STATUS_CODES')

    def chk_content_type(self):
        u"""
        кешируем только ответы определенного типа
        """
        ct_and_charset = self.response.get('content-type').split(';')
        try:
            return ct_and_charset[0] == conf.get('PCFG_ALLOWED_CONTENT_TYPE')
        except IndexError:
            return False

    def chk_scheme(self):
        """
        метод проверки необходимости кеширования
        данного урла, производит поиск данных
        о кешировании в конфиге, в случае удачи, сохраняет
        вычисленные и необходимые для кеширования промежуточные
        данные и возвращает True
        """
        self.scheme = CacheScheme.filter(request=self.request)
        return self.scheme and self.scheme.enabled

# coding: utf-8

import panacea.config as conf
from panacea.schemes import CacheScheme, CacheConf
from panacea import tools

logger = tools.get_logger()


class CacheEngine(object):
    u"""
    движок кеширующего механизма
    """

    def __init__(self, request, response):
        self.request = request
        self.response = response
        self.urlconf = tools.resolve_path(request)
        self.scheme = None

    def process_caching(self):
        u"""
        кешируем результат выполнения запроса
        в соответствии с указанной схемой
        """

        # получим ключ, по которому будет
        # сохранен контент ответа api
        panacea_key = self.scheme.generate_store_key(self.request)
        self.store_schemes(panacea_key)

    def store_schemes(self, _key):
        """
        кешируем конткнт ответа от api под ключем key
        по всех схемам, описанных в конфиге для данного урла
        """
        # контент, который будем сохранять
        _content = self.response.content

        # пройдем по списку всех моделей,
        # которые связаны с данной схемой кеширования
        for model_conf in self.scheme.model_confs:
            cache_conf = CacheConf(model_conf, self.urlconf)

            # время жизни ключа для данной модели в рамках схемы
            _ttl = self.scheme.ttl
            # модель, к которой привязываем инвалидацию
            _model = cache_conf.model
            # dnf на основании query-set модели, на котором основываем валидацию
            _dnf = cache_conf._dnf

            # сохраняем данные в redis!
            tools.cache_thing(_model, _key, _content , _dnf, _ttl)

    def allow_caching(self):
        u"""
        проверяем, необходимо ли кешированть
        данный запрос
        """

        # кеширование отключено глобально
        if not conf.get('PCFG_ENABLED', default=False):
            return

        for checker_name in ('method', 'status_code', 'content_type', 'scheme'):
            method_name = 'chk_%s' % checker_name
            if hasattr(self, method_name):
                checker_method = getattr(self, 'chk_%s' % checker_name)
                if not checker_method():
                    return
            else:
                logger.error("handler not found: %s" % method_name)
                return

        return True

    def chk_method(self):
        u"""
        кешируем только GET-запросы
        """
        return self.request.method == 'GET'

    def chk_status_code(self):
        u"""
        кешируем только ответы с определенынми статусами
        """
        return self.response.status_code in conf.get('PCFG_ALLOWED_STATUS_CODES')

    def chk_content_type(self):
        u"""
        кешируем только ответы определенного типа
        """
        ct_and_charset = self.response.get('content-type').split(';')
        try:
            return ct_and_charset[0] == conf.get('PCFG_ALLOWED_CONTENT_TYPE')
        except IndexError:
            return False

    def chk_scheme(self):
        """
        метод проверки необходимости кеширования
        данного урла, производит поиск данных
        о кешировании в конфиге, в случае удачи, сохраняет
        вычисленные и необходимые для кеширования промежуточные
        данные и возвращает True
        """
        self.scheme = CacheScheme.filter(request=self.request)
        return self.scheme and self.scheme.enabled
# coding: utf-8 движок кеширующего механизма кешируем результат выполнения запроса         в соответствии с указанной схемой # получим ключ, по которому будет # сохранен контент ответа api кешируем конткнт ответа от api под ключем key         по всех схемам, описанных в конфиге для данного урла # контент, который будем сохранять # пройдем по списку всех моделей, # которые связаны с данной схемой кеширования # время жизни ключа для данной модели в рамках схемы # модель, к которой привязываем инвалидацию # dnf на основании query-set модели, на котором основываем валидацию # сохраняем данные в redis! проверяем, необходимо ли кешированть         данный запрос # кеширование отключено глобально кешируем только GET-запросы кешируем только ответы с определенынми статусами кешируем только ответы определенного типа метод проверки необходимости кеширования         данного урла, производит поиск данных         о кешировании в конфиге, в случае удачи, сохраняет         вычисленные и необходимые для кеширования промежуточные         данные и возвращает True