1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
# -*- coding: UTF-8 -*-
# Copyright 2014 Red Hat, Inc.
# Part of clufter project
# Licensed under GPLv2+ (a copy included | http://gnu.org/licenses/gpl-2.0.txt)
"""Filter manager"""
__author__ = "Jan Pokorný <jpokorny @at@ Red Hat .dot. com>"
import logging
from .error import ClufterError
from .filter import filters
from .format import CompositeFormat
from .format_manager import FormatManager
from .plugin_registry import PluginManager
log = logging.getLogger(__name__)
class FilterManagerError(ClufterError):
pass
class FilterManager(PluginManager):
"""Class responsible to manage filters and filtering itself"""
_default_registry = filters
@classmethod
def _init_plugins(cls, filters, fmt_mgr=None, **kwargs):
log.debug("Filters before resolving: {0}".format(filters))
if fmt_mgr is None:
fmts = set()
for flt in filters.itervalues():
# XXX composite format
map(lambda a: fmts.add(getattr(flt, a)),
('in_format', 'out_format'))
fmt_mgr = FormatManager.init_lookup(fmts, **kwargs)
return cls._resolve(fmt_mgr.formats, filters)
@staticmethod
def _resolve(formats, filters):
def get_composite_onthefly(formats):
# XXX should rather be implemented by CompositeFormat itself?
composite_onthefly = \
lambda protocol, *args: \
CompositeFormat(protocol, formats=formats, *args)
# XXX currently instantiation only (no match for composite classes)
composite_onthefly.as_instance = composite_onthefly
composite_onthefly.context = CompositeFormat.context
return composite_onthefly
for flt_name, flt_cls in filters.items():
ret = flt_cls(formats)
if ret is not None:
filters[flt_name] = ret
else:
filters.pop(flt_name)
return filters
@property
def filters(self):
return self._plugins
def __call__(self, which, in_decl, **kwargs):
flt = self._plugins[which]
in_obj = flt.in_format.as_instance(*in_decl)
return flt(in_obj, **kwargs)
|
