Noyau/ascheckers.py

   1 #@ MODIF ascheckers Noyau  DATE 07/10/2008   AUTEUR PELLET J.PELLET
   2 # -*- coding: iso-8859-1 -*-
   3 #            CONFIGURATION MANAGEMENT OF EDF VERSION
   4 # ======================================================================
   5 # COPYRIGHT (C) 1991 - 2007  EDF R&D                  WWW.CODE-ASTER.ORG
   6 # THIS PROGRAM IS FREE SOFTWARE; YOU CAN REDISTRIBUTE IT AND/OR MODIFY
   7 # IT UNDER THE TERMS OF THE GNU GENERAL PUBLIC LICENSE AS PUBLISHED BY
   8 # THE FREE SOFTWARE FOUNDATION; EITHER VERSION 2 OF THE LICENSE, OR
   9 # (AT YOUR OPTION) ANY LATER VERSION.
  10 #
  11 # THIS PROGRAM IS DISTRIBUTED IN THE HOPE THAT IT WILL BE USEFUL, BUT
  12 # WITHOUT ANY WARRANTY; WITHOUT EVEN THE IMPLIED WARRANTY OF
  13 # MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE. SEE THE GNU
  14 # GENERAL PUBLIC LICENSE FOR MORE DETAILS.
  15 #
  16 # YOU SHOULD HAVE RECEIVED A COPY OF THE GNU GENERAL PUBLIC LICENSE
  17 # ALONG WITH THIS PROGRAM; IF NOT, WRITE TO EDF R&D CODE_ASTER,
  18 #    1 AVENUE DU GENERAL DE GAULLE, 92141 CLAMART CEDEX, FRANCE.
  19 # ======================================================================
  20
  21 class Parmi(object):
  22     """Classe qui exprime une contrainte multiple pour un attribut"""
  23     def __init__(self, *args):
  24         self.values = list(args)
  25
  26     def add_value(self, value ):
  27         if value not in self.values:
  28             self.values.append( value )
  29
  30     def __call__(self, obj, name, value, log ):
  31         if value not in self.values:
  32             log.err( obj, "l'attribut %s=%r n'est pas dans %r" % (name, value, self.values) )
  33
  34     def __repr__(self):
  35         l = [ "Parmi(", ]
  36         g = [ repr(v) for v in self.values ]
  37         l.append( ", ".join(g) )
  38         l.append( ")" )
  39         return "".join( l )
  40
  41 class CheckLog(object):
  42     """Un validateur qui enregistre toutes les erreurs trouvées.
  43     checkedXXX répond True si la "marq" courante est inférieure ou égale
  44     à la celle de la dernière vérification.
  45     Si on incrémentait "marq" à chaque étape, on revérifie à chaque fois.
  46     """
  47
  48     def __init__(self):
  49         self.msg       = []
  50         self.names     = {}
  51         self.cksums    = {}
  52         self.optional  = False
  53         self._marq     = 1
  54         self._lastmarq = self._marq
  55         self._debug    = False
  56         self._profond  = False # True pour forcer des vérifications plus profondes
  57
  58     def log(self, level, obj, msg ):
  59         if obj :
  60             self.msg.append( (level, obj.nomj(), msg) )
  61         else :
  62             self.msg.append( (level, 'None', msg) )
  63
  64     def err(self, obj, msg ):
  65         self.log( 0, obj, msg )
  66
  67     def warn(self, obj, msg ):
  68         self.log( 1, obj, msg )
  69
  70     def visitOJB(self, obj):
  71         key = obj.nomj()
  72         self.names[key] = self._marq
  73
  74     def checkSumOJB(self, obj, sd, maj='non'):
  75         # vérifie que le checksum de obj n'a pas changé
  76         # sd : concept qui contient obj
  77         # maj='maj', l'opérateur a le droit de modifier ojb
  78         if obj.exists :
  79             import md5
  80             m=md5.new()
  81             m.update(str(obj.get()))
  82             cksum=m.digest()
  83             nom=obj.nomj()
  84             if not self.cksums.has_key(nom) :
  85                 self.cksums[nom]=cksum
  86             else :
  87                 if self.cksums[nom] != cksum :
  88                     self.cksums[nom] = cksum
  89                     #if maj.strip()=='maj' and nom[0:8].strip()==sd.nomj.nomj[0:8].strip() :
  90                     # Remarque : ne pas tester 'maj' premet de résoudre (un peu) le problème
  91                     #            posé par la commande DETRUIRE
  92                     if nom[0:8].strip()==sd.nomj.nomj[0:8].strip() :
  93                         pass
  94                     else :
  95                         self.err(obj,'Le checksum a changé')
  96
  97     def visitAsBase(self, obj):
  98         key = (obj.nomj(), obj.__class__.__name__)
  99         self.names[key] = self._marq
 100
 101     def force(self, force=False):
 102         if not force:
 103            self._marq = 1
 104         else:
 105            self._lastmarq += 1
 106            self._marq = self._lastmarq
 107
 108     def checkedOJB(self, obj):
 109         key = obj.nomj()
 110         res = self.names.get(key, 0) >= self._marq
 111         self.help_dbg([key,], res)
 112         return res
 113
 114     def checkedAsBase(self, obj):
 115         key = (obj.nomj(), obj.__class__.__name__)
 116         res = self.names.get(key, 0) >= self._marq
 117         self.help_dbg(key, res)
 118         return res
 119
 120     def help_dbg(self, key, res):
 121         if self._debug:
 122             if res:
 123                s = 'ignore'
 124             else:
 125                s = 'check '
 126             print '#DBG %6d %s : %s' % (self._marq, s, ', '.join(key))
 127
 128     def __str__(self):
 129         d = { 0: "E", 1:"W" }
 130         return "\n".join( [ "%s:%s: %s" % (d[l],n,m)
 131                             for l,n,m in self.msg ])
 132
 133 class CheckFail(CheckLog):
 134     """Un validateur qui lève une exception
 135     dès la première erreur"""
 136     def err(self, obj, msg ):
 137         raise AssertionError("%s: %s" % (obj.nomj(), msg) )