X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcore%2Fauth.py;h=71a817e22efc15eb2179bf52d8952b510314f82e;hb=51f4486b06781541ee15ea332261247ed3e930f6;hp=bdc049891c43d72fe56dadbfea3ba9fc84fdc6d0;hpb=6439eb0e6f03b89629bbb8bad3e092133e56a614;p=osm%2FMON.git diff --git a/osm_mon/core/auth.py b/osm_mon/core/auth.py index bdc0498..71a817e 100644 --- a/osm_mon/core/auth.py +++ b/osm_mon/core/auth.py @@ -23,32 +23,44 @@ ## import json +import logging from osm_mon.core.database import VimCredentials, DatabaseManager +log = logging.getLogger(__name__) -class AuthManager: +class AuthManager: def __init__(self): self.database_manager = DatabaseManager() - def store_auth_credentials(self, message): - values = json.loads(message.value) + def store_auth_credentials(self, creds_dict): + log.info(creds_dict) credentials = VimCredentials() - credentials.uuid = values['_id'] - credentials.name = values['name'] - credentials.type = values['vim_type'] - credentials.url = values['vim_url'] - credentials.user = values['vim_user'] - credentials.password = values['vim_password'] - credentials.tenant_name = values['vim_tenant_name'] - credentials.config = json.dumps(values['config']) + credentials.uuid = creds_dict['_id'] + credentials.name = creds_dict['name'] + credentials.type = creds_dict['vim_type'] + credentials.url = creds_dict['vim_url'] + credentials.user = creds_dict['vim_user'] + credentials.password = creds_dict['vim_password'] + credentials.tenant_name = creds_dict['vim_tenant_name'] + if 'config' not in creds_dict: + creds_dict['config'] = {} + credentials.config = json.dumps(creds_dict['config']) self.database_manager.save_credentials(credentials) def get_credentials(self, vim_uuid): - return self.database_manager.get_credentials(vim_uuid) + creds = self.database_manager.get_credentials(vim_uuid) + return creds + + def delete_auth_credentials(self, creds_dict): + credentials = self.get_credentials(creds_dict['_id']) + if credentials: + credentials.delete_instance() - def delete_auth_credentials(self, message): - # TODO - pass + def get_config(self, vim_uuid): + return json.loads(self.get_credentials(vim_uuid).config) + def is_verify_ssl(self, vim_uuid): + vim_config = self.get_config(vim_uuid) + return 'insecure' not in vim_config or vim_config['insecure'] is False