Сервис на FastAPI: приём/доставка сообщений (WebSocket, HTTP-QUERY) + хранение в Redis, а также reverse proxy с расшифровкой ECIES.
Контейнер, только ENV-конфигурация.

+-------------+      +----------------+      +-------------------+
|  Клиенты    |      | MessageCenter  |      |  Redis / Backend  |
| WS / HTTP   |<---->|    :8000       |<---->|                   |
+-------------+      +----------------+      +-------------------+
        |                       |
        | Сообщения (WS, QUERY) | Прокси (POST + upstream)
        +-----------------------+

Два режима: сообщения (хранение + рассылка) и прокси с расшифровкой (только при заданном ключе).

docker network create msgw-net
docker run -d --name redis --network msgw-net redis --appendonly yes

# Без расшифровки
docker run -d --name msgw --network msgw-net -p 8000:8000 \
  -e MSGW_CACHE=redis://redis:6379/0 \
  ghcr.io/grevinden/msgw:latest

# С расшифровкой (прокси активирован)
docker run -d --name msgw --network msgw-net -p 8000:8000 \
  -e MSGW_CACHE=redis://redis:6379/0 \
  -e MSGW_ECIES_KEY="ваш_приватный_ключ_base64url" \
  ghcr.io/grevinden/msgw:latest

Открыты:

• ws://<хост>:8000/<путь> – WebSocket
• http://<хост>:8000/<путь> – метод QUERY
• POST http://<хост>:8000/<путь>?upstream=... – прокси (при ключе)

JavaScript

const ws = new WebSocket("ws://msgw:8000/chat/general");
ws.onopen = () => ws.send(JSON.stringify({
  uuid: crypto.randomUUID(),
  ttl: 3600,
  payload: { typ: "send", top: "https://t.me/example", mes: "Привет" }
}));
ws.onmessage = e => console.log(JSON.parse(e.data));

Go (gorilla/websocket)

u := url.URL{Scheme: "ws", Host: "msgw:8000", Path: "/chat/general"}
c, _, _ := websocket.DefaultDialer.Dial(u.String(), nil)
defer c.Close()
msg := map[string]interface{}{
    "uuid": uuid.New().String(), "ttl": 3600,
    "payload": map[string]interface{}{"typ":"send","top":"https://t.me/example","mes":"Привет"},
}
c.WriteJSON(msg)
// чтение входящих: c.ReadJSON(&m)

Python (websockets)

async with websockets.connect("ws://msgw:8000/chat/general") as ws:
    await ws.send(json.dumps({
        "uuid": str(uuid.uuid4()), "ttl": 3600,
        "payload": {"typ":"send","top":"https://t.me/example","mes":"Привет"}
    }))
    async for msg in ws:
        print(json.loads(msg))

send – обычное сообщение

{
  "uuid": "550e8400-e29b-41d4-a716-446655440000",
  "ttl": 3600,
  "payload": {
    "typ": "send",
    "top": "https://t.me/example",
    "mes": "Важное уведомление"
  }
}

Сохраняется в Redis, мгновенно рассылается всем WebSocket-клиентам. TTL обновляется при каждой записи.

done – подтверждение обработки

{
  "uuid": "550e8400-e29b-41d4-a716-446655440000",
  "ttl": 3600,
  "payload": {"typ": "done"}
}

Перезаписывает старый пакет с тем же uuid. Новые клиенты получат done, а не исходный send.

fail – ошибка обработки

{
  "uuid": "550e8400-e29b-41d4-a716-446655440000",
  "ttl": 3600,
  "payload": {"typ": "fail", "err": "Не удалось декодировать"}
}

Аналогично перезаписывает и уведомляет. Поле err – строка или массив строк.

Пакет можно перезаписывать повторно – продлевает TTL и вызывает повторную рассылку.

Метод QUERY (не POST/GET).

curl -X QUERY http://msgw:8000/chat/general \
  -H "Content-Type: application/json" \
  -d '{
    "uuid": "550e8400-e29b-41d4-a716-446655440000",
    "ttl": 3600,
    "payload": {"typ": "send", "top": "https://t.me/alerts", "mes": "Сервер перезагружен"}
  }'

Ответ 200 OK, идентичный отправленному JSON. Сообщение сохранено и разослано фоново.

Работает только при заданной переменной MSGW_ECIES_KEY.
Без ключа маршрут не регистрируется.

1. Клиент (Apprise) отправляет POST на http://msgw:8000/notify.
2. Параметр upstream указывает реальный backend: http://10.0.1.5:8080/notify.
3. В теле JSON могут быть поля, содержащие зашифрованные токены в формате {{<base64url-строка>}}.
4. MessageCenter расшифровывает токены, подставляет открытые значения, перенаправляет запрос на backend.
5. Заголовки копируются (кроме Host и Content-Length – длина пересчитается).

Путь в запросе к msgw (например, /notify) не передаётся бэкенду. Бэкенд получает путь из upstream.

• Все, кроме upstream, передаются на бэкенд.
• upstream удаляется.
• При дублировании приоритет у исходных параметров. Избегайте дублирования.

Исходный запрос от Apprise к MessageCenter:

curl -X POST "http://msgw:8000/notify?upstream=http://10.0.1.5:8080/notify&chat_id=777" \
  -H "Content-Type: application/json" \
  -d '{
    "urls": [
      "tgram://774307891:{{it4Zp41QfKOgaCHQ4MY0muhLlL2wqMS08bJpyworBV8P-JOkmV9cTIEsg09rOhO7eGzu9nOflJ7UGz0zi3G-JH7tX8zryWdT9MKNIhApOM54fIwhL4tH51gBnR-IdyA}}/154562805"
    ],
    "body": "тест"
  }'

MessageCenter расшифрует токен (например, в строку secret_chat_id) и отправит на http://10.0.1.5:8080/notify?chat_id=777:

{
  "urls": ["tgram://774307891:secret_chat_id/154562805"],
  "body": "тест"
}

• 502 Bad Gateway – нет соединения с upstream.
  Тело: Upstream unreachable: [Errno 111] Connection refused
• 500 Internal Server Error – внутренняя ошибка.
  Тело: сообщение исключения.
• Неудачная расшифровка – токен остаётся как есть, запрос уходит на бэкенд без изменений. Не ошибка прокси.

Приватный ключ: 32 байта → URL-safe Base64 без padding (ровно 43 символа).

# Через wg (WireGuard)
wg genkey | basenc --base64url -w0 | tr -d '='

# Через openssl
openssl rand -base64 32 | tr '+/' '-_' | tr -d '='

Публичный ключ для клиентов:

echo "приватный" | wg pubkey | basenc --base64url -w0 | tr -d '='

+--------+      +----------------+      +-------+
| Клиент |<---->| MessageCenter  |<---->| Redis |
| (WS)   |      +----------------+      +-------+
+--------+               ^
                   (QUERY)
                     |
                 +--------+
                 | Сервер |
                 +--------+

Сервер шлёт через QUERY, клиенты получают мгновенно. При отключении сообщения восстанавливаются.

+---------+          +----------------+          +---------+
| Сервис A|--QUERY-->| MessageCenter  |<--WS-->  | Сервис B|
+---------+          +----------------+          +---------+
                           |
                         Redis

A отправляет send, B обрабатывает и отвечает done. Если B упал, задача ждёт в Redis.

+--------+       +----------------+       +-----------+
| Клиент |--POST->| MessageCenter  |--POST->| Backend  |
+--------+       +----------------+       +-----------+
                      |
                 Приватный ключ

Клиент шифрует данные публичным ключом, оборачивает в {{...}}. msgw расшифровывает, бэкенд получает чистый JSON.

Сценарии 1 и 2 можно объединять. При недоступности WebSocket клиент может переключиться на HTTP QUERY.

Поддерживаются все переменные Uvicorn.

Сервис не требует файлов конфигурации, управляется только ENV, подходит для Docker Compose, K8s, Nomad.