From 3347ed4d026137c619a0f2f02845044d1611a939 Mon Sep 17 00:00:00 2001 From: Tony Mack Date: Tue, 16 Dec 2008 21:18:39 +0000 Subject: [PATCH] Geniwrapper up calls added. Keeps geni db consistent with changes to the PLC db --- PLC/Methods/AddNode.py | 10 ++++++++++ PLC/Methods/AddPersonToSite.py | 12 ++++++++++++ PLC/Methods/AddSite.py | 10 +++++++++- PLC/Methods/AddSlice.py | 10 ++++++++++ 4 files changed, 41 insertions(+), 1 deletion(-) diff --git a/PLC/Methods/AddNode.py b/PLC/Methods/AddNode.py index 8d253df..3119afd 100644 --- 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 --- 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 --- 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 --- 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'] -- 2.43.0