feat(notifier): add validation notifier config

go.mod

@@ -46,6 +46,7 @@ require (
 require github.com/prometheus/common v0.37.0
 
 require (
+	github.com/go-playground/validator/v10 v10.4.1
 	github.com/hashicorp/golang-lru/v2 v2.0.7
 	github.com/mattermost/mattermost/server/public v0.1.1
 	github.com/mitchellh/mapstructure v1.5.0
@@ -183,12 +184,15 @@ require (
 	github.com/go-openapi/jsonreference v0.20.2 // indirect
 	github.com/go-openapi/spec v0.20.9 // indirect
 	github.com/go-openapi/swag v0.22.4 // indirect
+	github.com/go-playground/locales v0.13.0 // indirect
+	github.com/go-playground/universal-translator v0.17.0 // indirect
 	github.com/hashicorp/go-hclog v1.6.3 // indirect
 	github.com/hashicorp/go-plugin v1.6.0 // indirect
 	github.com/hashicorp/yamux v0.1.1 // indirect
 	github.com/huandu/xstrings v1.3.3 // indirect
 	github.com/imdario/mergo v0.3.11 // indirect
 	github.com/josharian/intern v1.0.0 // indirect
+	github.com/leodido/go-urn v1.2.0 // indirect
 	github.com/mailru/easyjson v0.7.7 // indirect
 	github.com/mitchellh/copystructure v1.0.0 // indirect
 	github.com/mitchellh/go-testing-interface v1.14.1 // indirect

go.sum

@@ -637,9 +637,13 @@ github.com/go-openapi/swag v0.19.15/go.mod h1:QYRuS/SOXUCsnplDa677K7+DxSOj6IPNl/
 github.com/go-openapi/swag v0.22.3/go.mod h1:UzaqsxGiab7freDnrUUra0MwWfN/q7tE4j+VcZ0yl14=
 github.com/go-openapi/swag v0.22.4 h1:QLMzNJnMGPRNDCbySlcj1x01tzU8/9LTTL9hZZZogBU=
 github.com/go-openapi/swag v0.22.4/go.mod h1:UzaqsxGiab7freDnrUUra0MwWfN/q7tE4j+VcZ0yl14=
+github.com/go-playground/assert/v2 v2.0.1 h1:MsBgLAaY856+nPRTKrp3/OZK38U/wa0CcBYNjji3q3A=
 github.com/go-playground/assert/v2 v2.0.1/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
+github.com/go-playground/locales v0.13.0 h1:HyWk6mgj5qFqCT5fjGBuRArbVDfE4hi8+e8ceBS/t7Q=
 github.com/go-playground/locales v0.13.0/go.mod h1:taPMhCMXrRLJO55olJkUXHZBHCxTMfnGwq/HNwmWNS8=
+github.com/go-playground/universal-translator v0.17.0 h1:icxd5fm+REJzpZx7ZfpaD876Lmtgy7VtROAbHHXk8no=
 github.com/go-playground/universal-translator v0.17.0/go.mod h1:UkSxE5sNxxRwHyU+Scu5vgOQjsIJAF8j9muTVoKLVtA=
+github.com/go-playground/validator/v10 v10.4.1 h1:pH2c5ADXtd66mxoE0Zm9SUhxE20r7aM3F26W0hOn+GE=
 github.com/go-playground/validator/v10 v10.4.1/go.mod h1:nlOn6nFhuKACm19sB/8EGNn9GlaMV7XkbRSipzJ0Ii4=
 github.com/go-redis/redis v6.15.9+incompatible h1:K0pv1D7EQUjfyoMql+r/jZqCLizCGKFlFgcHWWmHQjg=
 github.com/go-redis/redis v6.15.9+incompatible/go.mod h1:NAIEuMOZ/fxfXJIrKDQDz8wamY7mA7PouImQ2Jvg6kA=
@@ -898,6 +902,7 @@ github.com/kr/pty v1.1.3/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
+github.com/leodido/go-urn v1.2.0 h1:hpXL4XnriNwQ/ABnpepYM/1vCLWNDfUNts8dX3xTG6Y=
 github.com/leodido/go-urn v1.2.0/go.mod h1:+8+nEpDfqqsY+g338gtMEUOtuK+4dEMhiQEgxpxOKII=
 github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
 github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=

senders/discord/init.go

@@ -5,6 +5,7 @@ import (
 	"time"
 
 	"github.com/bwmarrin/discordgo"
+	"github.com/go-playground/validator/v10"
 	"github.com/mitchellh/mapstructure"
 	"github.com/moira-alert/moira"
 	"github.com/moira-alert/moira/worker"
@@ -20,10 +21,15 @@ const (
 // Structure that represents the Discord configuration in the YAML file.
 type config struct {
 	ContactType string `mapstructure:"contact_type"`
-	Token       string `mapstructure:"token"`
+	Token       string `mapstructure:"token" validate:"required"`
 	FrontURI    string `mapstructure:"front_uri"`
 }
 
+func (cfg config) validate() error {
+	validator := validator.New()
+	return validator.Struct(cfg)
+}
+
 // Sender implements moira sender interface for discord.
 type Sender struct {
 	DataBase  moira.Database
@@ -42,9 +48,10 @@ func (sender *Sender) Init(senderSettings interface{}, logger moira.Logger, loca
 		return fmt.Errorf("failed to decode senderSettings to discord config: %w", err)
 	}
 
-	if cfg.Token == "" {
-		return fmt.Errorf("cannot read the discord token from the config")
+	if err = cfg.validate(); err != nil {
+		return fmt.Errorf("discord config validation error: %w", err)
 	}
+
 	sender.session, err = discordgo.New("Bot " + cfg.Token)
 	if err != nil {
 		return fmt.Errorf("error creating discord session: %w", err)

senders/discord/init_test.go

@@ -1,10 +1,11 @@
 package discord
 
 import (
-	"fmt"
+	"errors"
 	"testing"
 	"time"
 
+	"github.com/go-playground/validator/v10"
 	"github.com/moira-alert/moira"
 
 	logging "github.com/moira-alert/moira/logging/zerolog_adapter"
@@ -31,9 +32,14 @@ func TestInit(t *testing.T) {
 	location, _ := time.LoadLocation("UTC")
 	Convey("Init tests", t, func() {
 		sender := Sender{DataBase: &MockDB{}}
-		Convey("Empty map", func() {
-			err := sender.Init(map[string]interface{}{}, logger, nil, "")
-			So(err, ShouldResemble, fmt.Errorf("cannot read the discord token from the config"))
+
+		validatorErr := validator.ValidationErrors{}
+
+		Convey("With empty token", func() {
+			senderSettings := map[string]interface{}{}
+
+			err := sender.Init(senderSettings, logger, nil, "")
+			So(errors.As(err, &validatorErr), ShouldBeTrue)
 			So(sender, ShouldResemble, Sender{DataBase: &MockDB{}})
 		})
 
@@ -42,7 +48,9 @@ func TestInit(t *testing.T) {
 				"token":     "123",
 				"front_uri": "http://moira.uri",
 			}
-			sender.Init(senderSettings, logger, location, "15:04") //nolint
+
+			err := sender.Init(senderSettings, logger, location, "15:04") //nolint
+			So(err, ShouldBeNil)
 			So(sender.frontURI, ShouldResemble, "http://moira.uri")
 			So(sender.session.Token, ShouldResemble, "Bot 123")
 			So(sender.logger, ShouldResemble, logger)

senders/mail/mail.go

@@ -8,23 +8,29 @@ import (
 	"path/filepath"
 	"time"
 
+	"github.com/go-playground/validator/v10"
 	"github.com/mitchellh/mapstructure"
 	"github.com/moira-alert/moira"
 )
 
 // Structure that represents the Mail configuration in the YAML file.
 type config struct {
-	MailFrom     string `mapstructure:"mail_from"`
+	MailFrom     string `mapstructure:"mail_from" validate:"required"`
 	SMTPHello    string `mapstructure:"smtp_hello"`
-	SMTPHost     string `mapstructure:"smtp_host"`
-	SMTPPort     int64  `mapstructure:"smtp_port"`
+	SMTPHost     string `mapstructure:"smtp_host" validate:"required"`
+	SMTPPort     int64  `mapstructure:"smtp_port" validate:"required"`
 	InsecureTLS  bool   `mapstructure:"insecure_tls"`
 	FrontURI     string `mapstructure:"front_uri"`
 	SMTPPass     string `mapstructure:"smtp_pass"`
 	SMTPUser     string `mapstructure:"smtp_user"`
 	TemplateFile string `mapstructure:"template_file"`
 }
 
+func (cfg config) validate() error {
+	validator := validator.New()
+	return validator.Struct(cfg)
+}
+
 // Sender implements moira sender interface via pushover.
 type Sender struct {
 	From           string
@@ -64,6 +70,10 @@ func (sender *Sender) fillSettings(senderSettings interface{}, logger moira.Logg
 		return fmt.Errorf("failed to decode senderSettings to mail config: %w", err)
 	}
 
+	if err = cfg.validate(); err != nil {
+		return fmt.Errorf("mail config validation error: %w", err)
+	}
+
 	sender.logger = logger
 	sender.From = cfg.MailFrom
 	sender.SMTPHello = cfg.SMTPHello
@@ -76,12 +86,11 @@ func (sender *Sender) fillSettings(senderSettings interface{}, logger moira.Logg
 	sender.TemplateFile = cfg.TemplateFile
 	sender.location = location
 	sender.dateTimeFormat = dateTimeFormat
+
 	if sender.Username == "" {
 		sender.Username = sender.From
 	}
-	if sender.From == "" {
-		return fmt.Errorf("mail_from can't be empty")
-	}
+
 	return nil
 }
 
@@ -106,11 +115,13 @@ func (sender *Sender) tryDial() error {
 		return err
 	}
 	defer t.Close()
+
 	if sender.SMTPHello != "" {
 		if err := t.Hello(sender.SMTPHello); err != nil {
 			return err
 		}
 	}
+
 	if sender.Password != "" {
 		tlsConfig := &tls.Config{
 			InsecureSkipVerify: sender.InsecureTLS,
@@ -123,5 +134,6 @@ func (sender *Sender) tryDial() error {
 			return err
 		}
 	}
+
 	return nil
 }

senders/mail/mail_test.go

@@ -1,33 +1,90 @@
 package mail
 
 import (
-	"fmt"
+	"errors"
 	"testing"
 
+	"github.com/go-playground/validator/v10"
 	. "github.com/smartystreets/goconvey/convey"
 )
 
+const (
+	defaultMailFrom     = "test-mail-from"
+	defaultSMTPHost     = "test-smtp-host"
+	defaultSMTPPort     = 80
+	defaultSMTPHello    = "test-smtp-hello"
+	defaultInsecureTLS  = true
+	defaultFrontURI     = "test-front-uri"
+	defaultSMTPPass     = "test-smtp-pass"
+	defaultSMTPUser     = "test-smtp-user"
+	defaultTemplateFile = "test-template-file"
+)
+
 func TestFillSettings(t *testing.T) {
-	Convey("Empty map", t, func() {
+	Convey("Test fillSettings", t, func() {
 		sender := Sender{}
-		err := sender.fillSettings(map[string]interface{}{}, nil, nil, "")
-		So(err, ShouldResemble, fmt.Errorf("mail_from can't be empty"))
-		So(sender, ShouldResemble, Sender{})
-	})
 
-	Convey("Has From", t, func() {
-		sender := Sender{}
-		settings := map[string]interface{}{"mail_from": "123"}
-		Convey("No username", func() {
-			err := sender.fillSettings(settings, nil, nil, "")
-			So(err, ShouldBeNil)
-			So(sender, ShouldResemble, Sender{From: "123", Username: "123"})
+		validatorErr := validator.ValidationErrors{}
+
+		Convey("With empty mail_from", func() {
+			senderSettings := map[string]interface{}{
+				"smtp_host": defaultSMTPHost,
+				"smtp_port": defaultSMTPPort,
+			}
+
+			err := sender.fillSettings(senderSettings, nil, nil, "")
+			So(errors.As(err, &validatorErr), ShouldBeTrue)
+			So(sender, ShouldResemble, Sender{})
 		})
-		Convey("Has username", func() {
-			settings["smtp_user"] = "user"
-			err := sender.fillSettings(settings, nil, nil, "")
+
+		Convey("With empty smpt_host", func() {
+			senderSettings := map[string]interface{}{
+				"mail_from": defaultMailFrom,
+				"smtp_port": defaultSMTPPort,
+			}
+
+			err := sender.fillSettings(senderSettings, nil, nil, "")
+			So(errors.As(err, &validatorErr), ShouldBeTrue)
+			So(sender, ShouldResemble, Sender{})
+		})
+
+		Convey("With empty smpt_port", func() {
+			senderSettings := map[string]interface{}{
+				"mail_from": defaultMailFrom,
+				"smtp_host": defaultSMTPHost,
+			}
+
+			err := sender.fillSettings(senderSettings, nil, nil, "")
+			So(errors.As(err, &validatorErr), ShouldBeTrue)
+			So(sender, ShouldResemble, Sender{})
+		})
+
+		Convey("With full settings", func() {
+			senderSettings := map[string]interface{}{
+				"mail_from":     defaultMailFrom,
+				"smtp_host":     defaultSMTPHost,
+				"smtp_port":     defaultSMTPPort,
+				"smtp_hello":    defaultSMTPHello,
+				"insecure_tls":  defaultInsecureTLS,
+				"front_uri":     defaultFrontURI,
+				"smtp_user":     defaultSMTPUser,
+				"smtp_pass":     defaultSMTPPass,
+				"template_file": defaultTemplateFile,
+			}
+
+			err := sender.fillSettings(senderSettings, nil, nil, "")
 			So(err, ShouldBeNil)
-			So(sender, ShouldResemble, Sender{From: "123", Username: "user"})
+			So(sender, ShouldResemble, Sender{
+				From:         defaultMailFrom,
+				SMTPHello:    defaultSMTPHello,
+				SMTPHost:     defaultSMTPHost,
+				SMTPPort:     80,
+				FrontURI:     defaultFrontURI,
+				InsecureTLS:  defaultInsecureTLS,
+				Username:     defaultSMTPUser,
+				Password:     defaultSMTPPass,
+				TemplateFile: defaultTemplateFile,
+			})
 		})
 	})
 }

senders/mattermost/sender.go

@@ -7,6 +7,7 @@ import (
 	"net/http"
 	"time"
 
+	"github.com/go-playground/validator/v10"
 	"github.com/moira-alert/moira/senders/msgformat"
 
 	"github.com/moira-alert/moira"
@@ -18,15 +19,20 @@ import (
 
 // Structure that represents the Mattermost configuration in the YAML file.
 type config struct {
-	Url          string            `mapstructure:"url"`
+	Url          string            `mapstructure:"url" validate:"required,url"`
 	InsecureTLS  bool              `mapstructure:"insecure_tls"`
-	APIToken     string            `mapstructure:"api_token"`
-	FrontURI     string            `mapstructure:"front_uri"`
+	APIToken     string            `mapstructure:"api_token" validate:"required"`
+	FrontURI     string            `mapstructure:"front_uri" validate:"required"`
 	UseEmoji     bool              `mapstructure:"use_emoji"`
 	DefaultEmoji string            `mapstructure:"default_emoji"`
 	EmojiMap     map[string]string `mapstructure:"emoji_map"`
 }
 
+func (cfg config) validate() error {
+	validator := validator.New()
+	return validator.Struct(cfg)
+}
+
 // Sender posts messages to Mattermost chat.
 // It implements moira.Sender.
 // You must call Init method before SendEvents method.
@@ -53,8 +59,8 @@ func (sender *Sender) Init(senderSettings interface{}, logger moira.Logger, loca
 		return fmt.Errorf("failed to decode senderSettings to mattermost config: %w", err)
 	}
 
-	if cfg.Url == "" {
-		return fmt.Errorf("can not read Mattermost url from config")
+	if err = cfg.validate(); err != nil {
+		return fmt.Errorf("mattermost config validation error: %w", err)
 	}
 
 	client := model.NewAPIv4Client(cfg.Url)
@@ -68,20 +74,13 @@ func (sender *Sender) Init(senderSettings interface{}, logger moira.Logger, loca
 	}
 
 	sender.client = client
-
-	if cfg.APIToken == "" {
-		return fmt.Errorf("can not read Mattermost api_token from config")
-	}
 	sender.client.SetToken(cfg.APIToken)
 
-	if cfg.FrontURI == "" {
-		return fmt.Errorf("can not read Mattermost front_uri from config")
-	}
-
 	emojiProvider, err := emoji_provider.NewEmojiProvider(cfg.DefaultEmoji, cfg.EmojiMap)
 	if err != nil {
 		return fmt.Errorf("cannot initialize mattermost sender, err: %w", err)
 	}
+
 	sender.logger = logger
 	sender.formatter = msgformat.NewHighlightSyntaxFormatter(
 		emojiProvider,

senders/mattermost/sender_internal_test.go

@@ -21,7 +21,7 @@ func TestSendEvents(t *testing.T) {
 
 	Convey("Given configured sender", t, func() {
 		senderSettings := map[string]interface{}{ // redundant, but necessary config
-			"url":          "qwerty",
+			"url":          "https://mattermost.com/",
 			"api_token":    "qwerty",
 			"front_uri":    "qwerty",
 			"insecure_tls": true,

senders/mattermost/sender_manual_test.go

@@ -18,7 +18,7 @@ func TestSender(t *testing.T) {
 	logger, _ := logging.ConfigureLog("stdout", "debug", "test", true)
 
 	const (
-		url       = "http://localhost:8065"
+		url       = "https://mattermost.com/"
 		apiToken  = "8pdo6yoiutgidgxs9qxhbo7w4h"
 		channelID = "3y6ab8rptfdr9m1hzskghpxwsc"
 	)