From 6203faae3fe23114fa4a3c26b7f017dc3cc6b9da Mon Sep 17 00:00:00 2001 From: Brad Stein Date: Wed, 31 Dec 2025 15:23:17 -0300 Subject: [PATCH] communication: make pin job mutable --- services/communication/pin-othrys-job.yaml | 153 +++++++++++++-------- 1 file changed, 97 insertions(+), 56 deletions(-) diff --git a/services/communication/pin-othrys-job.yaml b/services/communication/pin-othrys-job.yaml index 07bd9b6..8d4d843 100644 --- a/services/communication/pin-othrys-job.yaml +++ b/services/communication/pin-othrys-job.yaml @@ -1,68 +1,109 @@ # services/communication/pin-othrys-job.yaml apiVersion: batch/v1 -kind: Job +kind: CronJob metadata: name: pin-othrys-invite namespace: communication spec: - ttlSecondsAfterFinished: 3600 - template: + schedule: "*/30 * * * *" + concurrencyPolicy: Forbid + successfulJobsHistoryLimit: 1 + failedJobsHistoryLimit: 1 + jobTemplate: spec: - restartPolicy: OnFailure - containers: - - name: pin - image: python:3.11-slim - env: - - name: SYNAPSE_BASE - value: http://othrys-synapse-matrix-synapse:8008 - - name: SEEDER_USER - value: othrys-seeder - - name: SEEDER_PASS - valueFrom: - secretKeyRef: - name: atlasbot-credentials-runtime - key: seeder-password - command: - - /bin/sh - - -c - - | - set -euo pipefail - pip install --no-cache-dir requests >/dev/null - python - <<'PY' - import requests, urllib.parse, os + template: + spec: + restartPolicy: OnFailure + containers: + - name: pin + image: python:3.11-slim + env: + - name: SYNAPSE_BASE + value: http://othrys-synapse-matrix-synapse:8008 + - name: SEEDER_USER + value: othrys-seeder + - name: SEEDER_PASS + valueFrom: + secretKeyRef: + name: atlasbot-credentials-runtime + key: seeder-password + command: + - /bin/sh + - -c + - | + set -euo pipefail + pip install --no-cache-dir requests >/dev/null + python - <<'PY' + import os, requests, urllib.parse - BASE = os.environ["SYNAPSE_BASE"] - def login(user, password): - r = requests.post(f"{BASE}/_matrix/client/v3/login", json={ - "type": "m.login.password", - "identifier": {"type": "m.id.user", "user": user}, - "password": password, - }) - r.raise_for_status() - return r.json()["access_token"] + BASE = os.environ["SYNAPSE_BASE"] + ROOM_ALIAS = "#othrys:live.bstein.dev" + MESSAGE = ( + "Invite guests: share https://live.bstein.dev/#/room/#othrys:live.bstein.dev?action=join " + "and choose 'Continue' -> 'Join as guest'." + ) - def resolve(alias, token): - enc = urllib.parse.quote(alias) - r = requests.get(f"{BASE}/_matrix/client/v3/directory/room/{enc}", headers={"Authorization": f"Bearer {token}"}) - r.raise_for_status() - return r.json()["room_id"] + def auth(token): return {"Authorization": f"Bearer {token}"} - def send(room_id, token, body): - r = requests.post(f"{BASE}/_matrix/client/v3/rooms/{urllib.parse.quote(room_id)}/send/m.room.message", - headers={"Authorization": f"Bearer {token}"}, - json={"msgtype": "m.text", "body": body}) - r.raise_for_status() - return r.json()["event_id"] + def login(user, password): + r = requests.post(f"{BASE}/_matrix/client/v3/login", json={ + "type": "m.login.password", + "identifier": {"type": "m.id.user", "user": user}, + "password": password, + }) + r.raise_for_status() + return r.json()["access_token"] - def pin(room_id, token, event_id): - r = requests.put(f"{BASE}/_matrix/client/v3/rooms/{urllib.parse.quote(room_id)}/state/m.room.pinned_events", - headers={"Authorization": f"Bearer {token}"}, - json={"pinned": [event_id]}) - r.raise_for_status() + def resolve(alias, token): + enc = urllib.parse.quote(alias) + r = requests.get(f"{BASE}/_matrix/client/v3/directory/room/{enc}", headers=auth(token)) + r.raise_for_status() + return r.json()["room_id"] - token = login(os.environ["SEEDER_USER"], os.environ["SEEDER_PASS"]) - room_id = resolve("#othrys:live.bstein.dev", token) - msg = "Invite guests: share https://live.bstein.dev/#/room/#othrys:live.bstein.dev?action=join and choose 'Continue' -> 'Join as guest'." - eid = send(room_id, token, msg) - pin(room_id, token, eid) - PY + def get_pinned(room_id, token): + r = requests.get( + f"{BASE}/_matrix/client/v3/rooms/{urllib.parse.quote(room_id)}/state/m.room.pinned_events", + headers=auth(token), + ) + if r.status_code == 404: + return [] + r.raise_for_status() + return r.json().get("pinned", []) + + def get_event(room_id, event_id, token): + r = requests.get( + f"{BASE}/_matrix/client/v3/rooms/{urllib.parse.quote(room_id)}/event/{urllib.parse.quote(event_id)}", + headers=auth(token), + ) + if r.status_code == 404: + return None + r.raise_for_status() + return r.json() + + def send(room_id, token, body): + r = requests.post( + f"{BASE}/_matrix/client/v3/rooms/{urllib.parse.quote(room_id)}/send/m.room.message", + headers=auth(token), + json={"msgtype": "m.text", "body": body}, + ) + r.raise_for_status() + return r.json()["event_id"] + + def pin(room_id, token, event_id): + r = requests.put( + f"{BASE}/_matrix/client/v3/rooms/{urllib.parse.quote(room_id)}/state/m.room.pinned_events", + headers=auth(token), + json={"pinned": [event_id]}, + ) + r.raise_for_status() + + token = login(os.environ["SEEDER_USER"], os.environ["SEEDER_PASS"]) + room_id = resolve(ROOM_ALIAS, token) + for event_id in get_pinned(room_id, token): + ev = get_event(room_id, event_id, token) + if ev and ev.get("content", {}).get("body") == MESSAGE: + raise SystemExit(0) + + eid = send(room_id, token, MESSAGE) + pin(room_id, token, eid) + PY