Initial Proof of Concept

journald-to-telegram-poc.py

@@ -0,0 +1,40 @@
+#!/usr/bin/python3
+
+from systemd import journal
+import datetime
+import time
+import sys
+import select
+import requests
+
+j = journal.Reader()
+j.log_level(journal.LOG_INFO)
+j.this_boot()
+j.this_machine()
+
+j.add_match(_SYSTEMD_UNIT="sheppy-insurgency-01.service")
+j.add_match(_SYSTEMD_UNIT="sheppy-insurgency-02.service")
+
+j.seek_tail()
+j.get_previous()
+
+p = select.poll()
+journal_fd = j.fileno()
+poll_event_mask = j.get_events()
+p.register(journal_fd, poll_event_mask)
+
+while True:
+    if p.poll(1000):
+        if j.process() == journal.APPEND:
+            for entry in j:
+                msg = entry["MESSAGE"]
+                token1 = '" say_team "'
+                token2 = '" say "'
+                if token1 in msg or token2 in msg:
+                    stuff, nameAndContent = msg.split(': "')
+                    server = entry['_SYSTEMD_UNIT'].split("sheppy-")[1].split(".service")[0]
+                    nameAndContent = nameAndContent.replace(token1, "\n")
+                    nameAndContent = nameAndContent.replace(token2, "\n")
+                    nameAndContent = nameAndContent.strip("\n").strip('"')
+                    requests.post("http://localhost:5012/send-all",
+                                json={ "message" : server + ": " + nameAndContent})