from twisted.internet import protocol, reactor
from twisted.python import log
import sys

import api
import logwatch_config as config

class LogWatchModule (api.Module) :
    name = "logs"
    version = 0x0005
    
    event_types = [
        "error",
        "sudo",
        "ssh",
        "all"
    ]
    
    def handleConnect (self) :
        for source in config.sources() :
            source.setModule(self)
    
    def error (self, msg) :
        self.sendEvent("error", msg)

def makeService (config) :
    return api.makeService(LogWatchModule, config)