Send a a warning email to the ISP when there is a problem in the cron task

config.py

@@ -4,8 +4,3 @@ SQLALCHEMY_DATABASE_URI = 'sqlite:///../ffdn-db.sqlite'
 #PASSWD_SALT = 'change this value to some random chars!'
 SECRET_KEY = '{J@uRKO,xO-PK7B,jF?>iHbxLasF9s#zjOoy=+:'
 DEBUG = True
-TITLE = u"Fédéral Database"
-#EMAIL = '"' + TITLE + '"' + ' <' + u"cavote@ffdn.org" + '>'
-#VERSION = "cavote 0.3.0"
-#SMTP_SERVER = "127.0.0.1"
-#PATTERNS = {u'Oui/Non': [u'Oui', u'Non'], u'Oui/Non/Blanc': [u'Oui', u'Non', u'Blanc'], u'Oui/Non/Peut-être': [u'Oui', u'Non', u'Peut-être']}

ffdnispdb/__init__.py

@@ -3,6 +3,7 @@
 from flask import Flask, g
 from flask.ext.babel import Babel
 from flask.ext.sqlalchemy import SQLAlchemy, event
+from flask.ext.mail import Mail
 from werkzeug.contrib.cache import NullCache
 from .sessions import MySessionInterface
 
@@ -13,6 +14,7 @@ babel = Babel(app)
 db = SQLAlchemy(app)
 app.session_interface = MySessionInterface(db)
 cache = NullCache()
+mail = Mail(app)
 
 @event.listens_for(db.engine, "connect")
 def connect(sqlite, connection_rec):

ffdnispdb/cron_task.py

@@ -5,9 +5,11 @@ import signal
 import traceback
 from sys import stderr
 from datetime import datetime, timedelta
+from flask.ext.mail import Message
+from flask import url_for
 from ffdnispdb.crawler import TextValidator
 from ffdnispdb.models import ISP
-from ffdnispdb import db
+from ffdnispdb import app, db, mail
 
 
 MAX_RUNTIME=15*60
@@ -32,8 +34,6 @@ def timeout_handler(signum, frame):
     if last_isp == isp.id:
         strike += 1
         if strike > 2:
-            # three strikes, you're out.
-            print "you're out", isp
             signal.alarm(6)
             raise Timeout
     else:
@@ -46,6 +46,35 @@ signal.signal(signal.SIGALRM, timeout_handler)
 signal.alarm(6)
 
 
+def send_warning_email(isp, debug_msg):
+    msg=Message(u"Problem while updating your ISP's data", sender=('FFDN DB <cron@db.ffdn.org>'))
+    msg.body = """
+Hello,
+
+You are receiving this mail because your ISP, %s, is registered on the FFDN ISP Database.
+
+Our automatic update script could not access or process your ISP's data located at %s.
+
+Automatic updates of your ISP were disabled until you fix the problem.
+
+Here is some debug output to help you locate the issue:
+
+%s
+
+---
+When the issue is resolved, please click on the link below to reactivate automatic updates on your ISP:
+%s
+
+Thanks,
+The FFDN ISP Database team
+    """.strip()%(isp.complete_name, isp.json_url, debug_msg.strip(), url_for('home'))
+    msg.add_recipient(isp.tech_email)
+    mail.send(msg)
+
+
+app.config['SERVER_NAME'] = 'db.ffdn.org'
+app.app_context().push()
+
 try:
     for isp in ISP.query.filter(ISP.is_disabled == False,
                                 ISP.json_url != None,
@@ -72,7 +101,7 @@ try:
                 db.session.commit()
                 print u'%s: Error while updating:'%(datetime.now())
                 if isp.update_error_strike >= 3:
-                    # send email
+                    send_warning_email(isp, log)
                     print u'    three strikes, you\'re out'
 
                 print log.rstrip()+'\n'
@@ -94,7 +123,8 @@ try:
             db.session.add(isp)
             db.session.commit()
             if isp.update_error_strike >= 3:
-                # send email
+                send_warning_email(isp, 'Your ISP took more then 18 seconds to process. '
+                                        'Having problems with your webserver ?')
                 print u'    three strikes, you\'re out'
             print traceback.format_exc()
 

ffdnispdb/models.py

@@ -71,6 +71,13 @@ class ISP(db.Model):
     def covered_areas_names(self):
         return [c['name'] for c in self.json.get('coveredAreas', [])]
 
+    @property
+    def complete_name(self):
+        if 'shortname' in self.json:
+            return u'%s (%s)'%(self.json['shortname'], self.json['name'])
+        else:
+            return u'%s'%self.json['name']
+
     @staticmethod
     def str2date(_str):
         d=None

requirements.txt

@@ -2,6 +2,7 @@ Flask==0.10.1
 Flask-Babel==0.9
 Flask-SQLAlchemy==1.0
 Flask-WTF==0.9.1
+Flask-Mail==0.9.0
 Jinja2==2.7.1
 MarkupSafe==0.18
 Werkzeug==0.9.3