SAAS-174 Percona Platform user's password reset

Gopkg.toml

@@ -16,11 +16,11 @@ required = [
 
 [[constraint]]
   name = "github.com/percona/pmm"
-  branch = "PMM-2.0"
+  branch = "SAAS-174-password-reset"
 
 [[constraint]]
   name = "github.com/percona-platform/saas"
-  branch = "main"
+  branch = "SAAS-174-password-reset"
 
 # to prevent unexpected downgrades; see https://github.com/percona/exporter_shared/releases/tag/v0.6.0
 [[constraint]]

services/platform/platform.go

@@ -171,6 +171,22 @@ func (s *Service) refreshSession(ctx context.Context) error {
 	return nil
 }
 
+// ResetPassword initiates password reset procedure for user with given email.
+func (s *Service) ResetPassword(ctx context.Context, email string) error {
+	cc, err := dial(ctx, s.host)
+	if err != nil {
+		return errors.Wrap(err, "failed establish connection with Percona")
+	}
+	defer cc.Close() //nolint:errcheck
+
+	_, err = api.NewAuthAPIClient(cc).ResetPassword(ctx, &api.ResetPasswordRequest{Email: email})
+	if err != nil {
+		return errors.Wrap(err, "failed to reset password")
+	}
+
+	return nil
+}
+
 func dial(ctx context.Context, fullHost string) (*grpc.ClientConn, error) {
 	host, _, err := net.SplitHostPort(fullHost)
 	if err != nil {

services/platform/platform_test.go

@@ -82,6 +82,17 @@ func TestPlatformService(t *testing.T) {
 		err = s.refreshSession(context.Background())
 		assert.NoError(t, err)
 	})
+
+	t.Run("ResetPassword", func(t *testing.T) {
+		login := gofakeit.Email()
+		password := gofakeit.Password(true, true, true, false, false, 14)
+
+		err := s.SignUp(context.Background(), login, password)
+		require.NoError(t, err)
+
+		err = s.ResetPassword(context.Background(), login)
+		assert.NoError(t, err)
+	})
 }
 
 func init() { //nolint:gochecknoinits

services/server/deps.go

@@ -93,4 +93,5 @@ type telemetryService interface {
 type platformService interface {
 	SignUp(ctx context.Context, email, password string) error
 	SignIn(ctx context.Context, email, password string) error
+	ResetPassword(ctx context.Context, email string) error
 }

services/server/server.go

@@ -636,6 +636,17 @@ func (s *Server) PlatformSignIn(ctx context.Context, req *serverpb.PlatformSignI
 	return &serverpb.PlatformSignInResponse{}, nil
 }
 
+// PlatformResetPassword initiates Percona Platform user's password reset procedure.
+func (s *Server) PlatformResetPassword(ctx context.Context, req *serverpb.PlatformResetPasswordRequest) (*serverpb.PlatformResetPasswordResponse, error) {
+	nCtx, cancel := context.WithTimeout(ctx, platformAPITimeout)
+	defer cancel()
+	if err := s.platformService.ResetPassword(nCtx, req.Email); err != nil {
+		return nil, err
+	}
+
+	return &serverpb.PlatformResetPasswordResponse{}, nil
+}
+
 // check interfaces
 var (
 	_ serverpb.ServerServer = (*Server)(nil)