mirror of
https://github.com/StackExchange/dnscontrol.git
synced 2025-02-25 16:13:04 +08:00
56 lines
1.4 KiB
Go
56 lines
1.4 KiB
Go
package notifications
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
"strconv"
|
|
)
|
|
|
|
func init() {
|
|
initers = append(initers, func(cfg map[string]string) Notifier {
|
|
if botToken, ok := cfg["telegram_bot_token"]; ok {
|
|
if chatID, ok := cfg["telegram_chat_id"]; ok {
|
|
notifier := &telegramNotifier{
|
|
BotToken: botToken,
|
|
ChatID: chatID,
|
|
}
|
|
return notifier
|
|
}
|
|
}
|
|
return nil
|
|
})
|
|
}
|
|
|
|
// telegramNotifier sends notifications to Telegram
|
|
type telegramNotifier struct {
|
|
BotToken string
|
|
ChatID string
|
|
}
|
|
|
|
func (s *telegramNotifier) Notify(domain, provider, msg string, err error, preview bool) {
|
|
var payload struct {
|
|
ChatID int64 `json:"chat_id"`
|
|
Text string `json:"text"`
|
|
}
|
|
|
|
var url = fmt.Sprintf("https://api.telegram.org/bot%s/sendMessage", s.BotToken)
|
|
|
|
payload.ChatID, _ = strconv.ParseInt(s.ChatID, 10, 64)
|
|
|
|
if preview {
|
|
payload.Text = fmt.Sprintf(`DNSControl preview: %s[%s] -** %s`, domain, provider, msg)
|
|
} else if err != nil {
|
|
payload.Text = fmt.Sprintf(`DNSControl ERROR running correction on %s[%s] -** (%s) Error: %s`, domain, provider, msg, err)
|
|
} else {
|
|
payload.Text = fmt.Sprintf(`DNSControl successfully ran correction for **%s[%s]** - %s`, domain, provider, msg)
|
|
}
|
|
|
|
marshaledPayload, _ := json.Marshal(payload)
|
|
|
|
_, _ = http.Post(url, "application/json", bytes.NewBuffer(marshaledPayload))
|
|
|
|
}
|
|
|
|
func (s *telegramNotifier) Done() {}
|