Skip to content
Snippets Groups Projects
Commit 59b759c5 authored by Tanner Prestegard's avatar Tanner Prestegard Committed by GraceDB
Browse files

Small update to xmpp alert code

parent ffabbdf7
No related branches found
No related tags found
No related merge requests found
...@@ -17,7 +17,7 @@ from events.permission_utils import is_external ...@@ -17,7 +17,7 @@ from events.permission_utils import is_external
from events.query import filter_for_labels from events.query import filter_for_labels
from events.shortcuts import is_event from events.shortcuts import is_event
from superevents.shortcuts import is_superevent from superevents.shortcuts import is_superevent
from .xmpp import issue_xmpp_alert from .xmpp import issue_xmpp_alerts
# Set up logger # Set up logger
log = logging.getLogger(__name__) log = logging.getLogger(__name__)
...@@ -102,7 +102,7 @@ def issue_alerts(event_or_superevent, alert_type, serialized_object, ...@@ -102,7 +102,7 @@ def issue_alerts(event_or_superevent, alert_type, serialized_object,
# Send XMPP alert # Send XMPP alert
if settings.SEND_XMPP_ALERTS: if settings.SEND_XMPP_ALERTS:
issue_xmpp_alert(event_or_superevent, alert_type, serialized_object, issue_xmpp_alerts(event_or_superevent, alert_type, serialized_object,
serialized_parent=serialized_parent) serialized_parent=serialized_parent)
# Below here, we only do processing for email and phone alerts ------------ # Below here, we only do processing for email and phone alerts ------------
......
...@@ -63,7 +63,7 @@ def get_xmpp_node_names(event_or_superevent): ...@@ -63,7 +63,7 @@ def get_xmpp_node_names(event_or_superevent):
return node_names return node_names
def issue_xmpp_alert(event_or_superevent, alert_type, serialized_object, def issue_xmpp_alerts(event_or_superevent, alert_type, serialized_object,
serialized_parent=None): serialized_parent=None):
""" """
serialized_object should be a dict serialized_object should be a dict
...@@ -98,7 +98,7 @@ def issue_xmpp_alert(event_or_superevent, alert_type, serialized_object, ...@@ -98,7 +98,7 @@ def issue_xmpp_alert(event_or_superevent, alert_type, serialized_object,
msg = simplejson.dumps(lva_data) msg = simplejson.dumps(lva_data)
# Log message for debugging # Log message for debugging
logger.info("issue_xmpp_alert: sending message {msg} for {uid}" \ logger.info("issue_xmpp_alerts: sending message {msg} for {uid}" \
.format(msg=msg, uid=uid)) .format(msg=msg, uid=uid))
# Get manager ready for LVAlert Overseer (?) # Get manager ready for LVAlert Overseer (?)
...@@ -114,7 +114,7 @@ def issue_xmpp_alert(event_or_superevent, alert_type, serialized_object, ...@@ -114,7 +114,7 @@ def issue_xmpp_alert(event_or_superevent, alert_type, serialized_object,
message_id = sha1(node_name + msg).hexdigest() message_id = sha1(node_name + msg).hexdigest()
# Log message # Log message
logger.info(("issue_xmpp_alert: sending alert type {alert_type} " logger.info(("issue_xmpp_alerts: sending alert type {alert_type} "
"with message {msg_id} for {uid} to {node}").format( "with message {msg_id} for {uid} to {node}").format(
alert_type=alert_type, msg_id=message_id, uid=uid, alert_type=alert_type, msg_id=message_id, uid=uid,
node=node_name)) node=node_name))
...@@ -129,7 +129,7 @@ def issue_xmpp_alert(event_or_superevent, alert_type, serialized_object, ...@@ -129,7 +129,7 @@ def issue_xmpp_alert(event_or_superevent, alert_type, serialized_object,
# If not success, we need to do this the old way. # If not success, we need to do this the old way.
if not success: if not success:
logger.critical(("issue_xmpp_alert: sending message with " logger.critical(("issue_xmpp_alerts: sending message with "
"LVAlert Overseer failed, trying lvalert_send")) "LVAlert Overseer failed, trying lvalert_send"))
# If not using LVAlert Overseer or if sending with overseer failed, # If not using LVAlert Overseer or if sending with overseer failed,
...@@ -138,6 +138,6 @@ def issue_xmpp_alert(event_or_superevent, alert_type, serialized_object, ...@@ -138,6 +138,6 @@ def issue_xmpp_alert(event_or_superevent, alert_type, serialized_object,
success, err = send_with_lvalert_send(node_name, msg, server) success, err = send_with_lvalert_send(node_name, msg, server)
if not success: if not success:
logger.critical(("issue_xmpp_alert: error sending message " logger.critical(("issue_xmpp_alerts: error sending "
"with lvalert_send: {e}").format(e=err)) "message with lvalert_send: {e}").format(e=err))
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment