feat(api): add emergency contact types allowed list

api/authorization.go

@@ -1,10 +1,13 @@
 package api
 
+import "github.com/moira-alert/moira/datatypes"
+
 // Authorization contains authorization configuration.
 type Authorization struct {
-	AdminList           map[string]struct{}
-	Enabled             bool
-	AllowedContactTypes map[string]struct{}
+	AdminList                    map[string]struct{}
+	Enabled                      bool
+	AllowedContactTypes          map[string]struct{}
+	AllowedEmergencyContactTypes map[datatypes.HeartbeatType]struct{}
 }
 
 // IsEnabled returns true if auth is enabled and false otherwise.

api/config.go

@@ -5,6 +5,7 @@ import (
 	"time"
 
 	"github.com/moira-alert/moira"
+	"github.com/moira-alert/moira/datatypes"
 )
 
 // WebContact is container for web ui contact validation.
@@ -43,12 +44,13 @@ type Config struct {
 
 // WebConfig is container for web ui configuration parameters.
 type WebConfig struct {
-	SupportEmail         string                `json:"supportEmail,omitempty" example:"[email protected]"`
-	RemoteAllowed        bool                  `json:"remoteAllowed" example:"true"`
-	MetricSourceClusters []MetricSourceCluster `json:"metric_source_clusters"`
-	Contacts             []WebContact          `json:"contacts"`
-	FeatureFlags         FeatureFlags          `json:"featureFlags"`
-	Sentry               Sentry                `json:"sentry"`
+	SupportEmail          string                    `json:"supportEmail,omitempty" example:"[email protected]"`
+	RemoteAllowed         bool                      `json:"remoteAllowed" example:"true"`
+	MetricSourceClusters  []MetricSourceCluster     `json:"metric_source_clusters"`
+	Contacts              []WebContact              `json:"contacts"`
+	EmergencyContactTypes []datatypes.HeartbeatType `json:"emergency_contact_types"`
+	FeatureFlags          FeatureFlags              `json:"featureFlags"`
+	Sentry                Sentry                    `json:"sentry"`
 }
 
 // MetricSourceCluster contains data about supported metric source cluster.

api/dto/emergency_contact.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"net/http"
 
+	"github.com/moira-alert/moira/api/middleware"
 	"github.com/moira-alert/moira/datatypes"
 )
 
@@ -28,10 +29,18 @@ func (emergencyContact *EmergencyContact) Bind(r *http.Request) error {
 		return ErrEmptyHeartbeatTypes
 	}
 
+	auth := middleware.GetAuth(r)
+	userLogin := middleware.GetLogin(r)
+	isAdmin := auth.IsAdmin(userLogin)
+
 	for _, emergencyType := range emergencyContact.HeartbeatTypes {
 		if !emergencyType.IsValid() {
 			return fmt.Errorf("'%s' heartbeat type doesn't exist", emergencyType)
 		}
+
+		if _, ok := auth.AllowedEmergencyContactTypes[emergencyType]; !ok && !isAdmin {
+			return fmt.Errorf("'%s' heartbeat type is not allowed", emergencyType)
+		}
 	}
 
 	return nil

api/dto/emergency_contact_test.go

@@ -1,8 +1,13 @@
 package dto
 
 import (
+	"fmt"
+	"net/http"
+	"net/http/httptest"
 	"testing"
 
+	"github.com/moira-alert/moira/api"
+	"github.com/moira-alert/moira/api/middleware"
 	"github.com/moira-alert/moira/datatypes"
 	. "github.com/smartystreets/goconvey/convey"
 )
@@ -16,6 +21,96 @@ var (
 	}
 )
 
+func TestEmergencyContactBind(t *testing.T) {
+	auth := &api.Authorization{
+		Enabled: true,
+		AllowedEmergencyContactTypes: map[datatypes.HeartbeatType]struct{}{
+			datatypes.HeartbeatNotifier: {},
+			datatypes.HeartbeatDatabase: {},
+		},
+	}
+
+	userLogin := "test"
+	testLoginKey := "login"
+	testAuthKey := "auth"
+	testContactID := "test-contact-id"
+
+	Convey("Test Bind", t, func() {
+		Convey("With empty emergency types", func() {
+			testRequest := httptest.NewRequest(http.MethodPut, "/contact", http.NoBody)
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testLoginKey, userLogin))
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testAuthKey, auth))
+
+			emergencyContact := &EmergencyContact{
+				ContactID: testContactID,
+			}
+
+			err := emergencyContact.Bind(testRequest)
+			So(err, ShouldEqual, ErrEmptyHeartbeatTypes)
+		})
+
+		Convey("With invalid heartbeat type", func() {
+			testRequest := httptest.NewRequest(http.MethodPut, "/contact", http.NoBody)
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testLoginKey, userLogin))
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testAuthKey, auth))
+
+			emergencyContact := &EmergencyContact{
+				ContactID:      testContactID,
+				HeartbeatTypes: []datatypes.HeartbeatType{"invalid-heartbeat-type"},
+			}
+
+			err := emergencyContact.Bind(testRequest)
+			So(err, ShouldResemble, fmt.Errorf("'invalid-heartbeat-type' heartbeat type doesn't exist"))
+		})
+
+		Convey("With not allowed heartbeat type", func() {
+			testRequest := httptest.NewRequest(http.MethodPut, "/contact", http.NoBody)
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testLoginKey, userLogin))
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testAuthKey, auth))
+
+			emergencyContact := &EmergencyContact{
+				ContactID:      testContactID,
+				HeartbeatTypes: []datatypes.HeartbeatType{datatypes.HeartbeatFilter},
+			}
+
+			err := emergencyContact.Bind(testRequest)
+			So(err, ShouldResemble, fmt.Errorf("'%s' heartbeat type is not allowed", datatypes.HeartbeatFilter))
+		})
+
+		Convey("With allowed heartbeat types", func() {
+			testRequest := httptest.NewRequest(http.MethodPut, "/contact", http.NoBody)
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testLoginKey, userLogin))
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testAuthKey, auth))
+
+			emergencyContact := &EmergencyContact{
+				ContactID:      testContactID,
+				HeartbeatTypes: []datatypes.HeartbeatType{datatypes.HeartbeatDatabase, datatypes.HeartbeatNotifier},
+			}
+
+			err := emergencyContact.Bind(testRequest)
+			So(err, ShouldBeNil)
+		})
+
+		Convey("With admin who's allowed everything", func() {
+			testRequest := httptest.NewRequest(http.MethodPut, "/contact", http.NoBody)
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testLoginKey, userLogin))
+			testRequest = testRequest.WithContext(middleware.SetContextValueForTest(testRequest.Context(), testAuthKey, auth))
+
+			auth.AdminList = map[string]struct{}{
+				userLogin: {},
+			}
+
+			emergencyContact := &EmergencyContact{
+				ContactID:      testContactID,
+				HeartbeatTypes: []datatypes.HeartbeatType{datatypes.HeartbeatFilter, datatypes.HeartbeatNotifier},
+			}
+
+			err := emergencyContact.Bind(testRequest)
+			So(err, ShouldBeNil)
+		})
+	})
+}
+
 func TestFromEmergencyContacts(t *testing.T) {
 	Convey("Test FromEmergencyContacts", t, func() {
 		Convey("With nil emergency contacts", func() {