Changeset 3746707 in osmose-backend


Ignore:
Timestamp:
Jan 6, 2013 5:49:17 PM (7 years ago)
Author:
Jocelyn Jaubert <jocelyn.jaubert@…>
Branches:
master
Children:
f46f22b
Parents:
d7a7c21
git-author:
Frédéric Rodrigo <frodrigo@…> (01/01/2013 21:42:47)
git-committer:
Jocelyn Jaubert <jocelyn.jaubert@…> (06/01/2013 17:49:17)
Message:

Clean code format into analyser_sax.py

File:
1 edited

Legend:

Unmodified
Added
Removed
  • analysers/analyser_sax.py

    rabc2a04 r3746707  
    5151        self._close_plugins() 
    5252        self._close_output() 
    53          
     53 
    5454    ################################################################################ 
    5555    #### Fonctions utiles 
    56      
     56 
    5757    def ToolsGetFilePath(self, filename): 
    5858        return os.path.join(self.config.dir_scripts, filename) 
     
    8585        f.close() 
    8686        return d 
    87      
     87 
    8888    def ToolsStripAccents(self, mot): 
    8989        mot = mot.replace(u"à", u"a").replace(u"â", u"a") 
     
    106106        mot = mot.replace(U"Æ", U"AE") 
    107107        return mot 
    108      
     108 
    109109    def ToolsStripDouble(self, mot): 
    110110        mot = mot.replace(u"cc", u"c") 
     
    120120        mot = mot.replace(u"tt", u"t") 
    121121        return mot 
    122      
     122 
    123123    ################################################################################ 
    124124    #### Reader 
    125      
     125 
    126126    def NodeGet(self, NodeId): 
    127127        return self._reader.NodeGet(NodeId) 
    128          
     128 
    129129    def WayGet(self, WayId): 
    130130        return self._reader.WayGet(WayId) 
    131          
     131 
    132132    def RelationGet(self, RelationId): 
    133133        return self._reader.RelationGet(RelationId) 
     
    158158    ################################################################################ 
    159159    #### Logs 
    160          
     160 
    161161    def _log(self, txt): 
    162162        self.logger.log(txt) 
     
    164164    def _sublog(self, txt): 
    165165        self.logger.sub().log(txt) 
    166      
     166 
    167167    def _cpt(self, txt): 
    168168        self.logger.cpt(txt) 
     
    215215 
    216216    def NodeCreate(self, data): 
    217          
     217 
    218218        # Initialisation 
    219219        err  = [] 
     
    228228            if res: 
    229229                err += res 
    230          
     230 
    231231        # Enregistrement des erreurs 
    232232        if err: 
     
    251251 
    252252    def NodeUpdate(self, data): 
    253         self.NodeDelete(data) 
    254         self.NodeCreate(data) 
     253        self.NodeDelete(data) 
     254        self.NodeCreate(data) 
    255255 
    256256    def NodeDelete(self, data): 
     
    259259    ################################################################################ 
    260260    #### Parsage d'un way 
    261      
     261 
    262262    def WayCreate(self, data): 
    263          
     263 
    264264        # Initialisation 
    265265        err  = [] 
    266266        tags = data[u"tag"] 
    267267        nds  = data[u"nd"] 
    268          
     268 
    269269        # On execute les jobs 
    270270        for meth in self.pluginsWayMethodes: 
     
    272272            if res: 
    273273                err += res 
    274          
     274 
    275275        # Enregistrement des erreurs 
    276276        if err: 
     
    298298 
    299299    def WayUpdate(self, data): 
    300         self.WayDelete(data) 
    301         self.WayCreate(data) 
     300        self.WayDelete(data) 
     301        self.WayCreate(data) 
    302302 
    303303    def WayDelete(self, data): 
    304304        self._outxml.Element("delete", {"type": "way", "id": str(data["id"])}) 
    305      
     305 
    306306    ################################################################################ 
    307307    #### Parsage d'une relation 
    308      
     308 
    309309    def RelationCreate(self, data): 
    310          
     310 
    311311        # Initialisation 
    312          
     312 
    313313        err  = [] 
    314314        tags = data[u"tag"] 
    315315        members = data[u"member"] 
    316          
     316 
    317317        # On execute les jobs 
    318318        for meth in self.pluginsRelationMethodes: 
     
    320320            if res: 
    321321                err += res 
    322                          
     322 
    323323        # Enregistrement des erreurs 
    324324        if err and data[u"member"]: 
     
    354354 
    355355    def RelationUpdate(self, data): 
    356         self.RelationDelete(data) 
    357         self.RelationCreate(data) 
    358      
     356        self.RelationDelete(data) 
     357        self.RelationCreate(data) 
     358 
    359359    def RelationDelete(self, data): 
    360360        self._outxml.Element("delete", {"type": "relation", "id": str(data["id"])}) 
     
    399399        else: 
    400400            raise Exception, "File extension '%s' is not recognized" % self.config.src 
    401          
     401 
    402402    ################################################################################ 
    403403 
    404404    def _load_plugins(self): 
    405          
     405 
    406406        self._log(u"Chargement des plugins") 
    407407        self._Err = {} 
     
    414414        _order = ["pre_pre_","pre_", "", "post_", "post_post_"] 
    415415        _types = ["way", "node", "relation"] 
    416          
     416 
    417417        for x in _order: 
    418418            for y in _types: 
     
    433433            __import__("plugins."+pluginName) 
    434434            pluginClazz = eval("plugins."+pluginName+"."+pluginName) 
    435              
     435 
    436436            if "only_for" in dir(pluginClazz): 
    437437                if conf_limit.isdisjoint(set(pluginClazz.only_for)): 
     
    450450            if "relation" in pluginAvailableMethodes: 
    451451                self.pluginsRelationMethodes.append(pluginInstance.relation) 
    452              
     452 
    453453            # Initialisation du plugin 
    454454            self._sublog(u"init "+pluginName+" ("+", ".join(self.plugins[pluginName].availableMethodes())+")") 
     
    460460                    raise Exception, "class %d already present as item %d" % (cl, self._Err[cl]['item']) 
    461461                self._Err[cl] = v 
    462                      
    463     ################################################################################ 
    464      
     462 
     463    ################################################################################ 
     464 
    465465    def _load_output(self): 
    466          
     466 
    467467        # Fichier de sortie xml 
    468468        if self.config.dst.endswith(".bz2"): 
     
    477477        else: 
    478478            self._outxml.startElement("analyser", {"timestamp":time.strftime("%Y-%m-%dT%H:%M:%SZ", time.gmtime())}) 
    479                      
     479 
    480480        # Création des classes dans le fichier xml 
    481481        for (cl, item) in self._Err.items(): 
     
    489489                self._outxml.Element("classtext", {"lang":lang, "title":title}) 
    490490            self._outxml.endElement("class") 
    491              
     491 
    492492    ################################################################################ 
    493493 
     
    496496        self.parser.CopyTo(self) 
    497497        self._log(u"Analyse terminée") 
    498          
     498 
    499499    ################################################################################ 
    500500 
     
    505505            self._sublog(u"end "+y) 
    506506            self.plugins[y].end(self.logger.sub().sub()) 
    507                      
     507 
    508508    def _close_output(self): 
    509509        # Fin du fichier xml 
     
    513513            self._outxml.endElement("analyser") 
    514514        self._output.close() 
    515          
     515 
    516516 
    517517    ################################################################################ 
     
    523523        print "Syntax: analyser_sax.py <fichier_source.osm> <fichier_dest.xml.bz2>" 
    524524        sys.exit(-1) 
    525          
     525 
    526526    # Prepare configuration 
    527527    class config: 
     
    533533                            } 
    534534    analyser_conf.src = sys.argv[1] 
    535     analyser_conf.dst = sys.argv[2]  
    536      
     535    analyser_conf.dst = sys.argv[2] 
     536 
    537537    # Start analyser 
    538538    with Analyser_Sax(analyser_conf) as analyser_obj: 
Note: See TracChangeset for help on using the changeset viewer.