Make reportbot a service.

README.md

 
 Environment variable | Description
 -------------------- | --------------------------------------------------------
- `LAS_REPORTBOT_ADDRESS` | The host:port combination to send messages to
- `LAS_REPORTBOT_PREFIX`  | The text to send to the socket before any messages (e.g. API key)
+ `LAS_REPORTBOT_URL` | The full URL to the report API endpoint
+ `LAS_REPORTBOT_KEY` | The authentication key to use
+ `LAS_REPORTBOT_CHANNEL` | The channel to send messages to
 
-LaS can send messages to a ReportBot instance (sending plain text over a TCP
-connection with a specified prefix).
+LaS can send messages to a ReportBot instance.
 
 ## Contributing
 

lineandsinker/services/__init__.py

 
 from .jenkins import Jenkins
 from .gitea import Gitea
+from .reportbot import ReportBot
 
 
 def gitea_factory():
     )
 
 
+def reportbot_factory():
+    return ReportBot(
+        os.environ["LAS_REPORTBOT_URL"],
+        os.environ["LAS_REPORTBOT_KEY"],
+        os.environ["LAS_REPORTBOT_CHANNEL"],
+    )
+
+
 factories = {"gitea": gitea_factory, "jenkins": jenkins_factory}

lineandsinker/services/reportbot.py

+import requests
+
+from .service import Service
+
+
+class ReportBot(Service):
+    def __init__(self, url, key, channel):
+        super().__init__("reportbot")
+        self._url = url
+        self._key = key
+        self._channel = channel
+
+    def announce(self, message):
+        requests.get(
+            self._url,
+            {"key": self._key, "command": f"CM {self._channel}", "args": message},
+        )

main.py

-import os
 import re
-import socket
 from functools import wraps
 
 from flask import Flask, abort, request, Response
 
 from lineandsinker.common import get_hook_key
-from lineandsinker.services import gitea_factory, jenkins_factory
-
+from lineandsinker.services import gitea_factory, jenkins_factory, reportbot_factory
 
 url_pattern = re.compile(
     "^/hooks/(?P<service>[^/]+)/(?P<identifier>.*)/(?P<key>[^/]+)$"
     return wrapper
 
 
-def reportbot_announce(message):
-    try:
-        with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
-            host = os.environ["LAS_REPORTBOT_ADDRESS"].split(":")
-            sock.connect((host[0], int(host[1])))
-            sock.sendall(
-                f"{os.environ['LAS_REPORTBOT_PREFIX']} {message}\n".encode("utf-8")
-            )
-            app.logger.info(f"Report bot response: {sock.recv(512)}")
-    except:
-        app.logger.exception("Unable to send report bot message")
-
-
 jenkins_service = jenkins_factory()
 gitea_service = gitea_factory()
+reportbot_service = reportbot_factory()
 repos = dict((name, [ssh, clone]) for name, ssh, clone in gitea_service.get_repos())
 jobs = list(jenkins_service.get_jobs())
 app = Flask(__name__)
             compare = data["compare_url"]
             pusher = data["pusher"]["login"]
 
-            reportbot_announce(
+            reportbot_service.announce(
                 f"\002[git]\002 {pusher} pushed {commits} commit{'s' if commits != 1 else ''} to {repo}: {compare}"
             )
             for commit in data["commits"][:3]:
-                reportbot_announce(
+                reportbot_service.announce(
                     f"\002[git]\002 {commit['id'][:10]}: {commit['message'][:100]}"
                 )
 
             tag = event["target"]["tag"]
             host = event["request"]["host"]
             user = event["actor"]["name"]
-            reportbot_announce(
+            reportbot_service.announce(
                 f"\002[registry]\002 New manifest pushed to {host}/{repo}:{tag} by {user}"
             )