Add notification for third party services

.env

@@ -2,3 +2,5 @@ FLASK_ENV=development
 FLASK_DEBUG=1
 FLASK_APP=openreferee_server.app
 DATABASE_URI = 'postgresql:///openreferee'
+NOTIFY_URL=
+NOTIFY_TOKEN=

openreferee_server/app.py

@@ -5,7 +5,7 @@
 from apispec_webframeworks.flask import FlaskPlugin
 from flask import Flask, jsonify
 from werkzeug.exceptions import HTTPException, UnprocessableEntity
-
+from .notify import NotifyExtension
 from . import __version__
 from .db import db, register_db_cli
 
@@ -26,6 +26,7 @@ def create_app():
     register_error_handlers(app)
     db.init_app(app)
     register_db_cli(app)
+    NotifyExtension(app, os.environ.get('NOTIFY_URL'), os.environ.get('NOTIFY_TOKEN'))
     app.register_blueprint(api)
     return app
 

openreferee_server/notify.py

@@ -0,0 +1,45 @@
+import json
+import threading
+
+from .operations import setup_requests_session
+
+
+class NotifyService:
+    def __init__(self, url=None, token=None) -> None:
+        self.url = url
+        self.token = token
+        self.session = None
+
+    def send(self, payload):
+        try:
+            self.session.get(self.url, data=json.dumps({"payload": payload}))
+        except Exception:
+            pass
+
+    def notify(self, payload):
+        if self.url is None:
+            return
+
+        if self.session is None:
+            self.session = setup_requests_session(self.token)
+
+        threading.Thread(target=self.send, args=(payload,)).start()
+
+
+class NotifyExtension:
+    def __init__(self, context=None, notify_url=None, notify_token=None):
+        self.url = notify_url
+        self.token = notify_token
+        self.service = None
+        if context is not None:
+            self.init_app(context)
+
+    def init_app(self, context):
+        context.config.setdefault('NOTIFY_URL', self.url)
+        context.config.setdefault('NOTIFY_TOKEN', self.token)
+
+        self.service = NotifyService(context.config['NOTIFY_URL'], context.config['NOTIFY_TOKEN'])
+        if not hasattr(context, 'extensions'):
+            context.extensions = {}
+
+        context.extensions['notifier'] = self.service

openreferee_server/server.py

@@ -17,6 +17,7 @@
 
 from .app import register_spec
 from .db import db
+from .notify import NotifyService
 from .defaults import DEFAULT_EDITABLES, PROCESS_EDITABLE_FILES, SERVICE_INFO
 from .models import Event
 from .operations import (
@@ -44,6 +45,10 @@
 )
 
 
+def get_notifier(context) -> NotifyService:
+    return context.extensions.get('notifier')
+
+
 def require_event_token(fn):
     @wraps(fn)
     def wrapper(*args, **kwargs):
@@ -285,6 +290,17 @@ def review_editable(
         "A new revision %r was submitted for contribution %r", revision_id, contrib_id
     )
     resp = {}
+
+    get_notifier(current_app).notify({
+        "event": event.identifier,
+        "contrib_id": contrib_id,
+        "revision_id": revision_id,
+        "action": action,
+        "editable_type": editable_type,
+        "user": user,
+        "request": request.json
+    })
+
     if action == "accept":
         resp = process_accepted_revision(event, revision)