sirbot: readthedocs

Author: ovv

pyslackersweb/sirbot/__init__.py

@@ -1,7 +1,6 @@
 from aiohttp import web
 
-from .. import settings
-from .views import routes  # , on_oauth2_login
+from .views import routes
 
 
 async def app_factory() -> web.Application:
@@ -10,10 +9,7 @@ async def app_factory() -> web.Application:
         client_session=None,  # populated via parent app signal
         redis=None,  # populated via parent app signal
         scheduler=None,  # populated via parent app signal
-        slack_invite_token=settings.SLACK_INVITE_TOKEN,
-        slack_token=settings.SLACK_TOKEN,
     )
 
     sirbot.add_routes(routes)
-
     return sirbot

pyslackersweb/sirbot/settings.py

@@ -0,0 +1,8 @@
+import os
+
+# production
+READTHEDOCS_NOTIFICATION_CHANNEL = "community_projects"
+
+# Development
+if os.environ.get("PLATFORM_BRANCH") != "master":
+    READTHEDOCS_NOTIFICATION_CHANNEL = "general"

pyslackersweb/sirbot/views.py

@@ -1,10 +1,32 @@
 import logging
 
 from aiohttp import web
+from slack import methods
+from slack.events import Message
 
 from pyslackersweb.util.log import ContextAwareLoggerAdapter
 
+from . import settings
 
 logger = ContextAwareLoggerAdapter(logging.getLogger(__name__))
 
 routes = web.RouteTableDef()
+
+
+@routes.view("/readthedocs", name="readthedocs")
+class ReadTheDocsView(web.View):
+    async def post(self):
+        payload = await self.request.json()
+
+        project = payload.get("name")
+        if not project:
+            return web.Response(status=400)
+
+        logger.debug("Incoming readthedocs notification: %s", payload)
+
+        msg = Message()
+        msg["channel"] = settings.READTHEDOCS_NOTIFICATION_CHANNEL
+        msg["text"] = f"""Building of {project} documentation failed ! :cry:"""
+        await self.request.app["slack_client"].query(methods.CHAT_POST_MESSAGE, data=msg)
+
+        return web.Response(status=200)

tests/test_sirbot.py

@@ -0,0 +1,24 @@
+from slack import methods
+
+from pyslackersweb.sirbot import settings
+
+
+async def test_readthedocs_notification(client):
+    r = await client.post("/bot/readthedocs", json={"name": "pyslackers/website"})
+    assert r.status == 200
+
+    # Assert we send a message to slack
+    client.app["slack_client"]._request.assert_called_once()
+    assert methods.CHAT_POST_MESSAGE.value[0] in client.app["slack_client"]._request.call_args.args
+    assert (
+        settings.READTHEDOCS_NOTIFICATION_CHANNEL
+        in client.app["slack_client"]._request.call_args.args[3]
+    )
+
+
+async def test_readthedocs_notification_missing_name(client):
+    r = await client.post("/bot/readthedocs", json={})
+    assert r.status == 400
+
+    # Assert we did not send a message to slack
+    assert not client.app["slack_client"]._request.called