TURN/turn-bridge
Public Access
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Чат-бот для объединения Telegram и Discord в ROX, в отличии от основого нет ВК и сайта

Browse Source
This commit is contained in:
Taz
2026-04-22 18:27:05 +02:00
parent 95d94c16b6
commit d3b54c682b
11 changed files with 20 additions and 298 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Dockerfile
-6
View File
@@ -11,13 +11,7 @@ COPY --from=builder /app/chat-bridge .
# Переменные окружения (можно задать через docker run -e ...)
ENV TELEGRAM_TOKEN=""
ENV DISCORD_TOKEN=""
ENV VK_TOKEN=""
ENV TELEGRAM_CHAT_ID=""
ENV DISCORD_CHANNEL_ID=""
ENV VK_PEER_ID=""
ENV VK_GROUP_ID=""
ENV SITE_API_URL=""
ENV SITE_API_TOKEN=""
ENV WEBHOOK_API_KEY=""
CMD ["./chat-bridge"]
README.md
+5 -43
View File
@@ -1,74 +1,42 @@
## Пример .env
Создайте файл `.env` в корне проекта и заполните:
```env
TELEGRAM_TOKEN=your_telegram_token
DISCORD_TOKEN=your_discord_token
VK_TOKEN=your_vk_token
TELEGRAM_CHAT_ID=-1001234567890
DISCORD_CHANNEL_ID=123456789012345678
VK_PEER_ID=2000000001
VK_GROUP_ID=2000000001
```
docker-compose автоматически подхватит эти переменные.
# Go Chat Bridge
Мультичат-бот для объединения Telegram, Discord и VK.
Мультичат-бот для объединения Telegram и Discord.
## Возможности
- Пересылка сообщений между Telegram, Discord и VK
- Пересылка сообщений между Telegram и Discord
- Отображение имени отправителя в пересылаемых сообщениях
- Поддержка работы с группами VK через LongPoll
- Поддержка медиафайлов (изображения, видео, документы)
## Быстрый старт
1. Клонируйте репозиторий:
```bash
git clone <repo_url>
cd turn-bridge
cd turn-rox-bridge
```
2. Установите зависимости:
```bash
go mod tidy
```
3. Создайте и настройте ботов/токены для всех платформ:
3. Создайте и настройте ботов/токены для платформ:
- Telegram: получите токен у @BotFather
- Discord: создайте приложение и получите токен
- VK: получите токен группы с правами messages, groups (см. инструкцию ниже)
4. Укажите переменные окружения:
```bash
export TELEGRAM_TOKEN=... # токен Telegram-бота
export DISCORD_TOKEN=... # токен Discord-бота
export VK_TOKEN=... # токен группы VK
export TELEGRAM_CHAT_ID=... # id чата/канала Telegram
export DISCORD_CHANNEL_ID=... # id канала Discord
export VK_PEER_ID=... # peer_id беседы VK
export VK_GROUP_ID=... # id группы VK
```
5. Запустите приложение:
```bash
go run .
```
## Получение токена VK с нужными правами
1. В настройках группы VK включите Long Poll API и разрешите сообщения.
2. Получите токен через интерфейс группы или через OAuth:
- Создайте Standalone-приложение VK
- Перейдите по ссылке:
```
https://oauth.vk.com/authorize?client_id=ВАШ_CLIENT_ID&display=page&redirect_uri=https://oauth.vk.com/blank.html&scope=messages,groups&response_type=token&v=5.131
```
- Авторизуйтесь, скопируйте access_token из адресной строки.
## Формат пересылаемых сообщений
- `[TG] user: текст` — из Telegram
- `[DS] user: текст` — из Discord
- `[VK] user: текст` — из VK (имя пользователя VK)
## Пример .env
@@ -77,14 +45,8 @@ docker-compose автоматически подхватит эти переме
```env
TELEGRAM_TOKEN=your_telegram_token
DISCORD_TOKEN=your_discord_token
VK_TOKEN=your_vk_token
TELEGRAM_CHAT_ID=-1001234567890
DISCORD_CHANNEL_ID=123456789012345678
VK_PEER_ID=2000000001
VK_GROUP_ID=2000000001
SITE_API_URL=https://turn-guild.ru/
SITE_API_TOKEN=website_webhook_token
WEBHOOK_API_KEY=brige_webhook_token
```
docker-compose автоматически подхватит эти переменные.
bridge.go
+1 -54
View File
@@ -1,64 +1,25 @@
package main
import (
"fmt"
"io"
"mime"
"net/http"
"net/url"
"os"
"path"
"strconv"
"strings"
"github.com/SevereCloud/vksdk/v2/api"
"github.com/bwmarrin/discordgo"
tgbotapi "github.com/go-telegram-bot-api/telegram-bot-api/v5"
)
// Отправка сообщения на сайт
func (b *Bridge) SendToSite(text string) error {
apiURL := os.Getenv("SITE_API_URL")
token := os.Getenv("SITE_API_TOKEN")
if apiURL == "" || token == "" {
return fmt.Errorf("SITE_API_URL или SITE_API_TOKEN не заданы")
}
fullURL := fmt.Sprintf("%s?token=%s&text=%s", apiURL, token, url.QueryEscape(text))
req, err := http.NewRequest("GET", fullURL, nil)
if err != nil {
return err
}
req.Header.Set("Accept", "application/json")
client := &http.Client{}
resp, err := client.Do(req)
if err != nil {
return err
}
defer resp.Body.Close()
_, err = io.ReadAll(resp.Body)
return err
}
// Получить имя пользователя VK по id
func (b *Bridge) GetVKUserName(userID int) (string, error) {
resp, err := b.VK.UsersGet(api.Params{"user_ids": userID})
if err != nil || len(resp) == 0 {
return strconv.Itoa(userID), err
}
return resp[0].FirstName + " " + resp[0].LastName, nil
}
// Структура для хранения клиентов
type Bridge struct {
Telegram *tgbotapi.BotAPI
Discord *discordgo.Session
VK *api.VK
}
func NewBridge(telegramToken, discordToken, vkToken string) (*Bridge, error) {
func NewBridge(telegramToken, discordToken string) (*Bridge, error) {
// Telegram
tgBot, err := tgbotapi.NewBotAPI(telegramToken)
if err != nil {
@@ -71,13 +32,9 @@ func NewBridge(telegramToken, discordToken, vkToken string) (*Bridge, error) {
return nil, err
}
// VK
vk := api.NewVK(vkToken)
return &Bridge{
Telegram: tgBot,
Discord: dg,
VK: vk,
}, nil
}
@@ -94,16 +51,6 @@ func (b *Bridge) SendToDiscord(channelID, text string) error {
return err
}
// Отправка сообщения в VK
func (b *Bridge) SendToVK(peerID int, text string) error {
_, err := b.VK.MessagesSend(api.Params{
"peer_id": peerID,
"message": text,
"random_id": 0,
})
return err
}
// Загруженный файл на диск для пересылки как вложение
type DownloadedFile struct {
FileName string
chat-bridge
Executable
BIN
View File
Binary file not shown.
discord_listener.go
+6 -1
View File
@@ -6,11 +6,16 @@ import (
"github.com/bwmarrin/discordgo"
)
func (b *Bridge) StartDiscordListener(forward func(text string, sender string, media []string)) {
func (b *Bridge) StartDiscordListener(channelID string, forward func(text string, sender string, media []string)) {
b.Discord.AddHandler(func(s *discordgo.Session, m *discordgo.MessageCreate) {
// Игнорируем сообщения от ботов
if m.Author.Bot {
return
}
// Игнорируем сообщения не из нужного канала
if channelID != "" && m.ChannelID != channelID {
return
}
// Собираем URL вложений
media := make([]string, 0)
for _, a := range m.Attachments {
docker-compose.yml
+2 -10
View File
@@ -1,19 +1,11 @@
version: '3.8'
services:
chat-bridge:
chat-rox-bridge:
build: .
container_name: chat-bridge
container_name: chat-rox-bridge
environment:
TELEGRAM_TOKEN: "${TELEGRAM_TOKEN}"
DISCORD_TOKEN: "${DISCORD_TOKEN}"
VK_TOKEN: "${VK_TOKEN}"
TELEGRAM_CHAT_ID: "${TELEGRAM_CHAT_ID}"
DISCORD_CHANNEL_ID: "${DISCORD_CHANNEL_ID}"
VK_PEER_ID: "${VK_PEER_ID}"
VK_GROUP_ID: "${VK_GROUP_ID}"
SITE_API_URL: "${SITE_API_URL}"
SITE_API_TOKEN: "${SITE_API_TOKEN}"
WEBHOOK_API_KEY: "${WEBHOOK_API_KEY}"
restart: unless-stopped
ports:
- "8080:8080"
go.mod
-5
View File
@@ -3,17 +3,12 @@ module go-chat-bridge
go 1.22
require (
github.com/SevereCloud/vksdk/v2 v2.17.0
github.com/bwmarrin/discordgo v0.29.0
github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1
)
require (
github.com/gorilla/websocket v1.5.3 // indirect
github.com/klauspost/compress v1.17.9 // indirect
github.com/vmihailenco/msgpack/v5 v5.4.1 // indirect
github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
golang.org/x/crypto v0.0.0-20210421170649-83a5a9bb288b // indirect
golang.org/x/sys v0.0.0-20201119102817-f84b799fce68 // indirect
golang.org/x/text v0.16.0 // indirect
)
go.sum
-18
View File
@@ -1,24 +1,10 @@
github.com/SevereCloud/vksdk/v2 v2.17.0 h1:Wll63JSuBTdE0L7+V/PMn9PyhLrWSWIjX76XpWbXTFw=
github.com/SevereCloud/vksdk/v2 v2.17.0/go.mod h1:y3q3XAdqnQ2Wf0B+Wi7qNdqJc5ZZsz4ve+DoSQsrChk=
github.com/bwmarrin/discordgo v0.29.0 h1:FmWeXFaKUwrcL3Cx65c20bTRW+vOb6k8AnaP+EgjDno=
github.com/bwmarrin/discordgo v0.29.0/go.mod h1:NJZpH+1AfhIcyQsPeuBKsUtYrRnjkyu0kIVMCHkZtRY=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1 h1:wG8n/XJQ07TmjbITcGiUaOtXxdrINDz1b0J1w0SzqDc=
github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1/go.mod h1:A2S0CWkNylc2phvKXWBBdD3K0iGnDBGbzRpISP2zBl8=
github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
github.com/klauspost/compress v1.17.9 h1:6KIumPrER1LHsvBVuDa0r5xaG0Es51mhhB9BQB2qeMA=
github.com/klauspost/compress v1.17.9/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
github.com/vmihailenco/msgpack/v5 v5.4.1 h1:cQriyiUvjTwOHg8QZaPihLWeRAAVoCpE00IUPn0Bjt8=
github.com/vmihailenco/msgpack/v5 v5.4.1/go.mod h1:GaZTsDaehaPpQVyxrf5mtQlH+pc21PIudVV/E3rRQok=
github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g=
github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds=
golang.org/x/crypto v0.0.0-20210421170649-83a5a9bb288b h1:7mWr3k41Qtv8XlltBkDkl8LoP3mpSgBW8BUoxtEdbXg=
golang.org/x/crypto v0.0.0-20210421170649-83a5a9bb288b/go.mod h1:T9bdIzuCu7OtxOm1hfPfRQxPLYneinmdGuTeoZ9dtd4=
golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
@@ -26,8 +12,4 @@ golang.org/x/sys v0.0.0-20201119102817-f84b799fce68 h1:nxC68pudNYkKU6jWhgrqdreuF
golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
golang.org/x/text v0.16.0 h1:a94ExnEXNtEwYLGJSIUxnWoxoRz/ZcCsV63ROupILh4=
golang.org/x/text v0.16.0/go.mod h1:GhwF1Be+LQoKShO3cGOHzqOgRrGaYc9AvblQOmPVHnI=
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
lenza-py
View File
main.go
+6 -121
View File
@@ -1,9 +1,7 @@
package main
import (
"encoding/json"
"log"
"net/http"
"os"
"strconv"
"strings"
@@ -14,13 +12,12 @@ func main() {
telegramToken := os.Getenv("TELEGRAM_TOKEN")
discordToken := os.Getenv("DISCORD_TOKEN")
vkToken := os.Getenv("VK_TOKEN")
if telegramToken == "" || discordToken == "" || vkToken == "" {
log.Fatal("Необходимо задать переменные окружения TELEGRAM_TOKEN, DISCORD_TOKEN, VK_TOKEN")
if telegramToken == "" || discordToken == "" {
log.Fatal("Необходимо задать переменные окружения TELEGRAM_TOKEN, DISCORD_TOKEN")
}
bridge, err := NewBridge(telegramToken, discordToken, vkToken)
bridge, err := NewBridge(telegramToken, discordToken)
if err != nil {
log.Fatalf("Ошибка инициализации Bridge: %v", err)
}
@@ -30,7 +27,6 @@ func main() {
// Получаем ID чатов/каналов из переменных окружения
telegramChatID := os.Getenv("TELEGRAM_CHAT_ID") // int64
discordChannelID := os.Getenv("DISCORD_CHANNEL_ID") // string
vkPeerID := os.Getenv("VK_PEER_ID") // int
forward := func(text string, from string, sender string, media []string) {
// Собираем итоговый текст с медиа URL, если есть
@@ -59,13 +55,6 @@ func main() {
_ = bridge.SendToDiscord(discordChannelID, "[TG] "+sender+": "+msg)
}
}
// Для VK и сайта оставляем ссылки
if vkPeerID != "" {
if id, err := strconv.Atoi(vkPeerID); err == nil {
_ = bridge.SendToVK(id, "[TG] "+sender+": "+msg)
}
}
_ = bridge.SendToSite("[TG] " + sender + ": " + msg)
case "discord":
// Для Telegram отправляем файлы, если есть, иначе текст
if telegramChatID != "" {
@@ -83,116 +72,12 @@ func main() {
}
}
}
// Для VK и сайта оставляем ссылки
if vkPeerID != "" {
if id, err := strconv.Atoi(vkPeerID); err == nil {
_ = bridge.SendToVK(id, "[DS] "+sender+": "+msg)
}
}
_ = bridge.SendToSite("[DS] " + sender + ": " + msg)
case "vk":
// Если когда-либо будут передаваться ссылки на медиа из VK, для TG/Discord можем тоже отправлять файлы
if telegramChatID != "" {
if id, err := strconv.ParseInt(telegramChatID, 10, 64); err == nil {
if len(media) > 0 {
files, derr := bridge.DownloadFiles(media)
if derr == nil && len(files) > 0 {
_ = bridge.SendFilesToTelegram(id, files, "[VK] "+sender+": "+text)
bridge.CleanupFiles(files)
} else {
_ = bridge.SendToTelegram(id, "[VK] "+sender+": "+msg)
}
} else {
_ = bridge.SendToTelegram(id, "[VK] "+sender+": "+msg)
}
}
}
if discordChannelID != "" {
if len(media) > 0 {
files, derr := bridge.DownloadFiles(media)
if derr == nil && len(files) > 0 {
_ = bridge.SendFilesToDiscord(discordChannelID, files, "[VK] "+sender+": "+text)
bridge.CleanupFiles(files)
} else {
_ = bridge.SendToDiscord(discordChannelID, "[VK] "+sender+": "+msg)
}
} else {
_ = bridge.SendToDiscord(discordChannelID, "[VK] "+sender+": "+msg)
}
}
// Для сайта оставляем ссылки
_ = bridge.SendToSite("[VK] " + sender + ": " + msg)
case "site":
// Из сайта пока не принимаем ссылки на файлы, отправляем как текст
if telegramChatID != "" {
if id, err := strconv.ParseInt(telegramChatID, 10, 64); err == nil {
_ = bridge.SendToTelegram(id, "[SITE] "+sender+": "+msg)
}
}
if discordChannelID != "" {
_ = bridge.SendToDiscord(discordChannelID, "[SITE] "+sender+": "+msg)
}
if vkPeerID != "" {
if id, err := strconv.Atoi(vkPeerID); err == nil {
_ = bridge.SendToVK(id, "[SITE] "+sender+": "+msg)
}
}
}
}
bridge.StartTelegramListener(func(text string, sender string, media []string) { forward(text, "telegram", sender, media) })
bridge.StartDiscordListener(func(text string, sender string, media []string) { forward(text, "discord", sender, media) })
bridge.StartVKListener(func(text string, sender string, media []string) { forward(text, "vk", sender, media) })
bridge.StartDiscordListener(discordChannelID, func(text string, sender string, media []string) { forward(text, "discord", sender, media) })
// webhook endpoint
http.HandleFunc("/webhook", func(w http.ResponseWriter, r *http.Request) {
if r.Method != http.MethodPost {
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
return
}
apiKey := os.Getenv("WEBHOOK_API_KEY")
if apiKey == "" {
http.Error(w, "Webhook API key not set", http.StatusInternalServerError)
return
}
key := r.URL.Query().Get("key")
if key == "" {
// также можно принимать ключ в теле запроса
var req struct {
Key string `json:"key"`
Text string `json:"text"`
Sender string `json:"sender"`
}
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
http.Error(w, "Bad request", http.StatusBadRequest)
return
}
if req.Key != apiKey {
http.Error(w, "Forbidden", http.StatusForbidden)
return
}
forward(req.Text, "site", req.Sender, nil)
w.WriteHeader(http.StatusOK)
w.Write([]byte("ok"))
return
}
if key != apiKey {
http.Error(w, "Forbidden", http.StatusForbidden)
return
}
var req struct {
Text string `json:"text"`
Sender string `json:"sender"`
}
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
http.Error(w, "Bad request", http.StatusBadRequest)
return
}
forward(req.Text, "site", req.Sender, nil)
w.WriteHeader(http.StatusOK)
w.Write([]byte("ok"))
})
log.Println("Webhook listening on :8080 (/webhook)")
log.Fatal(http.ListenAndServe(":8080", nil))
log.Println("Chat Bridge запущен и работает")
select {} // Бесконечный цикл для поддержания работы программы
}
vk_listener.go
-40
View File
@@ -1,40 +0,0 @@
package main
import (
"context"
"log"
"os"
"strconv"
"github.com/SevereCloud/vksdk/v2/events"
"github.com/SevereCloud/vksdk/v2/longpoll-bot"
)
func (b *Bridge) StartVKListener(forward func(text string, sender string, media []string)) {
groupIDStr := os.Getenv("VK_GROUP_ID")
if groupIDStr == "" {
log.Println("VK_GROUP_ID не задана в переменных окружения")
return
}
groupID, err := strconv.Atoi(groupIDStr)
if err != nil {
log.Printf("Ошибка преобразования VK_GROUP_ID: %v", err)
return
}
lp, err := longpoll.NewLongPoll(b.VK, groupID)
if err != nil {
log.Printf("Ошибка создания longpoll: %v", err)
return
}
lp.MessageNew(func(_ context.Context, obj events.MessageNewObject) {
log.Printf("[VK] %d: %s", obj.Message.FromID, obj.Message.Text)
sender := "vk:" + strconv.Itoa(obj.Message.FromID)
if name, err := b.GetVKUserName(obj.Message.FromID); err == nil {
sender = name
}
forward(obj.Message.Text, sender, nil)
})
go lp.Run()
}