US560: store alarm and send notification
US561: create a dict using report values and send them all in the notification Change-Id: Ib10cd6f735f153ad62ede2ac59588ecd7f912f25
This commit is contained in:
parent
72e6edcef2
commit
32b4caee14
@ -51,9 +51,7 @@ def store_report_and_notify(title, plugin_id, report_id, component_id,
|
|||||||
component_name, component_type, project_id,
|
component_name, component_type, project_id,
|
||||||
description, security_rating, vulnerabilities,
|
description, security_rating, vulnerabilities,
|
||||||
vulnerabilities_number, last_report_date):
|
vulnerabilities_number, last_report_date):
|
||||||
try:
|
report = {'title': title,
|
||||||
db_api.security_report_create(
|
|
||||||
{'title': title,
|
|
||||||
'plugin_id': plugin_id,
|
'plugin_id': plugin_id,
|
||||||
'report_id': report_id,
|
'report_id': report_id,
|
||||||
'component_id': component_id,
|
'component_id': component_id,
|
||||||
@ -63,19 +61,33 @@ def store_report_and_notify(title, plugin_id, report_id, component_id,
|
|||||||
'description': description,
|
'description': description,
|
||||||
'security_rating': security_rating,
|
'security_rating': security_rating,
|
||||||
'vulnerabilities': vulnerabilities,
|
'vulnerabilities': vulnerabilities,
|
||||||
'vulnerabilities_number': vulnerabilities_number})
|
'vulnerabilities_number': vulnerabilities_number}
|
||||||
|
try:
|
||||||
|
db_api.security_report_create(report)
|
||||||
db_report_id = db_api.security_report_get_from_report_id(
|
db_report_id = db_api.security_report_get_from_report_id(
|
||||||
report_id).id
|
report_id).id
|
||||||
db_api.security_report_update_last_report_date(
|
db_api.security_report_update_last_report_date(
|
||||||
db_report_id, last_report_date)
|
db_report_id, last_report_date)
|
||||||
payload = {'security_rating': security_rating}
|
notifications.send_notification('store', 'security_report', report)
|
||||||
notifications.send_notification('store', 'security_report', payload)
|
except cerberus_exception.DBException:
|
||||||
except cerberus_exception.DBException as e:
|
raise
|
||||||
LOG.exception(e)
|
|
||||||
pass
|
|
||||||
except Exception as e:
|
def store_alarm_and_notify(plugin_id, alarm_id, timestamp, status, severity,
|
||||||
LOG.exception(e)
|
component_id, description, summary):
|
||||||
pass
|
alarm = {'plugin_id': plugin_id,
|
||||||
|
'alarm_id': alarm_id,
|
||||||
|
'timestamp': timestamp,
|
||||||
|
'status': status,
|
||||||
|
'severity': severity,
|
||||||
|
'component_id': component_id,
|
||||||
|
'description': description,
|
||||||
|
'summary': summary}
|
||||||
|
try:
|
||||||
|
db_api.security_alarm_create(alarm)
|
||||||
|
notifications.send_notification('store', 'security_alarm', alarm)
|
||||||
|
except cerberus_exception.DBException:
|
||||||
|
raise
|
||||||
|
|
||||||
|
|
||||||
class CerberusManager(service.CerberusService):
|
class CerberusManager(service.CerberusService):
|
||||||
|
Loading…
Reference in New Issue
Block a user