3

import re # XXX

     4

import os.path, fnmatch

     5

     8

        Match syslog messages fields against given patterns.

    11

    def __init__ (self, **filters) :

    13

            Match using given { field: regex }.

    16

        self.filters = filters

    18

    def match_prog (self, attr, filter, prog=None) :

    20

            XXX: Match given prog as glob?

    23

        if not filter :

    24

            # ignore

    25

            return None

    28

        prog = prog.strip().lower()

    29

        _, prog = os.path.split(prog)

    32

        if fnmatch.fnmatch(prog, filter) :

    33

            return { attr: prog }

    34

        else :

    37

    def match (self, attr, regex, value=None) :

    38

        """

    39

            Match given value against given pattern.

    40

        """

    42

        if not filter :

    43

            # ignore

    44

            return None

    45

    46

        if not value :

    47

            # XXX: optional = match empty string?

    48

            value = ''

    50

            # normalize; XXX: unicode?

    51

            value = str(value).strip()

    52

    53

        # match

    54

        match = regex.match(value)

    55

    56

        if match :

    57

            # as matche-values

    58

            match = match.groupdict()

    59

            match[attr] = value

    60

    61

        return match

    65

            Match given item. Returns any matched values (including regexp capture groups) across all fields.

    68

        matches = {}

    69

    70

        for attr in self.filters :

    71

            # lookup match-func

    72

            match = getattr(self, 'match_{attr}'.format(attr=attr), self.match)

    73

    74

            # filter

    75

            filter = self.filters[attr]

    76

    77

            # apply match

    78

            if attr in item :

    79

                match = match(attr, filter, item[attr])

    80

            else :

    81

                match = match(attr, filter)

    82

    83

            log.debug("%s: %s", attr, match)

    86

                # match

    87

                matches.update(match)

    90

                # ignore

    91

                continue

    94

                # reject

    95

                return

    97

        # XXX: test last match, in case they were all None

   102

            return matches

   104

    def process (self, items) :

   106

            match = self.filter(item)

   107

   108

            if match :

   110

   111

    __call__ = process