38 lines
923 B
Go
38 lines
923 B
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"log"
|
|
|
|
n "moxitech/sender/internal/nats"
|
|
t "moxitech/sender/internal/telegram"
|
|
|
|
"github.com/nats-io/nats.go"
|
|
)
|
|
|
|
// Send to telegram about new stream
|
|
func main() {
|
|
// Создаем экземпляр NatsConnection
|
|
nc := &n.NatsConnection{}
|
|
tg := t.SpawnTelegramChallenger()
|
|
log.Printf("NATS Consumer started")
|
|
// Подключаемся к NATS-серверу
|
|
err := nc.Connect("nats://10.5.0.10:4222")
|
|
if err != nil {
|
|
log.Fatalf("Ошибка подключения к NATS-серверу: %v", err)
|
|
}
|
|
defer nc.Conn.Close()
|
|
// Обработчик сообщений
|
|
msgHandler := func(msg *nats.Msg) {
|
|
answer := string(msg.Data)
|
|
fmt.Printf("Получено сообщение: %s\n", answer)
|
|
tg.Send(answer)
|
|
}
|
|
_, err = nc.Scanner("telegram_queue", msgHandler)
|
|
if err != nil {
|
|
log.Fatalf("Ошибка подписки на тему: %v", err)
|
|
}
|
|
|
|
select {}
|
|
}
|