1

import optparse, sys

     2

     3

from pvl.syslog.parser import SyslogParser

     4

from pvl.syslog.syslog import SyslogSource

     5

from pvl.syslog import fifo, tail

     6

     7

# XXX: use optparse parser.error()?

     8

import logging; log = logging.getLogger('pvl.syslog.args')

     9

    10

def parser (parser, prog=None) :

    11

    """

    12

        Optparse option group

    13

    14

            prog        - filter to only process lines from given process

    15

    """

    16

    17

    syslog = optparse.OptionGroup(parser, 'Syslog collector')

    18

    19

    syslog.add_option('--syslog-fifo',          metavar='PATH',

    20

            help="Read syslog messages from given fifo")

    21

    22

    syslog.add_option('--syslog-file',          metavar='FILE',

    23

            help="Read syslog messages from given file")

    24

    25

    syslog.add_option('--syslog-tail',          type='float', metavar='POLL',

    26

            help="Continuously poll file")

    27

    28

    syslog.add_option('--syslog-raw',           action='store_true',

    29

            help="Parse raw syslog lines without timestamp/etc")

    30

    31

    syslog.add_option('--syslog-prog',          metavar='PROG',     default=prog,

    32

            help="Filter by given prog: %default")

    33

    34

    return syslog

    35

    36

def apply (options, optional=False) :

    37

    """

    38

        Handle options, returning a SyslogSource, if any.

    39

    40

        May log.error/sys.exit

    41

    """

    42

    43

    if options.syslog_fifo :

    44

        # read fifo

    45

        source = fifo.Fifo(options.syslog_fifo)

    46

    47

    elif options.syslog_file :

    48

        # tail file

    49

        source = tail.TailFile(options.syslog_file)

    50

    51

    elif optional :

    52

        log.debug("No --syslog source given")

    53

        return None

    54

    55

    else :

    56

        log.error("No --syslog source given")

    57

        sys.exit(2)

    58

    59

    parser = SyslogParser(

    60

        raw     = options.syslog_raw,

    61

        prog    = options.syslog_prog,

    62

    )

    63

    64

    # build

    65

    return SyslogSource(source, parser)

    66