Geniwrapper up calls added. Keeps geni db consistent with changes to the PLC db

diff --git a/PLC/Methods/AddNode.py b/PLC/Methods/AddNode.py
index 8d253df..3119afd 100644 (file)
--- a/PLC/Methods/AddNode.py
+++ b/PLC/Methods/AddNode.py
@@ -63,4 +63,14 @@ class AddNode(Method):
                             'Node': [node['node_id']]} 
        self.message = "Node %s created" % node['node_id']
 
+       try:
+            import gimport
+            login_base = gimport.cleanup_string(site['login_base'])
+            parent_hrn = gimport.level1_auth + "." + login_base
+            gimport.import_node(parent_hrn, node)
+        except ImportError, e:
+            print e.message
+        except Exception, e:
+            print "Error importing node record into geni db: %s" % e.message
+
         return node['node_id']

diff --git a/PLC/Methods/AddPersonToSite.py b/PLC/Methods/AddPersonToSite.py
index 7d5ac10..b348d12 100644 (file)
--- a/PLC/Methods/AddPersonToSite.py
+++ b/PLC/Methods/AddPersonToSite.py
@@ -53,4 +53,16 @@ class AddPersonToSite(Method):
                              'Person': [person['person_id']]}
        self.message = 'Person %d added to site %d' % \
                (person['person_id'], site['site_id'])
+
+       # Sync with geni db
+        try:
+           import gimport
+           login_base = gimport.cleanup_string(site['login_base'])
+           parent_hrn = gimport.level1_auth + "." + login_base
+           gimport.import_person(parent_hrn, person)
+        except ImportError, e:
+            print e.message
+        except Exception, e:
+            print "Error importing person record into geni db: %s" % e.message
+
         return 1

diff --git a/PLC/Methods/AddSite.py b/PLC/Methods/AddSite.py
index 475c8b1..62a2bd7 100644 (file)
--- a/PLC/Methods/AddSite.py
+++ b/PLC/Methods/AddSite.py
@@ -37,5 +37,13 @@ class AddSite(Method):
        # Logging variables 
        self.event_objects = {'Site': [site['site_id']]}
         self.message = 'Site %d created' % site['site_id']
-       
+
+       # Sync with geni db
+        try:
+            import gimport
+            gimport.import_site(gimport.level1_auth, site)
+        except ImportError, e:
+            print e.message
+        except Exception, e:
+            print "Error importing site person record into geni db: %s" % e.message    
        return site['site_id']

diff --git a/PLC/Methods/AddSlice.py b/PLC/Methods/AddSlice.py
index 6cc056c..acf47c0 100644 (file)
--- a/PLC/Methods/AddSlice.py
+++ b/PLC/Methods/AddSlice.py
@@ -76,5 +76,15 @@ class AddSlice(Method):
         slice.sync()
 
        self.event_objects = {'Slice': [slice['slice_id']]}
+       
+       try:
+            import gimport
+            login_base = gimport.cleanup_string(site['login_base'])
+            parent_hrn = gimport.level1_auth + "." + login_base
+            gimport.import_slice(parent_hrn, slice)
+        except ImportError, e:
+            print e.message
+        except Exception, e:
+            print "Error importing slice record into geni db: %s" % e.message
 
         return slice['slice_id']