1

import optparse, sys

     2

     3

from pvl.syslog.parser import SyslogParser

     4

from pvl.syslog.filter import SyslogFilter

     5

from pvl.syslog.syslog import SyslogSource

     6

from pvl.syslog import fifo, tail

     7

     8

# XXX: use optparse parser.error()?

     9

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

    10

    11

def parser (parser, prog=None) :

    12

    """

    13

        Optparse option group

    14

    15

            prog        - filter to only process lines from given process

    16

    """

    17

    18

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

    19

    20

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

    21

            help="Read syslog messages from given fifo")

    22

    23

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

    24

            help="Read syslog messages from given file")

    25

    26

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

    27

            help="Continuously poll file")

    28

    29

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

    30

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

    31

    32

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

    33

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

    34

    35

    return syslog

    36

    37

def apply (options, optional=False) :

    38

    """

    39

        Handle options, returning a SyslogSource, if any.

    40

    41

        May log.error/sys.exit

    42

    """

    43

    44

    if options.syslog_fifo :

    45

        # read fifo

    46

        source = fifo.Fifo(options.syslog_fifo)

    47

        poll = True

    48

    49

    elif options.syslog_tail :

    50

        # tail file

    51

        source = tail.TailFile(options.syslog_file, skip=True)

    52

        poll = options.syslog_tail # float

    53

    54

    elif options.syslog_file :

    55

        # read file

    56

        source = open(options.syslog_file)

    57

        poll = False

    58

    59

    elif optional :

    60

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

    61

        return None

    62

    63

    else :

    67

    68

    parser = SyslogParser(

    69

        raw     = options.syslog_raw,

    70

    )

    71

    72

    filter = SyslogFilter(

    73

        prog    = options.syslog_prog,

    74

    )

    75

    76

    # build

    77

    return SyslogSource(source, parser,

    78

            filter  = filter,

    79

            poll    = poll,

    80

    )

    81