X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=PLC%2FKeys.py;h=8d22dc2e93fd13cb55b04fd3b74422bfcd329094;hb=refs%2Fheads%2Fplanetlab-4_0-branch;hp=9af1e6ccc8321e6e48e8cf7a16f1e781e08695c0;hpb=13ad57cef92a336e57bf065b421a77cf7e977e6c;p=plcapi.git diff --git a/PLC/Keys.py b/PLC/Keys.py index 9af1e6c..8d22dc2 100644 --- a/PLC/Keys.py +++ b/PLC/Keys.py @@ -16,18 +16,20 @@ class Key(Row): table_name = 'keys' primary_key = 'key_id' - join_tables = ['person_key'] + join_tables = ['person_key', 'peer_key'] fields = { 'key_id': Parameter(int, "Key identifier"), 'key_type': Parameter(str, "Key type"), 'key': Parameter(str, "Key value", max = 4096), - 'peer_id': Parameter(int, "Peer at which this node is managed", nullok = True), + 'person_id': Parameter(int, "User to which this key belongs", nullok = True), + 'peer_id': Parameter(int, "Peer to which this key belongs", nullok = True), + 'peer_key_id': Parameter(int, "Foreign key identifier at peer", nullok = True), } # for Cache class_key= 'key' foreign_fields = ['key_type'] - foreign_xrefs = {} + foreign_xrefs = [] def validate_key_type(self, key_type): key_types = [row['key_type'] for row in KeyTypes(self.api)] @@ -91,7 +93,7 @@ class Key(Row): " WHERE key_id IN (%s)" % ", ".join(map(str, key_ids))) # But disassociate them from all join tables - for table in ['person_key']: + for table in self.join_tables: self.api.db.do("DELETE FROM %s WHERE key_id IN (%s)" % \ (table, ", ".join(map(str, key_ids)))) @@ -107,7 +109,7 @@ class Keys(Table): def __init__(self, api, key_filter = None, columns = None): Table.__init__(self, api, Key, columns) - sql = "SELECT %s FROM keys WHERE is_blacklisted IS False" % \ + sql = "SELECT %s FROM view_keys WHERE is_blacklisted IS False" % \ ", ".join(self.columns) if key_filter is not None: @@ -115,6 +117,6 @@ class Keys(Table): key_filter = Filter(Key.fields, {'key_id': key_filter}) elif isinstance(key_filter, dict): key_filter = Filter(Key.fields, key_filter) - sql += " AND (%s)" % key_filter.sql(api) + sql += " AND (%s) %s" % key_filter.sql(api) self.selectall(sql)