[JOH-50] Implement forgot password rpc

cfgldr/config.go

@@ -25,6 +25,7 @@ type Jwt struct {
  ExpiresIn int `mapstructure:"expires_in"`
  RefreshTokenTTL int `mapstructure:"refresh_token_ttl"`
  Issuer string `mapstructure:"issuer"`
+ ResetTokenTTL int `mapstructure:"reset_token_ttl"`
 }
 
 type Redis struct {
@@ -33,11 +34,23 @@ type Redis struct {
  Password string `mapstructure:"password"`
 }
 
+type Auth struct {
+ ClientURL string `mapstructure:"client_url"`
+}
+
+type Sendgrid struct {
+ ApiKey string `mapstructure:"api_key"`
+ Name string `mapstructure:"name"`
+ Address string `mapstructure:"address"`
+}
+
 type Config struct {
  App App `mapstructure:"app"`
  Database Database `mapstructure:"database"`
  Jwt Jwt `mapstructure:"jwt"`
  Redis Redis `mapstructure:"redis"`
+ Auth Auth `mapstructure:"auth"`
+ Sendgrid Sendgrid `mapstructure:"sendgrid"`
 }
 
 func LoadConfig() (config *Config, err error) {

cmd/main.go

@@ -9,6 +9,7 @@ import (
  cacheRp "github.com/isd-sgcu/johnjud-auth/internal/repository/cache"
  userRp "github.com/isd-sgcu/johnjud-auth/internal/repository/user"
  authSvc "github.com/isd-sgcu/johnjud-auth/internal/service/auth"
+ emailSvc "github.com/isd-sgcu/johnjud-auth/internal/service/email"
  jwtSvc "github.com/isd-sgcu/johnjud-auth/internal/service/jwt"
  tokenSvc "github.com/isd-sgcu/johnjud-auth/internal/service/token"
  userSvc "github.com/isd-sgcu/johnjud-auth/internal/service/user"
@@ -132,12 +133,14 @@ func main() {
 
  accessTokenCache := cacheRp.NewRepository(cacheDb)
  refreshTokenCache := cacheRp.NewRepository(cacheDb)
+ resetPasswordCache := cacheRp.NewRepository(cacheDb)
 
  jwtStrategy := strategy.NewJwtStrategy(conf.Jwt.Secret)
  jwtService := jwtSvc.NewService(conf.Jwt, jwtStrategy, jwtUtil)
- tokenService := tokenSvc.NewService(jwtService, accessTokenCache, refreshTokenCache, uuidUtil)
+ tokenService := tokenSvc.NewService(jwtService, accessTokenCache, refreshTokenCache, resetPasswordCache, uuidUtil)
 
- authService := authSvc.NewService(authRepo, userRepo, tokenService, bcryptUtil)
+ emailService := emailSvc.NewService(conf.Sendgrid)
+ authService := authSvc.NewService(authRepo, userRepo, tokenService, emailService, bcryptUtil, conf.Auth)
 
  grpc_health_v1.RegisterHealthServer(grpcServer, health.NewServer())
  authPb.RegisterAuthServiceServer(grpcServer, authService)

config/config.example.yaml

@@ -15,8 +15,17 @@ jwt:
  expires_in: 3600
  refresh_token_ttl: 604800
  issuer: <issuer>
+ reset_token_ttl: 900
 
 redis:
  host: localhost
  port: 6379
  password: ""
+
+auth:
+ client_url: localhost:3000
+
+sendgrid:
+ api_key: <api_key>
+ name: johnjud
+ address: [email protected]

go.mod

@@ -33,6 +33,8 @@ require (
  github.com/rs/zerolog v1.31.0 // indirect
  github.com/sagikazarmark/locafero v0.4.0 // indirect
  github.com/sagikazarmark/slog-shim v0.1.0 // indirect
+ github.com/sendgrid/rest v2.6.9+incompatible // indirect
+ github.com/sendgrid/sendgrid-go v3.14.0+incompatible // indirect
  github.com/sourcegraph/conc v0.3.0 // indirect
  github.com/spf13/afero v1.11.0 // indirect
  github.com/spf13/cast v1.6.0 // indirect

go.sum

@@ -69,6 +69,10 @@ github.com/sagikazarmark/locafero v0.4.0 h1:HApY1R9zGo4DBgr7dqsTH/JJxLTTsOt7u6ke
 github.com/sagikazarmark/locafero v0.4.0/go.mod h1:Pe1W6UlPYUk/+wc/6KFhbORCfqzgYEpgQ3O5fPuL3H4=
 github.com/sagikazarmark/slog-shim v0.1.0 h1:diDBnUNK9N/354PgrxMywXnAwEr1QZcOr6gto+ugjYE=
 github.com/sagikazarmark/slog-shim v0.1.0/go.mod h1:SrcSrq8aKtyuqEI1uvTDTK1arOWRIczQRv+GVI1AkeQ=
+github.com/sendgrid/rest v2.6.9+incompatible h1:1EyIcsNdn9KIisLW50MKwmSRSK+ekueiEMJ7NEoxJo0=
+github.com/sendgrid/rest v2.6.9+incompatible/go.mod h1:kXX7q3jZtJXK5c5qK83bSGMdV6tsOE70KbHoqJls4lE=
+github.com/sendgrid/sendgrid-go v3.14.0+incompatible h1:KDSasSTktAqMJCYClHVE94Fcif2i7P7wzISv1sU6DUA=
+github.com/sendgrid/sendgrid-go v3.14.0+incompatible/go.mod h1:QRQt+LX/NmgVEvmdRw0VT/QgUn499+iza2FnDca9fg8=
 github.com/sourcegraph/conc v0.3.0 h1:OQTbbt6P72L20UqAkXXuLOj79LfEanQ+YQFNpLA9ySo=
 github.com/sourcegraph/conc v0.3.0/go.mod h1:Sdozi7LEKbFPqYX2/J+iBAM6HpqSLTASQIKqDmF7Mt0=
 github.com/spf13/afero v1.11.0 h1:WJQKhtpdm3v2IzqG8VMqrr6Rf3UYpEF239Jy9wNepM8=

internal/constant/email.constant.go

@@ -0,0 +1,3 @@
+package constant
+
+const ResetPasswordSubject = "Reset Password Request"

internal/domain/dto/token/token.dto.go

@@ -29,3 +29,7 @@ type RefreshTokenCache struct {
  UserID string `json:"user_id"`
  Role constant.Role `json:"role"`
 }
+
+type ResetPasswordTokenCache struct {
+ UserID string `json:"user_id"`
+}

internal/service/auth/auth.service.go

@@ -2,12 +2,14 @@ package auth
 
 import (
  "context"
-
+ "fmt"
+ "github.com/isd-sgcu/johnjud-auth/cfgldr"
  "github.com/isd-sgcu/johnjud-auth/internal/constant"
  "github.com/isd-sgcu/johnjud-auth/internal/domain/model"
  "github.com/isd-sgcu/johnjud-auth/internal/utils"
  "github.com/isd-sgcu/johnjud-auth/pkg/repository/auth"
  "github.com/isd-sgcu/johnjud-auth/pkg/repository/user"
+ "github.com/isd-sgcu/johnjud-auth/pkg/service/email"
  "github.com/isd-sgcu/johnjud-auth/pkg/service/token"
  "github.com/rs/zerolog/log"
 
@@ -23,15 +25,19 @@ type serviceImpl struct {
  authRepo auth.Repository
  userRepo user.Repository
  tokenService token.Service
+ emailService email.Service
  bcryptUtil utils.IBcryptUtil
+ config cfgldr.Auth
 }
 
-func NewService(authRepo auth.Repository, userRepo user.Repository, tokenService token.Service, bcryptUtil utils.IBcryptUtil) authProto.AuthServiceServer {
+func NewService(authRepo auth.Repository, userRepo user.Repository, tokenService token.Service, emailService email.Service, bcryptUtil utils.IBcryptUtil, config cfgldr.Auth) authProto.AuthServiceServer {
  return &serviceImpl{
  authRepo: authRepo,
  userRepo: userRepo,
  tokenService: tokenService,
+ emailService: emailService,
  bcryptUtil: bcryptUtil,
+ config: config,
  }
 }
 
@@ -163,3 +169,31 @@ func (s *serviceImpl) SignOut(_ context.Context, request *authProto.SignOutReque
 
  return &authProto.SignOutResponse{IsSuccess: true}, nil
 }
+
+func (s *serviceImpl) ForgotPassword(_ context.Context, request *authProto.ForgotPasswordRequest) (*authProto.ForgotPasswordResponse, error) {
+ user := &model.User{}
+ err := s.userRepo.FindByEmail(request.Email, user)
+ if err != nil {
+ return nil, status.Error(codes.NotFound, constant.UserNotFoundErrorMessage)
+ }
+
+ resetPasswordToken, err := s.tokenService.CreateResetPasswordToken(user.ID.String())
+ if err != nil {
+ return nil, status.Error(codes.Internal, constant.InternalServerErrorMessage)
+ }
+
+ resetPasswordURL := fmt.Sprintf("%s/reset-password/%s", s.config.ClientURL, resetPasswordToken)
+ emailSubject := constant.ResetPasswordSubject
+ emailContent := fmt.Sprintf("Please click the following url to reset password %s", resetPasswordURL)
+ if err := s.emailService.SendEmail(emailSubject, user.Firstname, user.Email, emailContent); err != nil {
+ return nil, status.Error(codes.Internal, constant.InternalServerErrorMessage)
+ }
+
+ return &authProto.ForgotPasswordResponse{
+ Url: resetPasswordURL,
+ }, nil
+}
+
+func (s *serviceImpl) ResetPassword(_ context.Context, request *authProto.ResetPasswordRequest) (*authProto.ResetPasswordResponse, error) {
+ return nil, nil
+}