Add an authenticated fixed-message delivery test and serialize Telegram sends

README.md

@@ -66,6 +66,10 @@ authenticated diagnostics use the configured transport.
 When the relay is configured, read-only `/diagnostics` and `/status` also accept
 `Authorization: Bearer TELEGRAM_RELAY_SECRET`. The existing webhook-secret
 routes continue to work. This does not authorize incoming publication webhooks.
+An explicit authenticated POST to `/diagnostics/telegram-test` sends one fixed,
+silent integration-test message to the configured chat. It does not consume AI
+tokens or enqueue a publication. Do not retry it blindly after a network error:
+Telegram may have accepted the message even when its response was lost.
 
 See `telegram-relay/README.md` for deployment and secret configuration. Verify
 the relay's read-only getMe, getChat and getChatMember checks before rebuilding

receiver.py

@@ -368,6 +368,7 @@ class Clients:
     def __init__(self, config):
         self.config, self.last_tg = config, 0.0
         self.diagnostics_lock = threading.Lock()
+        self.telegram_lock = threading.Lock()
         self.telegram_health = {"status": "not_checked"}
 
     def telegram_request(self, method, payload, timeout):
@@ -441,6 +442,10 @@ class Clients:
         return answer, result.get("usage", {})
 
     def telegram(self, method, payload):
+        with self.telegram_lock:
+            return self.telegram_locked(method, payload)
+
+    def telegram_locked(self, method, payload):
         time.sleep(max(0, 3.2 - (time.monotonic() - self.last_tg)))
         self.last_tg = time.monotonic()
         data = {"chat_id": self.config.chat_id, **payload}
@@ -620,6 +625,14 @@ def make_server(monitor, host="0.0.0.0", port=7860):
             return self.reply(404, {"error": "not_found"})
 
         def do_POST(self):
+            if urlsplit(self.path).path == "/diagnostics/telegram-test" and self.relay_authorized():
+                try:
+                    sent = monitor.clients.telegram("sendMessage", {
+                        "text": "Проверка интеграции: доставка из Hugging Face в Telegram восстановлена",
+                        "disable_notification": True})
+                    return self.reply(200, {"ok": True, "message_id": sent["message_id"]})
+                except ServiceError as exc:
+                    return self.reply(503, {"ok": False, "error": exc.code})
             if not self.authorized("/medialogia/"):
                 return self.reply(404, {"error": "not_found"})
             try: