Add voice/SMS contacts with Twilio

This patch adds user-configurable SMS and text-to-speech voice alerts using Twilio, a programmable voice and SMS service. I use this service for iPTF alerts.

This is a cheaper and more powerful alternative to the Email2Phone service that is currently in use. The pricing for Twilio is $1/month, plus $0.015/minute voice and $0.0075/text message. This is about 1/20 to 10/10 the price of Email2Phone depending on volume.

Note that we do need to figure out who would pay for this service before merging it. That may depend on how much it costs, which in turn depends on how many people use it. If we have about 10 alerts a month, all going to about 20 follow-up advocates, then the service would cost $3.25 / month or $39 / year of continuous operation. If a significant fraction of the collaboration used it (about 500 people), then it would be $113.50 / month or $1362 / year. Another way to think of it is that it would cost on the order of a dollar per year per person who uses the feature.

TO DO

Note that we should probably restrict this feature to LVC users only (i.e., not EM partners). @tanner.prestegard should comment on how to test for LVC membership before issuing alerts.

How to set up phone alerts

Please do NOT overuse this test script. It WILL cost me money.

Once you are logged in to GraceDB, navigate to the OPTIONS tab:

Then click Create New Contact. In the form, enter a description and a phone number, then click Submit:

Click Create Notification. Select ADVREQ from the Labels list and your new contact from the Contacts list, then click Submit.

You have now created a voice/SMS notification that will be triggered whenever the ADVREQ label is applied to an event.

gracedb/alert.py

@@ -9,6 +9,8 @@ import json
 
 import logging
 
+from django_twilio.client import twilio_client
+
 from utils import gpsToUtc
 
 from query import filter_for_labels
@@ -24,9 +26,17 @@ if settings.USE_LVALERT_OVERSEER:
 
 log = logging.getLogger('gracedb.alert')
 
-def issueAlert(event, location, event_url, serialized_object=None):
+def get_twilio_from():
+    log.info('in get_twilio_from')
+    for from_ in twilio_client.phone_numbers.iter():
+        log.info('in get_twilio_from loop')
+        return from_.phone_number
+    log.info('in get_twilio_from, no phone number found')
+    raise RuntimeError('Could not determine "from" Twilio phone number')
+
+def issueAlert(event, location, event_url, twiml_url, serialized_object=None):
     issueXMPPAlert(event, location, serialized_object=serialized_object)
-    issueEmailAlert(event, event_url)
+    issueEmailAlert(event, event_url, twiml_url)
 
 def indent(nindent, text):
     return "\n".join([(nindent*' ')+line for line in text.split('\n')])
@@ -56,11 +66,12 @@ def issueAlertForUpdate(event, description, doxmpp, filename="", serialized_obje
     # XXX No emails for this.  Argh.
 
 # The only kind of serialized object relevant for a Label is an event.
-def issueAlertForLabel(event, label, doxmpp, serialized_event=None, event_url=None):
+def issueAlertForLabel(event, label, doxmpp, serialized_event=None, event_url=None, twiml_url=None):
     if doxmpp:
         issueXMPPAlert(event, "", "label", label, serialized_event)
     # Email
     profileRecips = []
+    phoneRecips = []
     pipeline = event.pipeline
     # Triggers on given label matching pipeline OR with no pipeline (wildcard type)
     triggers = label.trigger_set.filter(pipelines=pipeline)
@@ -76,7 +87,10 @@ def issueAlertForLabel(event, label, doxmpp, serialized_event=None, event_url=No
                 continue
 
         for recip in trigger.contacts.all():
-            profileRecips.append(recip.email)
+            if recip.email:
+                profileRecips.append(recip.email)
+            if recip.phone:
+                phoneRecips.append(recip.phone)
 
     if event.search:
         subject = "[gracedb] %s / %s / %s / %s" % (label.name, event.pipeline.name, event.search.name, event.graceid())
@@ -104,8 +118,21 @@ def issueAlertForLabel(event, label, doxmpp, serialized_event=None, event_url=No
         email = EmailMessage(subject, message, fromaddress, toaddresses, bccaddresses)
         email.send()
 
+    if twiml_url is not None:
+        log.info('in if statement')
+        log.info('phoneRecips: %s' % phoneRecips)
+        from_ = get_twilio_from()
+        log.info('from_: %s' % from_)
+        for recip in phoneRecips:
+            log.info('in for loop')
+            try:
+                log.info('issueAlertForLabel: calling %s', recip)
+                twilio_client.calls.create(recip, from_, twiml_url, method='GET')
+            except:
+                log.exception('Failed to create call')
+
 
-def issueEmailAlert(event, event_url):
+def issueEmailAlert(event, event_url, twiml_url):
 
     # The right way of doing this is to make the email alerts filter-able
     # by search. But this is a low priority dev task. For now, we simply 
@@ -118,6 +145,7 @@ def issueEmailAlert(event, event_url):
         fromaddress = settings.ALERT_TEST_EMAIL_FROM
         toaddresses = settings.ALERT_TEST_EMAIL_TO
         bccaddresses = []
+        twilio_recips = []
     else:
         fromaddress = settings.ALERT_EMAIL_FROM
         toaddresses = settings.ALERT_EMAIL_TO
@@ -127,15 +155,22 @@ def issueEmailAlert(event, event_url):
         # See: https://bugs.ligo.org/redmine/issues/2185
         #bccaddresses = settings.ALERT_EMAIL_BCC
         bccaddresses = []
+        twilio_recips = []
         pipeline = event.pipeline
         triggers = pipeline.trigger_set.filter(labels=None)
         for trigger in triggers:
             for recip in trigger.contacts.all():
                if not trigger.farThresh:
-                   bccaddresses.append(recip.email)
+                   if recip.email:
+                       bccaddresses.append(recip.email)
+                   if recip.phone:
+                       twilio_recips.append(recip.phone)
                else:
                    if event.far and event.far < trigger.farThresh:
-                       bccaddresses.append(recip.email)
+                       if recip.email:
+                           bccaddresses.append(recip.email)
+                       if recip.phone:
+                           twilio_recips.append(recip.phone)
     subject = "[gracedb] %s event. ID: %s" % (event.pipeline.name, event.graceid())
     message = """
 New Event
@@ -161,6 +196,14 @@ Event Summary:
 
     #send_mail(subject, message, fromaddress, toaddresses)
 
+    from_ = get_twilio_from()
+    for recip in twilio_recips:
+        try:
+            log.info('issueEmailAlert: calling %s', recip)
+            twilio_client.calls.create(recip, from_, twiml_url, method='GET')
+        except:
+            log.exception('Failed to create call')
+
 def issueXMPPAlert(event, location, alert_type="new", description="", serialized_object=None):
     
     nodename = "%s_%s" % (event.group.name, event.pipeline.name)