commit 8800c3815ab330359ab9f0272afa9f3817c7fc57
Author: Stefan Schwarz <ssz@bitsbeats.com>
Date:   Mon Sep 7 14:16:19 2020 +0200

    find my key

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..47def24
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1 @@
+/env/
diff --git a/Dockerfile b/Dockerfile
new file mode 100644
index 0000000..49ae423
--- /dev/null
+++ b/Dockerfile
@@ -0,0 +1,9 @@
+FROM python:3.8
+
+WORKDIR /app
+RUN true \
+	&& pip install beautifulsoup4 matrix-nio
+
+ADD . /app
+
+CMD python key.py
diff --git a/key.py b/key.py
new file mode 100644
index 0000000..bcb0089
--- /dev/null
+++ b/key.py
@@ -0,0 +1,75 @@
+import hashlib
+import time
+import asyncio
+import os
+
+import aiohttp
+import bs4
+from nio import AsyncClient, MatrixRoom, RoomMessageText
+
+
+class App:
+    def __init__(self, user="", password="", room_id=""):
+        self.user = user
+        self.password = password
+        self.room_id = room_id
+        self.known = set()
+
+    async def setup(self):
+        self.client = AsyncClient("https://doesnt.social", self.user)
+        await self.client.login(self.password)
+        await self.send_message("hi there, i'm marvin")
+
+    async def send_message(self, message: str):
+        print(message)
+        resp = await self.client.room_send(
+            room_id=self.room_id,
+            message_type="m.room.message",
+            content={
+                "msgtype": "m.text",
+                "body": message,
+            },
+        )
+        print(resp)
+
+    async def run(self):
+        await self.setup()
+        while True:
+            await self.update()
+            time.sleep(500)
+
+    async def update(self):
+        text = ""
+        async with aiohttp.ClientSession() as session:
+            url = (
+                "https://fundsuche02.kivbf.de//MyApp.asp"
+                "?wci=FundHeader&Mdt=Bamberg&format=&PLZ=96047"
+                "&KM=50&KATEGORIE=%7B705DA1A1-2E03-4B2A-A31D-4E78E713CD79%7D"
+                "&DATUM=01.09.2020&BESCHREIBUNG=&FILTER=A&MerkmaleData="
+            )
+            async with session.get(url) as resp:
+                text = await resp.text()
+        soup = bs4.BeautifulSoup(text, "html.parser")
+        elements = soup.find_all(
+            title="Link zum Suchergebnis, Link öffnet neues Fenster"
+        )
+        for element in elements:
+            description = element.text.strip()
+            digest = hashlib.sha256(description.encode()).hexdigest()
+            if self.is_new(digest):
+                await self.send_message(description)
+
+    def is_new(self, digest):
+        if digest in self.known:
+            return False
+        self.known.add(digest)
+        return True
+
+
+if __name__ == "__main__":
+    app = App(
+        user=os.environ["USER"],
+        password=os.environ["PASSWORD"],
+        room_id=os.environ["ROOM_ID"],
+    )
+    asyncio.get_event_loop().run_until_complete(app.run())