AToMPM/mt/ptcal/pytcore/rules/crule.py

from ..tcore.composer import Composer
from ...tconstants import TConstants as TC

class CRule(Composer):

    def __init__(self,motifContext):
        self._mtContexts = []
        self._mtContexts.append(motifContext)
        self.cruleEnd = False
        self.packet = None
    
    def packet_in(self, packet):
        
        self.cruleEnd = False
        self._mtContexts[-1]._expired=False
        self._mtContexts[-1]._lastStep={}
        
        self.exception = None
        self.is_success = False
        self.packet = packet
        while not self.cruleEnd:
            result = self._step()
            self.is_success = result if result != None else False
        
        return self.packet
            

    def _nextRule(self) :
        mtc = self._mtContexts[-1]

        ns = mtc.nextStep()

        if 'id' in ns :
        
            fulltype = mtc.t['nodes'][ns['id']]['$type']
            
            if fulltype == mtc.metamodel+"CRule":
                
                #self._loadTransform(ns['rule'])
                
                return self._nextRule()
                
            elif fulltype.startswith('/Formalisms/__Transformations__/Transformation/T-Core') or\
                    fulltype.startswith('/Formalisms/__Transformations__/Transformation/MoTif'):
                    
                return ns

        elif 'trafoResult' in ns:
            return ns;
        
    def _step(self) :       

        def runRule(r) :
            
            ar = r['rule']
            
            self.packet = ar.packet_in(self.packet)

            if ar.is_success :
                return (self.packet.deltas,TC.SUCCEEDED)
            elif not ar.is_success :
                if ar.exception :
                    return (str(ar.exception),TC.EXCEPTION)
                else :
                    return (None,TC.FAILED)

        try :
            nr = self._nextRule()
        except Exception :
            self.cruleEnd = True
            return

        if 'trafoResult' in nr:
            self.cruleEnd = True
            return nr['trafoResult']

        if nr.__class__ != {}.__class__ :
            self.cruleEnd = True
            return

        elif '$err' in nr :
            self.cruleEnd = True
            return

        else :
            (res,ai) = runRule(nr)
            
            self._mtContexts[-1].setLastStepApplicationInfo(ai)

            if ai == TC.FAILED :
                pass
                #self._aswPrintReq(TC.RULE_FAILURE_MSG+" ("+self._mtContexts[-1]._lastStep['alias']+":"+self._mtContexts[-1]._lastStep['name']+")")
            elif ai == TC.EXCEPTION :
                pass
                #self._aswPrintReq(TC.RULE_EXCEPTION_MSG + res)
            else :
                return True
                #self._mtContexts[-1].setLastStepFeedbackReceived()