X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=PLC%2FKeys.py;h=ebabd190d555e7e02207700598d0e0db217ad603;hb=refs%2Fheads%2Fremove-xmlrpc;hp=b81442d54c39870ae18585a05b177e3fec4718c1;hpb=27504781de89a7c8f95b06ab3cf08b939302562e;p=plcapi.git diff --git a/PLC/Keys.py b/PLC/Keys.py index b81442d..ebabd19 100644 --- a/PLC/Keys.py +++ b/PLC/Keys.py @@ -9,8 +9,8 @@ from PLC.KeyTypes import KeyType, KeyTypes class Key(Row): """ - Representation of a row in the keys table. To use, instantiate with a - dict of values. Update as you would a dict. Commit to the database + Representation of a row in the keys table. To use, instantiate with a + dict of values. Update as you would a dict. Commit to the database with sync(). """ @@ -26,27 +26,22 @@ class Key(Row): 'peer_key_id': Parameter(int, "Foreign key identifier at peer", nullok = True), } - # for Cache - class_key= 'key' - foreign_fields = ['key_type'] - foreign_xrefs = [] - def validate_key_type(self, key_type): key_types = [row['key_type'] for row in KeyTypes(self.api)] if key_type not in key_types: raise PLCInvalidArgument, "Invalid key type" - return key_type + return key_type def validate_key(self, key): - # Key must not be blacklisted - rows = self.api.db.selectall("SELECT 1 from keys" \ - " WHERE key = %(key)s" \ + # Key must not be blacklisted + rows = self.api.db.selectall("SELECT 1 from keys" \ + " WHERE key = %(key)s" \ " AND is_blacklisted IS True", locals()) - if rows: + if rows: raise PLCInvalidArgument, "Key is blacklisted and cannot be used" - return key + return key def validate(self): # Basic validation @@ -72,13 +67,13 @@ class Key(Row): def blacklist(self, commit = True): """ - Permanently blacklist key (and all other identical keys), - preventing it from ever being added again. Because this could - affect multiple keys associated with multiple accounts, it - should be admin only. - """ + Permanently blacklist key (and all other identical keys), + preventing it from ever being added again. Because this could + affect multiple keys associated with multiple accounts, it + should be admin only. + """ - assert 'key_id' in self + assert 'key_id' in self assert 'key' in self # Get all matching keys @@ -92,7 +87,7 @@ class Key(Row): self.api.db.do("UPDATE keys SET is_blacklisted = True" \ " WHERE key_id IN (%s)" % ", ".join(map(str, key_ids))) - # But disassociate them from all join tables + # But disassociate them from all join tables for table in self.join_tables: self.api.db.do("DELETE FROM %s WHERE key_id IN (%s)" % \ (table, ", ".join(map(str, key_ids)))) @@ -108,15 +103,17 @@ class Keys(Table): def __init__(self, api, key_filter = None, columns = None): Table.__init__(self, api, Key, columns) - - sql = "SELECT %s FROM view_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: - if isinstance(key_filter, (list, tuple, set)): + if isinstance(key_filter, (list, tuple, set, int, long)): 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) + else: + raise PLCInvalidArgument, "Wrong key filter %r"%key_filter + sql += " AND (%s) %s" % key_filter.sql(api) - self.selectall(sql) + self.selectall(sql)