Changeset 799 for vanHelsing/trunk/src/bcfg.py

Timestamp:

Oct 15, 2009, 6:37:56 PM (15 years ago)

Author:

slederer

Message:

Änderungen am Parser, so dass er funktioniert

File:

• vanHelsing/trunk/src/bcfg.py (modified) (3 diffs)

vanHelsing/trunk/src/bcfg.py

@@ -11 +11 @@
 RESOURCE_TYPES = ('dird', 'console', 'filed', 'stored')
 
-rxp_item = re.compile('\s*(?P<Name>[\S]+)\s*=\s*(?P<Value>.*)$') # xxx = xxx matchen
-rxp_openbrace = re.compile('\s*(?P<Name>[\S ]+)=?\s+{.*')    # match xxx {
-rxp_closebrace = re.compile('.*}.*')               # match }
+rxp_item = re.compile('^\\s*(\\w[\\w ]*\\w+)\\s*\\=(.*)') # xxx = xxx matchen
+rxp_item2 = re.compile('^\\s*(\\w[\\w ]*\\w+)\\s*\\=\\s*{(.*)}\\s*') # match key = { a = 1; b= 2}
+rxp_openbrace = re.compile('^\\s*(\\w[\\w ]*\\w+)\\s*\\=?\\s*\\{\\s*')    # match xxx {
+rxp_closebrace = re.compile('[^{]*}.*')               # match }
 rxp_comment = re.compile('^\s*#.*')
 
@@ -26 +27 @@
         self.filename = filename
         self.resources = resource.Resource(level=0)
+        self.resources.name="<root>"
 
     def read(self):
-        print "reading %s" % self.filename
-        self.parse()
-        print self.resources
+        self.parse(self.resources,open(self.filename,"r"),0)
+        #print self.resources
         
-    
     def write(self):
         pass
-    
-    def parse(self):
-        multiRes = set(['Run','File','Ip']) # entries, which can be multiple times in a ressource
-        f = open(self.filename)         
-        dirRes=[] # Liste der Director Ressourcen
-        curRes = self.resources
-        braceLevel = 0;
-        tmpRes = {}
-        treeindex=range(10)
-        treeindex[0]=curRes
-       
-        print resource.directives
-        
-        for line in f:
-                #print braceLevel,line
-            commentline = rxp_comment.match(line)
-            if commentline:
-                curRes.add_comment(line.strip())
+
+    def getResourceById(self,theid):
+        return self.resources.getById(theid)
+
+    def getResourceByName(self,name):
+        return self.resources.getByName(name)
+
+    def getRoot(self):
+        return self.resources
+
+    def parse(self,curRes,f,level):
+        #print "START",curRes.name
+
+        while True:
+            line=f.readline()
+            if not line:
+                break
+
+            inlinecomment=None
+         
+            commentStart=line.find("#")
+            if commentStart!=-1:
+                inlinecomment=line[commentStart:]
+                line=line[:commentStart].strip()
+                #curRes.add_comment(inlinecomment)
+
+            if rxp_closebrace.match(line):
+                #print "closebraceline"
+                break
+
+            item2 = rxp_item2.match(line)
+            if item2:
+                #print "item2"
+                name = item2.group(1)
+                value = item2.group(2)
+                #print "item:",name,value
+                newRes=resource.Resource(level+1)
+                newRes.name=name
+                newRes.value="{"+value+"}"
+                curRes.add_item(newRes)
                 continue
-            print braceLevel
+
             openbraceline = rxp_openbrace.match(line)
-            closebraceline = rxp_closebrace.match(line)
+            if openbraceline:
+                #print "openbraceline"
+                resname = openbraceline.group(1)
+                try:
+                        resClass = getattr(resource,resname);
+                except:
+                        resClass = resource.Resource
+
+                newRes=resClass(level+1)
+                newRes.name=resname
+                curRes.add_item(newRes);
+                self.parse(newRes,f,level+1);
+
+                continue
+
             item = rxp_item.match(line)
-            
-            if openbraceline:
-                braceLevel += 1
-                resname = openbraceline.group("Name")
-                
-                if not resname in resource.directives:
-                    raise "Unknown Resource: %s" % resname
+            if item:
+                name = item.group(1)
+                value = item.group(2)
+                #print "item:",name,value
+                newRes=resource.Resource(level+1)
+                newRes.name=name
+                newRes.value=value
+                curRes.add_item(newRes)
+                continue
 
-                print resname
-                newRes = eval("resource.%s(braceLevel)" % resname)
-                print newRes
-                curRes.add_item(newRes)
-                treeindex[braceLevel]=curRes;
-                curRes = newRes
-            elif closebraceline:
-                braceLevel -= 1
-                curRes = treeindex[braceLevel]           
-            elif item:
-                name = item.group("Name")
-                value = item.group("Value")
-                curRes.add_item(directive.Item(name, value))
-    
+        #print "END",curRes.name
     
 class DirdConfig(Config):
@@ -97 +122 @@
 if __name__ == "__main__":
     
-    dirdcfg = DirdConfig("../conf/bacula-dir.conf")
+    dirdcfg = DirdConfig("test.conf")
     dirdcfg.read()
-    
+    #print dirdcfg.getResourceById(174)
+    jobs=dirdcfg.getResourceByName("Job")
+    for j in jobs:
+        print j.getByName("Name")[0].value
+    d=dirdcfg.getResourceByName("ip")[1]
+    print d
+
+    job=resource.Job(1,"Job")
+    job.add("Name",'"test2"')
+    job.add("Client",'"test2"')
+    job.add("JobDefs",'"testdefs"')
+    job.add("FileSet",'"Full Set"')
+
+    root=dirdcfg.getRoot()
+    root.add_item(job)
+
+    print root
     sys.exit(0)