- try:
- values = json.loads(message.value)
- except JSONDecodeError:
- values = yaml.safe_load(message.value)
-
- response = None
-
- if message.topic == "vim_account":
- if message.key == "create" or message.key == "edit":
- values['vim_password'] = self.common_db.decrypt_vim_password(values['vim_password'],
- values['schema_version'],
- values['_id'])
- self.auth_manager.store_auth_credentials(values)
- if message.key == "delete":
- self.auth_manager.delete_auth_credentials(values)
-
- elif message.topic == "alarm_request":
- if message.key == "create_alarm_request":
+ if topic == "vim_account":
+ if key == "create" or key == "edit":
+ if 'config' not in values:
+ values['config'] = {}
+ self.service.upsert_vim_account(values['_id'],
+ values['name'],
+ values['vim_type'],
+ values['vim_url'],
+ values['vim_user'],
+ values['vim_password'],
+ values['vim_tenant_name'],
+ values['schema_version'],
+ values['config'])
+
+ if key == "delete":
+ self.service.delete_vim_account(values['_id'])
+
+ elif topic == "alarm_request":
+ if key == "create_alarm_request":