Subversion Repositories HomeAutomation

###########################################################

#

# The default implementation of the packet handler

#

###########################################################

from CanPktHandlerBase import CanPktHandlerBase

from CanPkt import CanPkt

class SpacePort():

    filterSpaces = {}

    def __init__ (self, filterSpaces):

        for fs in filterSpaces:

            self.filterSpaces[fs.name] = fs

    def runAll(self, args):

        for fs in filterSpaces.values():

            relatedSpaces = s.__RELATED_SPACES__

            fs.run(relatedSpaces, args)

    def run(self, spaceName, args):

        filtersSpaces[spaceName].run(args)

class CanPktHandler1(CanPktHandlerBase):

    daemonCfg = None

    def __init__ (self, daemonCfg):

        self.daemonCfg = daemonCfg

    def input(self, strdata):

        """Make data buffer into CanPkt and do early discard check """

        """Call all filters in chain """

        if len(strdata) < 2:

            return

        if strdata[0:3] != 'PKT':

            return

#        print strdata

        pkt = CanPkt.stringToCanPkt(self, strdata)

#        print 'incoming: ' + pkt.toString()

        for filter in self.daemonCfg.filterChain:

            fObj = self.daemonCfg.filterCfg.filterModules[filter]

            sp = SpacePort(fObj.__ASSOCIATED_SPACES__)

            fObj.filter('', pkt, sp) # FIXME: use if name

    def output(self, data):

        pass