sfa/methods/remove.py

   1 ### $Id$
   2 ### $URL$
   3
   4 from sfa.util.faults import *
   5 from sfa.util.method import Method
   6 from sfa.util.parameter import Parameter, Mixed
   7 from sfa.util.auth import Auth
   8 from sfa.util.record import GeniRecord
   9 from sfa.util.debug import log
  10
  11 class remove(Method):
  12     """
  13     Remove an object from the registry. If the object represents a PLC object,
  14     then the PLC records will also be removed.
  15
  16     @param cred credential string
  17     @param type record type
  18     @param hrn human readable name of record to remove
  19
  20     @return 1 if successful, faults otherwise
  21     """
  22
  23     interfaces = ['registry']
  24
  25     accepts = [
  26         Parameter(str, "Credential string"),
  27         Parameter(str, "Record type"),
  28         Parameter(str, "Human readable name (hrn) of record to be removed")
  29         ]
  30
  31     returns = Parameter(int, "1 if successful")
  32
  33     def call(self, cred, type, hrn):
  34         self.api.auth.check(cred, "remove")
  35         self.api.auth.verify_object_permission(hrn)
  36         auth_name = self.api.auth.get_authority(hrn)
  37         table = self.api.auth.get_auth_table(auth_name)
  38         record_list = table.resolve(type, hrn)
  39         if not record_list:
  40             raise RecordNotFound(hrn)
  41         record = record_list[0]
  42
  43         type = record['type']
  44         # TODO: sa, ma
  45         if type == "user":
  46             self.api.plshell.DeletePerson(self.api.plauth, record.get_pointer())
  47         elif type == "slice":
  48             self.api.plshell.DeleteSlice(self.api.plauth, record.get_pointer())
  49         elif type == "node":
  50             self.api.plshell.DeleteNode(self.api.plauth, record.get_pointer())
  51         elif (type in ['authority', 'sa', 'ma']):
  52             other_rec = table.resolve(type, record.get_name())
  53
  54             if other_rec:
  55                 # sa and ma both map to a site, so if we are deleting one
  56                 # but the other still exists, then do not delete the site
  57                 print >> log, "not removing site", record.get_name(), "because either sa or ma still exists"
  58                 pass
  59             else:
  60                 print >> log, "removing site", record.get_name()
  61                 self.api.plshell.DeleteSite(self.api.plauth, record.get_pointer())
  62         else:
  63             raise UnknownGeniType(type)
  64
  65         table.remove(record)
  66
  67         return 1