add email alert on restart with replication manager version

Author: emmaloubersac

cluster/cluster.go

@@ -26,6 +26,7 @@ import (
 	"github.com/signal18/replication-manager/config"
 	v3 "github.com/signal18/replication-manager/repmanv3"
 	"github.com/signal18/replication-manager/router/maxscale"
+	"github.com/signal18/replication-manager/utils/alert"
 	"github.com/signal18/replication-manager/utils/cron"
 	"github.com/signal18/replication-manager/utils/dbhelper"
 	"github.com/signal18/replication-manager/utils/logrus/hooks/pushover"
@@ -334,6 +335,22 @@ func (cluster *Cluster) Init(conf config.Config, cfgGroup string, tlog *s18log.T
 	}
 	cluster.LogPrintf("ALERT", "Replication manager init cluster version : %s", cluster.Conf.Version)
 
+	if cluster.Conf.MailTo != "" {
+		msg := "Replication manager init cluster version : " + cluster.Conf.Version
+		subj := "Replication-Manager version"
+		alert := alert.Alert{}
+		alert.From = cluster.Conf.MailFrom
+		alert.To = cluster.Conf.MailTo
+		alert.Destination = cluster.Conf.MailSMTPAddr
+		alert.User = cluster.Conf.MailSMTPUser
+		alert.Password = cluster.Conf.MailSMTPPassword
+		alert.TlsVerify = cluster.Conf.MailSMTPTLSSkipVerify
+		err := alert.EmailMessage(msg, subj)
+		if err != nil {
+			cluster.LogPrintf("ERROR", "Could not send mail alert: %s ", err)
+		}
+	}
+
 	hookerr, err := s18log.NewRotateFileHook(s18log.RotateFileConfig{
 		Filename:   cluster.WorkingDir + "/sql_error.log",
 		MaxSize:    cluster.Conf.LogRotateMaxSize,

utils/alert/alert.go

@@ -58,3 +58,27 @@ New server state change from %s is %s.`, a.Origin, a.PrevState, a.State)
 
 	return err
 }
+
+func (a *Alert) EmailMessage(msg string, subj string) error {
+	e := email.NewEmail()
+	e.From = a.From
+	e.To = strings.Split(a.To, ",")
+	e.Subject = subj
+	e.Text = []byte(msg)
+	var err error
+	if a.User == "" {
+		if a.TlsVerify {
+			err = e.SendWithTLS(a.Destination, nil, &tls.Config{InsecureSkipVerify: true})
+		} else {
+			err = e.Send(a.Destination, nil)
+		}
+	} else {
+		if a.TlsVerify {
+			err = e.SendWithTLS(a.Destination, smtp.PlainAuth("", a.User, a.Password, strings.Split(a.Destination, ":")[0]), &tls.Config{InsecureSkipVerify: true})
+		} else {
+			err = e.Send(a.Destination, smtp.PlainAuth("", a.User, a.Password, strings.Split(a.Destination, ":")[0]))
+		}
+	}
+
+	return err
+}