Add sensu support

README.md

@@ -67,6 +67,10 @@ Environment variable | Description
 
 LaS can send messages to a ReportBot instance.
 
+### Sensu
+
+LaS accepts JSON events from Sensu. There are no configuration options.
+
 ### Slack
 
 LaS accepts Slack-style webhooks. There are no configuration options.

lineandsinker/services/__init__.py

@@ -5,6 +5,7 @@ from .gitea import Gitea
 from .irccat import IrcCat
 from .jenkins import Jenkins
 from .reportbot import ReportBot
+from .sensu import Sensu
 from .slack import Slack
 
 services = {}
@@ -50,6 +51,11 @@ try:
 except:
     pass
 
+try:
+    services["sensu"] = Sensu()
+except:
+    pass
+
 try:
     services["slack"] = Slack()
 except:

lineandsinker/services/irccat.py

@@ -10,9 +10,9 @@ class IrcCat(Service):
         self._port = port
         self._channel = channel
 
-    def announce(self, message):
+    def announce(self, message, channel=None):
         s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
         s.connect((self._host, self._port))
         for line in message.split("\n"):
-            s.sendall(f"{self._channel} {line}\n".encode())
+            s.sendall(f"{channel or self._channel} {line}\n".encode())
         s.close()

lineandsinker/services/sensu.py

@@ -0,0 +1,9 @@
+from .service import Service
+
+
+class Sensu(Service):
+    def __init__(self):
+        super().__init__("sensu")
+
+    def accept_hook(self, identifier, request):
+        yield {"type": "sensu", **request.json}

main.py

@@ -37,6 +37,14 @@ def handle_events(events):
             )
         elif event["type"] == "slack":
             services["irccat"].announce(f"\002[{event['source']}]\002 {event['text']}")
+        elif event["type"] == "sensu":
+            state = event["check"]["state"].upper()
+            if state == "FAILING":
+                state = f"\0034{state}\003"
+            services["irccat"].announce(
+                f"{event['check']['metadata']['name']} is now \002{state}\002\n{event['check']['output']}",
+                "#sensu",
+            )
 
 
 @app.route("/")