eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-06-19 04:50:02 +02:00
Code Releases Activity

main.go: use github.com/nikoksr/notify as notification system instead of calling telegram directly.

Browse source
This commit is contained in:
Henrik Hautakoski 2022-11-29 16:37:09 +01:00
parent 1d350fc5f1
commit 9f1b2f3026
3 changed files with 26 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

16
main.go
View file

@ -11,7 +11,8 @@ import (
"eosio-ship-trace-reader/internal/config"
"eosio-ship-trace-reader/internal/redis"
"eosio-ship-trace-reader/internal/telegram"
"github.com/nikoksr/notify"
"github.com/nikoksr/notify/service/telegram"
eos "github.com/eoscanada/eos-go"
shipclient "github.com/eosswedenorg-go/eos-ship-client"
@ -53,8 +54,8 @@ func readerLoop() {
if recon_cnt >= 3 {
msg := fmt.Sprintf("Failed to connect to ship at '%s'", conf.ShipApi)
if err = telegram.Send(msg); err != nil {
log.WithError(err).Error("Failed to send to telegram")
if err := notify.Send(context.Background(), conf.Name, msg); err != nil {
log.WithError(err).Error("Failed to send notification")
}
recon_cnt = 0
}
@ -185,13 +186,18 @@ func main() {
return
}
// Init telegram
err = telegram.Init(conf.Name, conf.Telegram.Id, conf.Telegram.Channel)
// Init telegram notification service
telegram, err := telegram.New(conf.Telegram.Id)
if err != nil {
log.WithError(err).Fatal("Failed to initialize telegram")
return
}
telegram.AddReceivers(conf.Telegram.Channel)
// Register services in notification manager
notify.UseServices(telegram)
// Connect to redis
err = redis.Connect(conf.Redis.Addr, conf.Redis.Password, conf.Redis.DB)
if err != nil {