Merge pull request #20 from career-seekers/feat/password-changing

Feat/password changing mechanism

Author: scobca

src/main/kotlin/org/careerseekers/csmailservice/cache/CacheLoader.kt

@@ -1,6 +1,10 @@
 package org.careerseekers.csmailservice.cache
 
-interface CacheLoader<T> : CacheClient<T> {
-    fun preloadCache(): Any
+import org.springframework.data.redis.core.RedisTemplate
+
+interface CacheLoader<T> {
+    val cacheKey: String
+    val redisTemplate: RedisTemplate<String, T>
+
     fun loadItemToCache(item: T): Any
 }

src/main/kotlin/org/careerseekers/csmailservice/cache/CachePreloader.kt

@@ -0,0 +1,6 @@
+package org.careerseekers.csmailservice.cache
+
+interface CachePreloader {
+
+    fun preloadCache(): Any
+}

src/main/kotlin/org/careerseekers/csmailservice/cache/CacheClient.kt renamed to src/main/kotlin/org/careerseekers/csmailservice/cache/CacheRetriever.kt

@@ -2,7 +2,7 @@ package org.careerseekers.csmailservice.cache
 
 import org.springframework.data.redis.core.RedisTemplate
 
-interface CacheClient<T> {
+interface CacheRetriever<T> {
     val cacheKey: String
     val redisTemplate: RedisTemplate<String, T>
 

src/main/kotlin/org/careerseekers/csmailservice/cache/UsersCacheClient.kt

@@ -15,7 +15,7 @@ import org.springframework.stereotype.Component
 class UsersCacheClient(
     override val redisTemplate: RedisTemplate<String, UsersCacheDto>,
     cacheManager: CacheManager,
-) : CacheClient<UsersCacheDto> {
+) : CacheRetriever<UsersCacheDto> {
     override val cacheKey = "users"
     private val cache = cacheManager.getCache(cacheKey)
 
@@ -30,7 +30,7 @@ class UsersCacheClient(
         return user
     }
 
-    private fun getUser(id: Long): UsersCacheDto? {
+    private fun getUser(id: Long): UsersCacheDto {
         try {
             return usersServiceStub.getById(
                 UserId.newBuilder()

src/main/kotlin/org/careerseekers/csmailservice/cache/VerificationCodesCache.kt

@@ -0,0 +1,24 @@
+package org.careerseekers.csmailservice.cache
+
+import org.careerseekers.csmailservice.dto.VerificationCodeDto
+import org.springframework.cache.CacheManager
+import org.springframework.data.redis.core.RedisTemplate
+import org.springframework.stereotype.Component
+
+@Component
+class VerificationCodesCache(
+    override val redisTemplate: RedisTemplate<String, VerificationCodeDto>,
+    cacheManager: CacheManager,
+) : CacheLoader<VerificationCodeDto>, CacheRetriever<VerificationCodeDto> {
+    override val cacheKey = "verification_codes"
+    private val cache = cacheManager.getCache(cacheKey)
+
+    override fun loadItemToCache(item: VerificationCodeDto) {
+        cache?.put(item.userId, item)
+    }
+
+
+    override fun getItemFromCache(key: Any): VerificationCodeDto? {
+        return cache?.get(key)?.let { it.get() as? VerificationCodeDto }
+    }
+}

src/main/kotlin/org/careerseekers/csmailservice/config/RedisTemplatesConfig.kt

@@ -2,6 +2,7 @@ package org.careerseekers.csmailservice.config
 
 import org.careerseekers.csmailservice.dto.CachesDto
 import org.careerseekers.csmailservice.dto.UsersCacheDto
+import org.careerseekers.csmailservice.dto.VerificationCodeDto
 import org.careerseekers.csmailservice.serializers.PolymorphicRedisSerializer
 import org.springframework.beans.factory.annotation.Qualifier
 import org.springframework.context.annotation.Bean
@@ -32,4 +33,22 @@ class RedisTemplatesConfig(
         template.afterPropertiesSet()
         return template
     }
+
+    @Bean
+    @Qualifier("verificationCodes")
+    fun verificationCodesRedisTemplate(
+        connectionFactory: RedisConnectionFactory
+    ): RedisTemplate<String, VerificationCodeDto> {
+        val template = RedisTemplate<String, VerificationCodeDto>()
+        template.connectionFactory = connectionFactory
+
+        template.keySerializer = StringRedisSerializer()
+        template.valueSerializer = serializer
+
+        template.hashKeySerializer = StringRedisSerializer()
+        template.hashValueSerializer = serializer
+
+        template.afterPropertiesSet()
+        return template
+    }
 }

src/main/kotlin/org/careerseekers/csmailservice/dto/CachesDto.kt

@@ -31,6 +31,14 @@ data class UsersCacheDto(
     val verified: Boolean,
 ) : CachesDto()
 
+@Serializable
+@SerialName("VerificationCodeDto")
+data class VerificationCodeDto(
+    val userId: Long,
+    val code: String,
+    var retries: Int
+) : CachesDto()
+
 val cacheModule = SerializersModule {
     polymorphic(CachesDto::class) {
         subclass(UsersCacheDto::class, UsersCacheDto.serializer())

src/main/kotlin/org/careerseekers/csmailservice/services/EmailProcessingService.kt

@@ -0,0 +1,10 @@
+package org.careerseekers.csmailservice.services
+
+import org.careerseekers.csmailservice.dto.EmailSendingTaskDto
+import org.careerseekers.csmailservice.enums.MailEventTypes
+
+interface EmailProcessingService {
+    val eventType: MailEventTypes
+
+    fun processEmail(message: EmailSendingTaskDto)
+}

src/main/kotlin/org/careerseekers/csmailservice/services/PasswordResetEmailService.kt

@@ -0,0 +1,59 @@
+package org.careerseekers.csmailservice.services
+
+import org.careerseekers.csmailservice.cache.VerificationCodesCache
+import org.careerseekers.csmailservice.dto.EmailSendingTaskDto
+import org.careerseekers.csmailservice.dto.VerificationCodeDto
+import org.careerseekers.csmailservice.enums.MailEventTypes
+import org.careerseekers.csmailservice.exceptions.NotFoundException
+import org.careerseekers.csmailservice.utils.CodeGenerator.generateVerificationCode
+import org.careerseekers.csmailservice.utils.JwtUtil
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.mail.SimpleMailMessage
+import org.springframework.mail.javamail.JavaMailSender
+import org.springframework.security.crypto.password.PasswordEncoder
+import org.springframework.stereotype.Service
+
+@Service
+class PasswordResetEmailService(
+    private val jwtUtil: JwtUtil,
+    private val mailer: JavaMailSender,
+    private val passwordEncoder: PasswordEncoder,
+    private val verificationCodesCache: VerificationCodesCache
+) : EmailProcessingService {
+    @Value("\${spring.mail.username}")
+    private val senderEmail: String? = null
+
+    override val eventType = MailEventTypes.PASSWORD_RESET
+
+    override fun processEmail(message: EmailSendingTaskDto) {
+        jwtUtil.getUserFromToken(message.token)?.let { user ->
+            val code = generateVerificationCode()
+            verificationCodesCache.loadItemToCache(VerificationCodeDto(
+                userId = user.id,
+                code = passwordEncoder.encode(code),
+                retries = 0
+            ))
+
+            val message = SimpleMailMessage()
+
+            message.from = senderEmail
+            message.setTo(user.email)
+            message.subject = "Изменение пароля"
+            message.text = """
+               Уважаемый(-ая) ${user.lastName} ${user.firstName} ${user.patronymic}!
+               
+               Для подтверждения изменения пароля введите следующий верификационный код:
+               
+               $code
+               
+               Если вы не запрашивали этот код, просто проигнорируйте это письмо.
+
+               Спасибо,
+               Команда поддержки Искателей профессий.
+            """.trimIndent()
+
+            mailer.send(message)
+        } ?: throw NotFoundException("User not found")
+
+    }
+}

src/main/kotlin/org/careerseekers/csmailservice/services/kafka/consumers/KafkaEmailSendingConsumer.kt

@@ -2,12 +2,15 @@ package org.careerseekers.csmailservice.services.kafka.consumers
 
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.careerseekers.csmailservice.dto.EmailSendingTaskDto
+import org.careerseekers.csmailservice.services.EmailProcessingService
 import org.springframework.kafka.annotation.KafkaListener
 import org.springframework.kafka.support.Acknowledgment
 import org.springframework.stereotype.Service
 
 @Service
-class KafkaEmailSendingConsumer : CustomKafkaConsumer<String, EmailSendingTaskDto> {
+class KafkaEmailSendingConsumer(
+    private val emailProcessingServices: List<EmailProcessingService>
+) : CustomKafkaConsumer<String, EmailSendingTaskDto> {
 
     @KafkaListener(
         topics = ["EMAIL_SENDING_TASKS"],
@@ -17,9 +20,14 @@ class KafkaEmailSendingConsumer : CustomKafkaConsumer<String, EmailSendingTaskDt
         consumerRecord: ConsumerRecord<String, EmailSendingTaskDto>,
         acknowledgment: Acknowledgment
     ) {
-        println(consumerRecord.value())
+        for (service in emailProcessingServices) {
+            if (service.eventType == consumerRecord.value().eventType) {
+                service.processEmail(consumerRecord.value())
+                acknowledgment.acknowledge()
 
-        acknowledgment.acknowledge()
+                break
+            }
+        }
     }
 
 }