Telegram bot initial commit

alerts/telegram.go

@@ -0,0 +1,37 @@
+package alerts
+
+import (
+	"log"
+
+	"gopkg.in/telegram-bot-api.v4"
+)
+
+type TelegramConfig struct {
+	Enabled bool   `json:"enabled"`
+	Api     string `json:"api"`
+	Chat    int64  `json:"chat"`
+}
+
+type TelegramBot struct {
+	config   *TelegramConfig
+	bot      *tgbotapi.BotAPI
+	halt     bool
+	lastFail error
+}
+
+func NewTelegramBot(cfg *TelegramConfig) *TelegramBot {
+	u := &TelegramBot{config: cfg}
+	u.bot, u.lastFail = tgbotapi.NewBotAPI(cfg.Api)
+	if u.lastFail != nil {
+		log.Panic(u.lastFail)
+	}
+	u.bot.Debug = true
+	return u
+}
+
+func (u *TelegramBot) SendMessage(text string) bool {
+	msg := tgbotapi.NewMessage(u.config.Chat, text)
+	//	msg.ReplyToMessageID = 11
+	u.bot.Send(msg)
+	return true
+}

config.example.json

@@ -3,6 +3,12 @@
 	"coin": "eth",
 	"name": "main",
 
+	"telegram": {
+		"enabled": false,
+		"api": "BOT_SECRET_KEY",
+		"chat": CHAT_ID
+	},
+
 	"proxy": {
 		"enabled": true,
 		"listen": "0.0.0.0:8888",

main.go

@@ -13,6 +13,7 @@ import (
 
 	"github.com/yvasiyarov/gorelic"
 
+	"github.com/sammy007/open-ethereum-pool/alerts"
 	"github.com/sammy007/open-ethereum-pool/api"
 	"github.com/sammy007/open-ethereum-pool/payouts"
 	"github.com/sammy007/open-ethereum-pool/proxy"
@@ -21,6 +22,7 @@ import (
 
 var cfg proxy.Config
 var backend *storage.RedisClient
+var bot *alerts.TelegramBot
 
 func startProxy() {
 	s := proxy.NewProxy(&cfg, backend)
@@ -80,6 +82,10 @@ func main() {
 		log.Printf("Running with %v threads", cfg.Threads)
 	}
 
+	if cfg.Telegram.Enabled {
+		bot := alerts.NewTelegramBot(&cfg.Telegram)
+	}
+
 	startNewrelic()
 
 	backend = storage.NewRedisClient(&cfg.Redis, cfg.Coin)

proxy/config.go

@@ -1,6 +1,7 @@
 package proxy
 
 import (
+	"github.com/sammy007/open-ethereum-pool/alerts"
 	"github.com/sammy007/open-ethereum-pool/api"
 	"github.com/sammy007/open-ethereum-pool/payouts"
 	"github.com/sammy007/open-ethereum-pool/policy"
@@ -21,6 +22,7 @@ type Config struct {
 
 	BlockUnlocker payouts.UnlockerConfig `json:"unlocker"`
 	Payouts       payouts.PayoutsConfig  `json:"payouts"`
+	Telegram      alerts.TelegramConfig  `json:"telegram"`
 
 	NewrelicName    string `json:"newrelicName"`
 	NewrelicKey     string `json:"newrelicKey"`