Created special slab_get_authority to import slab nodes in sfa db.
[sfa.git] / sfa / importer / slabimporter.py
index 2f6e863..d38f454 100644 (file)
@@ -1,8 +1,7 @@
 import sys
 
 from sfa.util.config import Config
-from sfa.util.xrn import get_authority, hrn_to_urn
-from sfa.planetlab.plxrn import PlXrn
+from sfa.util.xrn import Xrn, get_authority, hrn_to_urn
 
 from sfa.senslab.slabdriver import SlabDriver
 from sfa.senslab.slabpostgres import SliceSenslab, slab_dbsession
@@ -13,8 +12,9 @@ from sfa.trust.gid import create_uuid
 from sfa.storage.alchemy import dbsession
 from sfa.storage.model import RegRecord, RegAuthority, RegSlice, RegNode, \
                                                     RegUser, RegKey
+from sfa.util.sfalogging import logger
 
-
+from sqlalchemy.exc import SQLAlchemyError
 
 
 def _get_site_hrn(site):
@@ -23,13 +23,15 @@ def _get_site_hrn(site):
 
 class SlabImporter:
     
-    def __init__ (self, auth_hierarchy, logger):
+    def __init__ (self, auth_hierarchy, loc_logger):
         self.auth_hierarchy = auth_hierarchy
-        self.logger=logger
+        self.logger = loc_logger
+        self.logger.setLevelDebug()
+
+    def hostname_to_hrn_escaped(self, root_auth, hostname):
+        return '.'.join( [root_auth,Xrn.escape(hostname)] )
+
 
-       
-    def hostname_to_hrn(self,root_auth,login_base,hostname):
-        return PlXrn(auth=root_auth,hostname = hostname).get_hrn()   
     
     def slicename_to_hrn(self, person_hrn):
         return  (person_hrn +'_slice')
@@ -42,14 +44,15 @@ class SlabImporter:
         return self.records_by_type_hrn.get ( (type, hrn), None)
     
     def locate_by_type_pointer (self, type, pointer):
+        print>>sys.stderr, " \r\n \r\n \t SLABPOSTGRES locate_by_type_pointer  .........................." 
         ret = self.records_by_type_pointer.get ( (type, pointer), None)
+        print>>sys.stderr, " \r\n \r\n \t SLABPOSTGRES locate_by_type_pointer  " 
         return ret
     
     def update_just_added_records_dict (self, record):
-        record_tuple = (record.type, record.hrn)
-        if record_tuple in self.records_by_type_hrn:
-            self.logger.warning ("SlabImporter.update_just_added_records_dict: \
-                                            duplicate (%s,%s)" %(record_tuple))
+        tuple = (record.type, record.hrn)
+        if tuple in self.records_by_type_hrn:
+            self.logger.warning ("SlabImporter.update_just_added_records_dict: duplicate (%s,%s)"%tuple)
             return
         self.records_by_type_hrn [ tuple ] = record
         
@@ -71,16 +74,13 @@ class SlabImporter:
         #used  to know if a given record is already known to SFA 
        
         self.records_by_type_hrn = \
-            dict ( [ ( (record.type,record.hrn), record ) \
-                                                for record in all_records ] )
+            dict ( [ ( (record.type,record.hrn) , record ) for record in all_records ] )
             
         # create hash by (type,pointer) 
         self.records_by_type_pointer = \
-            dict ( [ ( (str(record.type),record.pointer), record ) \
-                            for record in all_records  if record.pointer != -1])
+            dict ( [ ( (str(record.type),record.pointer) , record ) for record in all_records  if record.pointer != -1] )
 
-        # initialize record.stale to True by default, 
-        #then mark stale=False on the ones that are in use
+        # initialize record.stale to True by default, then mark stale=False on the ones that are in use
         for record in all_records: 
             record.stale=True
         
@@ -91,11 +91,9 @@ class SlabImporter:
         ldap_person_listdict = slabdriver.GetPersons()
         slices_listdict = slabdriver.GetSlices()
         try:
-            slices_by_userid = dict ([(slice.record_id_user, slice ) \
-                                                for slice in slices_listdict])
+            slices_by_userid = dict ( [ (one_slice['record_id_user'], one_slice ) for one_slice in slices_listdict ] )
         except TypeError:
-             self.logger.log_exc("SlabImporter: failed to create list \
-                                                        of slices by user id.") 
+             self.logger.log_exc("SlabImporter: failed to create list of slices by user id.") 
              pass
  
         for site in sites_listdict:
@@ -103,7 +101,7 @@ class SlabImporter:
             site_record = self.find_record_by_type_hrn ('authority', site_hrn)
             if not site_record:
                 try:
-                    urn = hrn_to_urn(site_hrn, 'authority')
+                    urn = hrn_to_urn(site_hrn, 'authority') 
                     if not self.auth_hierarchy.auth_exists(urn):
                         self.auth_hierarchy.create_auth(urn)
                     auth_info = self.auth_hierarchy.get_auth_info(urn)
@@ -113,15 +111,12 @@ class SlabImporter:
                     site_record.just_created()
                     dbsession.add(site_record)
                     dbsession.commit()
-                    self.logger.info("SlabImporter: imported authority (site) \
-                                                    : %s" % (site_record)) 
+                    self.logger.info("SlabImporter: imported authority (site) : %s" % site_record) 
                     self.update_just_added_records_dict(site_record)
-                except:
-                    # if the site import fails then there is no point in 
-                    # trying to import the
+                except SQLAlchemyError:
+                    # if the site import fails then there is no point in trying to import the
                     # site's child records (node, slices, persons), so skip them.
-                    self.logger.log_exc("SlabImporter: failed to import site. \
-                                                        Skipping child records") 
+                    self.logger.log_exc("SlabImporter: failed to import site. Skipping child records") 
                     continue
             else:
                 # xxx update the record ...
@@ -133,31 +128,33 @@ class SlabImporter:
                 try:
                     node = nodes_by_id[node_id]
                 except:
-                    self.logger.warning ("SlabImporter: cannot find node_id \
-                                            %s - ignored" %(node_id))
+                    self.logger.warning ("SlabImporter: cannot find node_id %s - ignored"%node_id)
                     continue 
                 site_auth = get_authority(site_hrn)
-                site_name = site['name']
-                hrn =  self.hostname_to_hrn(slabdriver.root_auth, site_name, \
-                                                            node['hostname'])
+                site_name = site['name']                
+                escaped_hrn =  self.hostname_to_hrn_escaped(slabdriver.root_auth, node['hostname'])
+                print>>sys.stderr, "\r\n \r\n SLABIMPORTER node %s " %(node)               
+                hrn =  node['hrn']
+
+
                 # xxx this sounds suspicious
                 if len(hrn) > 64: hrn = hrn[:64]
                 node_record = self.find_record_by_type_hrn( 'node', hrn )
                 if not node_record:
                     try:
                         pkey = Keypair(create=True)
-                        urn = hrn_to_urn(hrn, 'node') 
-                        node_gid = self.auth_hierarchy.create_gid(urn, \
-                                                        create_uuid(), pkey)
+                        urn = hrn_to_urn(escaped_hrn, 'node') 
+                        node_gid = self.auth_hierarchy.create_gid(urn, create_uuid(), pkey)
+                        def slab_get_authority(hrn):
+                            return hrn.split(".")[0]
+                            
                         node_record = RegNode (hrn=hrn, gid=node_gid, 
                                                 pointer = '-1',
-                                                authority=get_authority(hrn))
+                                                authority=slab_get_authority(hrn)) 
                         node_record.just_created()
                         dbsession.add(node_record)
                         dbsession.commit()
-                        self.logger.info("SlabImporter: imported node: %s" \
-                                                            %(node_record))
-                        print>>sys.stderr, "\r\n \t\t\t SLAB IMPORTER NODE IMPORT NOTnode_record %s " %(node_record)  
+                        self.logger.info("SlabImporter: imported node: %s" % node_record)  
                         self.update_just_added_records_dict(node_record)
                     except:
                         self.logger.log_exc("SlabImporter: failed to import node") 
@@ -169,7 +166,8 @@ class SlabImporter:
                     
             # import persons
             for person in ldap_person_listdict : 
-            
+                if 'ssh-rsa' not in person['pkey']:
+                    continue
                 person_hrn = person['hrn']
                 slice_hrn = self.slicename_to_hrn(person['hrn'])
                
@@ -177,28 +175,29 @@ class SlabImporter:
                 if len(person_hrn) > 64: person_hrn = person_hrn[:64]
                 person_urn = hrn_to_urn(person_hrn, 'user')
     
-                user_record = self.find_record_by_type_hrn( 'user', person_hrn)
+                user_record = self.find_record_by_type_hrn('user', person_hrn)
                 slice_record = self.find_record_by_type_hrn ('slice', slice_hrn)
                 
-                # return a tuple pubkey (a plc key object) and pkey 
-                # (a Keypair object)
+                # return a tuple pubkey (a plc key object) and pkey (a Keypair object)
                 def init_person_key (person, slab_key):
-                    pubkey=None
+                    pubkey = None
                     if  person['pkey']:
                         # randomly pick first key in set
                         pubkey = slab_key
+                        
                         try:
                             pkey = convert_public_key(pubkey)
-                        except:
-                            self.logger.warning('SlabImporter: unable to convert \
-                                            public key for %s' %(person_hrn))
+                        except TypeError:
+                            #key not good. create another pkey
+                            self.logger.warn('SlabImporter: \
+                                                unable to convert public \
+                                                key for %s' % person_hrn)
                             pkey = Keypair(create=True)
+                       
                     else:
-                        # the user has no keys. Creating a random keypair 
-                        # for the user's gid
-                        self.logger.warn("SlabImporter: person %s does not \
-                                            have a  public key" %(person_hrn))
-                        pkey = Keypair(create=True)
+                        # the user has no keys. Creating a random keypair for the user's gid
+                        self.logger.warn("SlabImporter: person %s does not have a PL public key"%person_hrn)
+                        pkey = Keypair(create=True) 
                     return (pubkey, pkey)
                                 
                  
@@ -206,33 +205,31 @@ class SlabImporter:
                     slab_key = person['pkey']
                     # new person
                     if not user_record:
-                        (pubkey,pkey) = init_person_key(person, slab_key )
-                        person_gid = self.auth_hierarchy.create_gid(\
-                                                person_urn, create_uuid(), pkey)
-                        if person['email']:
-                            print>>sys.stderr, "\r\n \r\n SLAB IMPORTER PERSON EMAIL OK email %s " %(person['email'])
-                            person_gid.set_email(person['email'])
-                            user_record = RegUser (hrn=person_hrn, gid=person_gid, 
-                                                    pointer='-1', 
-                                                    authority=get_authority(person_hrn),
-                                                    email=person['email'])
-                        else:
-                            user_record = RegUser (hrn=person_hrn, gid=person_gid, 
-                                                    pointer='-1', 
-                                                    authority=get_authority(person_hrn))
-                            
-                        if pubkey: 
-                            user_record.reg_keys = [RegKey (pubkey)]
-                        else:
-                            self.logger.warning("No key found for user %s" \
-                                                        %(user_record))
-                        user_record.just_created()
-                        dbsession.add (user_record)
-                        dbsession.commit()
-                        self.logger.info("SlabImporter: imported person: %s" \
-                                                         %(user_record))
-                        print>>sys.stderr, "\r\n \r\n SLAB IMPORTER PERSON IMPORT NOTuser_record %s " %(user_record)
-                        self.update_just_added_records_dict(user_record)
+                        (pubkey,pkey) = init_person_key (person, slab_key )
+                        if pubkey is not None and pkey is not None :
+                            person_gid = self.auth_hierarchy.create_gid(person_urn, create_uuid(), pkey)
+                            if person['email']:
+                                print>>sys.stderr, "\r\n \r\n SLAB IMPORTER PERSON EMAIL OK email %s " %(person['email'])
+                                person_gid.set_email(person['email'])
+                                user_record = RegUser (hrn=person_hrn, gid=person_gid, 
+                                                        pointer='-1', 
+                                                        authority=get_authority(person_hrn),
+                                                        email=person['email'])
+                            else:
+                                user_record = RegUser (hrn=person_hrn, gid=person_gid, 
+                                                        pointer='-1', 
+                                                        authority=get_authority(person_hrn))
+                                
+                            if pubkey: 
+                                user_record.reg_keys = [RegKey (pubkey)]
+                            else:
+                                self.logger.warning("No key found for user %s"%user_record)
+                            user_record.just_created()
+                            dbsession.add (user_record)
+                            dbsession.commit()
+                            self.logger.info("SlabImporter: imported person: %s" % user_record)
+                            print>>sys.stderr, "\r\n \r\n SLAB IMPORTER PERSON IMPORT NOTuser_record %s " %(user_record)
+                            self.update_just_added_records_dict( user_record )
                     else:
                         # update the record ?
                         # if user's primary key has changed then we need to update the 
@@ -244,35 +241,29 @@ class SlabImporter:
                             new_key = True
                         if new_key:
                             (pubkey,pkey) = init_person_key (person, slab_key)
-                            person_gid = self.auth_hierarchy.create_gid(\
-                                                person_urn, create_uuid(), pkey)
+                            person_gid = self.auth_hierarchy.create_gid(person_urn, create_uuid(), pkey)
                             if not pubkey:
-                                user_record.reg_keys = []
+                                user_record.reg_keys=[]
                             else:
-                                user_record.reg_keys = [RegKey(pubkey)]
-                            self.logger.info("SlabImporter: updated person: \
-                                                    %s" %(user_record))
+                                user_record.reg_keys=[ RegKey (pubkey)]
+                            self.logger.info("SlabImporter: updated person: %s" % user_record)
                     if person['email']:
                         user_record.email = person['email']
                     dbsession.commit()
                     user_record.stale=False
                 except:
-                    self.logger.log_exc("SlabImporter: \
-                                    failed to import person  %s"%(person) ) 
+                    self.logger.log_exc("SlabImporter: failed to import person  %s"%(person) )       
                 
                 try:
                     slice = slices_by_userid[user_record.record_id]
                 except:
-                    self.logger.warning ("SlabImporter: \
-                    cannot locate slices_by_userid[user_record.record_id] %s\
-                                     - ignored" %(user_record.record_id ))
-                if not slice_record:
-                   
+                    self.logger.warning ("SlabImporter: cannot locate slices_by_userid[user_record.record_id] %s - ignored"%user_record)  
+                      
+                if not slice_record :
                     try:
                         pkey = Keypair(create=True)
                         urn = hrn_to_urn(slice_hrn, 'slice')
-                        slice_gid = self.auth_hierarchy.create_gid(urn, \
-                                                        create_uuid(), pkey)
+                        slice_gid = self.auth_hierarchy.create_gid(urn, create_uuid(), pkey)
                         slice_record = RegSlice (hrn=slice_hrn, gid=slice_gid, 
                                                     pointer='-1',
                                                     authority=get_authority(slice_hrn))
@@ -285,15 +276,13 @@ class SlabImporter:
                         #Get it
                         sl_rec = dbsession.query(RegSlice).filter(RegSlice.hrn.match(slice_hrn)).all()
                         
-                        slab_slice = SliceSenslab(slice_hrn=slice_hrn, \
-                                        record_id_slice=sl_rec[0].record_id, \
-                                        record_id_user= user_record.record_id)
+                        slab_slice = SliceSenslab( slice_hrn = slice_hrn, record_id_slice=sl_rec[0].record_id, record_id_user= user_record.record_id)
                         print>>sys.stderr, "\r\n \r\n SLAB IMPORTER SLICE IMPORT NOTslice_record %s \r\n slab_slice %s" %(sl_rec,slab_slice)
                         slab_dbsession.add(slab_slice)
                         slab_dbsession.commit()
-                        self.logger.info("SlabImporter: imported slice: %s" \
-                                                    %(slice_record) )
+                        self.logger.info("SlabImporter: imported slice: %s" % slice_record)  
                         self.update_just_added_records_dict ( slice_record )
+
                     except:
                         self.logger.log_exc("SlabImporter: failed to import slice")
                         
@@ -304,6 +293,7 @@ class SlabImporter:
                     pass
                 # record current users affiliated with the slice
 
+
                 slice_record.reg_researchers =  [user_record]
                 dbsession.commit()
                 slice_record.stale=False