Во что обернулась пересылка MQTT-сообщений в Telegram?

Периодически возникает желание получать уведомления, иметь возможность настраивать источник, фильтровать сообщения по темам, и писать как можно меньше кода. Например, присылать себе картинку/цитату/слово дня или дельту по изменениям ордеров на бирже. В результате получился универсальный инструмент — бот и персональное АПИ для отправки сообщений в Telegram. Прошу под кат.

Архитектура

Сервис состоит из следующих компонентов:

• MQTT-брокера

• REST API, которое его оборачивает и позволяет отправлять сообщения

• Telegram-бота, который подписан на MQTT и пересылает сообщения

• MongoDB для хранения пользователей и подписок

Как этим пользоваться?

Отправка сообщений организована вокруг топиков, через бота можно подписаться/отписаться. При этом реальное имя топика будет выглядеть так: <telegramId>/<topic>, поэтому каждый пользователь получает свое пространство имен и API-ключ.
Для отправки сообщений, нужно сделать следующее:

• Добавить Mqtt2TelegramBot

• Запустить команду /start, бот расскажет, как отправлять сообщение в уже созданный топик (по умолчанию их нет)

• Подписаться на какой-то топик: /sub <my-topic>, бот сразу покажет команду для отправки сообщения с помощью HTTPie (//url) и логин/пароль для Basic Auth

  О всех возможностях бот расскажет сам по команде /commands.

Примеры кода

curl -v -X POST -u "${LOGIN}:${PASSWORD}" \ https://mqtt2telegram.projects.royz.cc/api/v1.0/send \ -H "Content-Type: application/json" \ -d "{\"topic\": \"${TOPIC}\", \"payload\": \"${MESSAGE}\"}"

import requests  url = "https://mqtt2telegram.projects.royz.cc/api/v1.0/send"  login = "1234567" password = "aaBBccEEdd"  topic = "YOUR_TOPIC"  json = {     "topic": topic,     "payload": "YOUR_MESSAGE" }  requests.post(url, auth=(login, password), json=json)

import got from "got"  async function sendMessage(login, password, topic, message) {   const url = 'https://mqtt2telegram.projects.royz.cc/api/v1.0/send'   const hash = btoa(`${login}:${password}`)   const options = {     headers: {       authorization: `Basic ${hash}`     }    }   const json = {     topic,      payload: message   }   return got.post(url, {...options, json}) }

Мои примеры использования

• каждый день я отправляю себе цитату дня и картинку дня из Википедии с помощью scheduled job в github actions

• каждые 5 минут этот скрипт мониторит состояние ордеров на Binance, если что-то создалось/продалось, приходит уведомление

• у меня есть IoT-кнопка, анти-прокрастинатор, которая включает busy/idle режим в toggl.com, это не имеет ничего общего с пересылкой телеграм, просто запустил MQTT на той же инфраструктуре, и как побочный эффект могу этим же ботом подписаться на топик об изменениях состояния кнопки

• (пока идея) т.к. в MQTT позволяет отправить сразу картинку, можно отправлять изображение с камеры по расписанию или при обнаружении движения

Stack

• Сервер на Javalin (довольно сырой фреймворк, приходится просить доделывать фичи), TelegramBots

• MQTTv5: HiveMQ в облаке, бесплатного аккаунта хватает

• MongoDB в облаке для хранения пользователей и топиков

• CI/CD: github actions (деплой вручную с помощью helm в k8s под урпавлением Rancher)

Код проекта и документация.

Подключайтесь и рассказывайте о ваших примерах использования или идеях новых фич.

Спасибо за внимание!