diff --git a/Dockerfile b/Dockerfile index e47d677..d8c44aa 100644 --- a/Dockerfile +++ b/Dockerfile @@ -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"] diff --git a/README.md b/README.md index b14bdfe..5f92757 100644 --- a/README.md +++ b/README.md @@ -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 - 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 автоматически подхватит эти переменные. diff --git a/bridge.go b/bridge.go index b19e905..999b5e0 100644 --- a/bridge.go +++ b/bridge.go @@ -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 diff --git a/chat-bridge b/chat-bridge new file mode 100755 index 0000000..197ab90 Binary files /dev/null and b/chat-bridge differ diff --git a/discord_listener.go b/discord_listener.go index d07de95..661d74f 100644 --- a/discord_listener.go +++ b/discord_listener.go @@ -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 { diff --git a/docker-compose.yml b/docker-compose.yml index 0632ed5..850a440 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -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" diff --git a/go.mod b/go.mod index d14beaf..2e60bda 100644 --- a/go.mod +++ b/go.mod @@ -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 ) diff --git a/go.sum b/go.sum index 8ec1fb3..e06318d 100644 --- a/go.sum +++ b/go.sum @@ -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= diff --git a/lenza-py b/lenza-py new file mode 100644 index 0000000..e69de29 diff --git a/main.go b/main.go index 9ba31f1..6e3dacb 100644 --- a/main.go +++ b/main.go @@ -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 {} // Бесконечный цикл для поддержания работы программы } diff --git a/vk_listener.go b/vk_listener.go deleted file mode 100644 index 5f4a67d..0000000 --- a/vk_listener.go +++ /dev/null @@ -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() -}