from sfa.senslab.OARrestapi import OARapi
from sfa.senslab.LDAPapi import LDAPapi
from sfa.senslab.slabdriver import SlabDriver
+from sfa.senslab.slabpostgres import SlabDB
from sfa.util.config import Config
from sfa.util.xrn import hrn_to_urn, get_authority,Xrn,get_leaf
from sfa.util.table import SfaTable
TrustedR = TrustedRoots(Config.get_trustedroots_dir(config))
AuthHierarchy = Hierarchy()
table = SfaTable()
+db = SlabDB()
if not table.exists():
table.create()
-def create_sm_client_record(self):
+def create_sm_client_record():
"""
Create a user record for the Slicemanager service.
"""
extime = datetime.datetime.utcnow()
slice_record['date_created'] = int(time.mktime(extime.timetuple()))
-
+ #special slice table for Senslab, to store nodes info (OAR)
existing_records = table.find({'hrn': slice_record['hrn'], 'type': 'slice'})
if not existing_records:
print>>sys.stderr, " \r\n \t slab-import : slice record %s inserted" %(slice_record['hrn'])
table.insert(slice_record)
+ #table.insert_slab_slice(person)
+ db.insert_slab_slice(person)
+
else:
print>>sys.stderr, " \r\n \t slab-import : slice record %s updated" %(slice_record['hrn'])
existing_record = existing_records[0]
slice_record['record_id'] = existing_record['record_id']
- table.update(slice_record)
+ table.update(slice_record)
+ db.update_senslab_slice(slice_record)
def delete_record( hrn, type):
# delete the record
def main():
-
+ if not db.exists('slice'):
+ db.createtable('slice')
+
if not config.SFA_REGISTRY_ENABLED:
sys.exit(0)
root_auth = config.SFA_REGISTRY_ROOT_AUTH
create_top_level_auth_records(interface_hrn)
# create s user record for the slice manager Do we need this?
- #create_sm_client_record()
+ create_sm_client_record()
# create interface records ADDED 18 nov 11 Do we need this?
#print "\r\n NODES8DICT ",nodes_dict
ldap_person_list = Driver.GetPersons()
-
-
# import node records
for node in nodes_dict:
hrn = hostname_to_hrn( root_auth, node['hostname'])