1

#!/usr/bin/env python

     2

     3

"""

     4

    Syslog -> Irk

     5

"""

     6

     7

__version__ = '0.0'

     8

     9

import pvl.args

    10

import pvl.syslog.args

    11

import pvl.syslog.rule

    12

import pvl.irk

    13

    14

import logging, optparse

    15

    16

log = logging.getLogger('main')

    17

    18

def parse_options (argv) :

    19

    """

    20

        Parse command-line arguments.

    21

    """

    22

    23

    prog = argv[0]

    24

    25

    parser = optparse.OptionParser(

    26

            prog        = prog,

    27

            usage       = '%prog: [options]',

    28

            version     = __version__,

    29

    30

            # module docstring

    31

            description = __doc__,

    32

    )

    33

    34

    # options

    35

    parser.add_option_group(pvl.args.parser(parser))

    36

    37

    # input

    38

    parser.add_option_group(pvl.syslog.args.parser(parser))

    39

    parser.add_option_group(pvl.syslog.rule.parser(parser))

    40

    parser.add_option_group(pvl.irk.parser(parser, connect=None))

    41

    42

    parser.add_option('--irker-target', metavar='IRC',

    43

            help="Irker target URL")

    44

    45

    # parse

    46

    options, args = parser.parse_args(argv[1:])

    47

    48

    # apply

    49

    pvl.args.apply(options, prog, rootok=False)

    50

    51

    return options, args

    52

    53

def main (argv) :

    54

    options, args = parse_options(argv)

    55

    56

    if args :

    57

        # XXX: targets

    58

        target, = args

    59

    else :

    60

        target = None

    61

    62

    log.info("Open syslog...")

    63

    syslog = pvl.syslog.args.apply(options)

    64

    65

    log.info("Load rules...")

    66

    rules = pvl.syslog.rule.apply(options)

    67

    68

    log.info("Connect IRK..")

    69

    irker = pvl.irk.apply(options)

    70

    71

    if options.irker_target :

    72

        # pre-join target

    73

        irker[options.irker_target]

    74

    75

    log.info("Process syslog messages...")

    76

    77

    # customized mainloop that supports irker.irk

    78

    while True :

    79

        # syslogs

    80

        for item in syslog :

    81

            match, rulepath, apply = rules.apply(item)

    82

    83

            log.debug("%s: %s: %s", item, rulepath, apply)

    84

    85

            target = apply.get('irk', options.irker_target)

    86

    87

            tag = '/'.join(str(rule) for rule in reversed(rulepath[:-1]))

    88

            text = apply.get('text')

    89

    90

            log.info("%s: %s: %s", target, tag, text)

    91

    92

            if not text :

    93

                # XXX: plain irk = ... in rule is broken, as it always applies, and skips any further rules

    94

                continue

    95

    96

            if irker and target :

    97

                irker[target]('[' + tag + '] ' + text)

    98

            else :

    99

                print tag, text

   100

   103

            break

   104

   118

   123

   124

    # done

   125

    log.info("Exiting...")

   126

    return 0

   127

   128

if __name__ == '__main__':

   129

    import sys

   130

   131

    sys.exit(main(sys.argv))