X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fcommon.git;a=blobdiff_plain;f=osm_common%2Fdbbase.py;h=5f05e0da365f79d5d345389739a95d85506cd084;hp=7a98c7687e61ac605dc73da80162a3070c0b104c;hb=afc5cb6c6c8e3b3e1780d339ba5debb2288a22fe;hpb=2c9794c5dc468baabe99b2f934e4bdb32e98ce54 diff --git a/osm_common/dbbase.py b/osm_common/dbbase.py index 7a98c76..5f05e0d 100644 --- a/osm_common/dbbase.py +++ b/osm_common/dbbase.py @@ -279,7 +279,7 @@ class DbBase(object): http_code=HTTPStatus.INTERNAL_SERVER_ERROR) return unpadded_private_msg - def encrypt_decrypt_fields(self, item, action, fields=None, flags=re.I, schema_version=None, salt=None): + def encrypt_decrypt_fields(self, item, action, fields=None, flags=None, schema_version=None, salt=None): if not fields: return self.get_secret_key() @@ -288,18 +288,20 @@ class DbBase(object): raise DbException("Unknown action ({}): Must be one of {}".format(action, actions), http_code=HTTPStatus.INTERNAL_SERVER_ERROR) method = self.encrypt if action.lower() == 'encrypt' else self.decrypt + if flags is None: + flags = re.I - def process(item): - if isinstance(item, list): - for elem in item: + def process(_item): + if isinstance(_item, list): + for elem in _item: process(elem) - elif isinstance(item, dict): - for key, val in item.items(): - if any(re.search(f, key, flags) for f in fields) and isinstance(val, str): - item[key] = method(val, schema_version, salt) + elif isinstance(_item, dict): + for key, val in _item.items(): + if isinstance(val, str): + if any(re.search(f, key, flags) for f in fields): + _item[key] = method(val, schema_version, salt) else: process(val) - process(item)