repackaging

ticket jdbc repo

src/main/kotlin/com/vauthenticator/server/account/emailverification/SendVerifyEMailChallenge.kt

@@ -6,9 +6,9 @@ import com.vauthenticator.server.communication.domain.EMailSenderService
 import com.vauthenticator.server.mfa.domain.MfaMethod
 import com.vauthenticator.server.mfa.domain.MfaMethodsEnrollment
 import com.vauthenticator.server.oauth2.clientapp.domain.ClientAppId
-import com.vauthenticator.server.ticket.Ticket
-import com.vauthenticator.server.ticket.Ticket.Companion.MFA_SELF_ASSOCIATION_CONTEXT_VALUE
-import com.vauthenticator.server.ticket.TicketId
+import com.vauthenticator.server.ticket.domain.Ticket
+import com.vauthenticator.server.ticket.domain.Ticket.Companion.MFA_SELF_ASSOCIATION_CONTEXT_VALUE
+import com.vauthenticator.server.ticket.domain.TicketId
 import org.slf4j.LoggerFactory
 
 private const val LINK_KEY = "verificationEMailLink"

src/main/kotlin/com/vauthenticator/server/account/emailverification/VerifyEMailChallenge.kt

@@ -3,9 +3,9 @@ package com.vauthenticator.server.account.emailverification
 import com.vauthenticator.server.account.Account
 import com.vauthenticator.server.account.repository.AccountRepository
 import com.vauthenticator.server.mfa.domain.MfaMethodsEnrollmentAssociation
-import com.vauthenticator.server.ticket.InvalidTicketException
-import com.vauthenticator.server.ticket.TicketId
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.domain.InvalidTicketException
+import com.vauthenticator.server.ticket.domain.TicketId
+import com.vauthenticator.server.ticket.domain.TicketRepository
 
 class VerifyEMailChallenge(
     private val ticketRepository: TicketRepository,

src/main/kotlin/com/vauthenticator/server/config/EMailVerificationConfig.kt

@@ -15,7 +15,7 @@ import com.vauthenticator.server.communication.domain.SimpleEMailMessageFactory
 import com.vauthenticator.server.mfa.domain.MfaMethodsEnrollment
 import com.vauthenticator.server.mfa.domain.MfaMethodsEnrollmentAssociation
 import com.vauthenticator.server.oauth2.clientapp.domain.ClientApplicationRepository
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.domain.TicketRepository
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration

src/main/kotlin/com/vauthenticator/server/config/ResetPasswordConfig.kt

@@ -15,8 +15,8 @@ import com.vauthenticator.server.password.PasswordPolicy
 import com.vauthenticator.server.password.VAuthenticatorPasswordEncoder
 import com.vauthenticator.server.password.resetpassword.ResetAccountPassword
 import com.vauthenticator.server.password.resetpassword.SendResetPasswordMailChallenge
-import com.vauthenticator.server.ticket.TicketCreator
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.domain.TicketCreator
+import com.vauthenticator.server.ticket.domain.TicketRepository
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration

src/main/kotlin/com/vauthenticator/server/config/TicketConfig.kt

@@ -1,9 +1,9 @@
 package com.vauthenticator.server.config
 
-import com.vauthenticator.server.ticket.DynamoDbTicketRepository
-import com.vauthenticator.server.ticket.TicketCreator
-import com.vauthenticator.server.ticket.TicketFeatures
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.adapter.dynamodb.DynamoDbTicketRepository
+import com.vauthenticator.server.ticket.domain.TicketCreator
+import com.vauthenticator.server.ticket.domain.TicketFeatures
+import com.vauthenticator.server.ticket.domain.TicketRepository
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration

src/main/kotlin/com/vauthenticator/server/mfa/MfaConfig.kt

@@ -16,8 +16,8 @@ import com.vauthenticator.server.mask.SensitiveEmailMasker
 import com.vauthenticator.server.mask.SensitivePhoneMasker
 import com.vauthenticator.server.mfa.adapter.dynamodb.DynamoMfaAccountMethodsRepository
 import com.vauthenticator.server.mfa.domain.*
-import com.vauthenticator.server.ticket.TicketCreator
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.domain.TicketCreator
+import com.vauthenticator.server.ticket.domain.TicketRepository
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.boot.context.properties.ConfigurationProperties
 import org.springframework.context.annotation.Bean

src/main/kotlin/com/vauthenticator/server/mfa/domain/MfaMethodsEnrollment.kt

@@ -4,9 +4,9 @@ import com.vauthenticator.server.account.AccountNotFoundException
 import com.vauthenticator.server.account.repository.AccountRepository
 import com.vauthenticator.server.mask.SensitiveDataMaskerResolver
 import com.vauthenticator.server.oauth2.clientapp.domain.ClientAppId
-import com.vauthenticator.server.ticket.TicketContext
-import com.vauthenticator.server.ticket.TicketCreator
-import com.vauthenticator.server.ticket.TicketId
+import com.vauthenticator.server.ticket.domain.TicketContext
+import com.vauthenticator.server.ticket.domain.TicketCreator
+import com.vauthenticator.server.ticket.domain.TicketId
 import org.slf4j.LoggerFactory
 
 class MfaMethodsEnrollment(

src/main/kotlin/com/vauthenticator/server/mfa/domain/MfaMethodsEnrollmentAssociation.kt

@@ -1,9 +1,9 @@
 package com.vauthenticator.server.mfa.domain
 
-import com.vauthenticator.server.ticket.InvalidTicketException
-import com.vauthenticator.server.ticket.Ticket
-import com.vauthenticator.server.ticket.TicketId
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.domain.InvalidTicketException
+import com.vauthenticator.server.ticket.domain.Ticket
+import com.vauthenticator.server.ticket.domain.TicketId
+import com.vauthenticator.server.ticket.domain.TicketRepository
 
 typealias MfaAssociationVerifier = (ticket: Ticket) -> Unit
 

src/main/kotlin/com/vauthenticator/server/password/resetpassword/ResetAccountPassword.kt

@@ -8,10 +8,10 @@ import com.vauthenticator.server.oauth2.clientapp.domain.ClientAppId
 import com.vauthenticator.server.password.Password
 import com.vauthenticator.server.password.PasswordPolicy
 import com.vauthenticator.server.password.VAuthenticatorPasswordEncoder
-import com.vauthenticator.server.ticket.InvalidTicketException
-import com.vauthenticator.server.ticket.Ticket
-import com.vauthenticator.server.ticket.TicketId
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.domain.InvalidTicketException
+import com.vauthenticator.server.ticket.domain.Ticket
+import com.vauthenticator.server.ticket.domain.TicketId
+import com.vauthenticator.server.ticket.domain.TicketRepository
 import java.time.Instant
 import java.util.*
 

src/main/kotlin/com/vauthenticator/server/password/resetpassword/RestePasswordEndPoint.kt

@@ -6,7 +6,7 @@ import com.vauthenticator.server.i18n.I18nScope
 import com.vauthenticator.server.oauth2.clientapp.domain.Scope
 import com.vauthenticator.server.oauth2.clientapp.domain.Scopes
 import com.vauthenticator.server.role.domain.PermissionValidator
-import com.vauthenticator.server.ticket.TicketId
+import com.vauthenticator.server.ticket.domain.TicketId
 import jakarta.servlet.http.HttpSession
 import org.springframework.http.ResponseEntity
 import org.springframework.http.ResponseEntity.noContent

src/main/kotlin/com/vauthenticator/server/password/resetpassword/SendResetPasswordMailChallenge.kt

@@ -3,7 +3,7 @@ package com.vauthenticator.server.password.resetpassword
 import com.vauthenticator.server.account.repository.AccountRepository
 import com.vauthenticator.server.communication.domain.EMailSenderService
 import com.vauthenticator.server.oauth2.clientapp.domain.ClientAppId
-import com.vauthenticator.server.ticket.TicketCreator
+import com.vauthenticator.server.ticket.domain.TicketCreator
 
 class SendResetPasswordMailChallenge(
     private val accountRepository: AccountRepository,

src/main/kotlin/com/vauthenticator/server/ticket/DynamoDbTicketRepository.kt → src/main/kotlin/com/vauthenticator/server/ticket/adapter/dynamodb/DynamoDbTicketRepository.kt

@@ -1,6 +1,10 @@
-package com.vauthenticator.server.ticket
+package com.vauthenticator.server.ticket.adapter.dynamodb
 
 import com.vauthenticator.server.extentions.*
+import com.vauthenticator.server.ticket.domain.Ticket
+import com.vauthenticator.server.ticket.domain.TicketContext
+import com.vauthenticator.server.ticket.domain.TicketId
+import com.vauthenticator.server.ticket.domain.TicketRepository
 import software.amazon.awssdk.services.dynamodb.DynamoDbClient
 import software.amazon.awssdk.services.dynamodb.model.DeleteItemRequest
 import software.amazon.awssdk.services.dynamodb.model.GetItemRequest

src/main/kotlin/com/vauthenticator/server/ticket/adapter/jdbc/JdbcTicketRepository.kt

@@ -0,0 +1,61 @@
+package com.vauthenticator.server.ticket.adapter.jdbc
+
+import com.fasterxml.jackson.databind.ObjectMapper
+import com.vauthenticator.server.role.domain.Role
+import com.vauthenticator.server.ticket.domain.Ticket
+import com.vauthenticator.server.ticket.domain.TicketContext
+import com.vauthenticator.server.ticket.domain.TicketId
+import com.vauthenticator.server.ticket.domain.TicketRepository
+import org.springframework.jdbc.core.JdbcTemplate
+import java.util.*
+
+class JdbcTicketRepository(
+    private val jdbcTemplate: JdbcTemplate,
+    private val objectMapper: ObjectMapper
+) : TicketRepository {
+
+    override fun store(ticket: Ticket) {
+        jdbcTemplate.update(
+            "INSERT INTO TICKET (ticket, ttl, user_name, client_application_id, context) VALUES (?,?,?,?,?)",
+            ticket.ticketId.content,
+            ticket.ttl,
+            ticket.userName,
+            ticket.clientAppId,
+            objectMapper.writeValueAsString(ticket.context.content)
+        )
+    }
+
+
+    override fun loadFor(ticketId: TicketId): Optional<Ticket> {
+        val queryResult = jdbcTemplate.query(
+            "SELECT * FROM TICKET WHERE ticket = ?",
+            { rs, _ ->
+                Ticket(
+                    ticketId = TicketId(rs.getString("ticket")),
+                    ttl = rs.getLong("ttl"),
+                    userName = rs.getString("user_name"),
+                    clientAppId = rs.getString("client_application_id"),
+                    context = TicketContext(
+                        objectMapper.readValue(
+                            rs.getString("context"),
+                            Map::class.java
+                        ) as Map<String, String>
+                    )
+
+                )
+            },
+            ticketId.content
+        )
+
+        return if (queryResult.isEmpty()) {
+            Optional.empty()
+        } else {
+            Optional.of(queryResult.first())
+        }
+    }
+
+    override fun delete(ticketId: TicketId) {
+        jdbcTemplate.update("DELETE FROM TICKET WHERE ticket=?", ticketId.content)
+    }
+
+}

src/main/kotlin/com/vauthenticator/server/ticket/Ticket.kt → src/main/kotlin/com/vauthenticator/server/ticket/domain/Ticket.kt

@@ -1,13 +1,13 @@
-package com.vauthenticator.server.ticket
+package com.vauthenticator.server.ticket.domain
 
 import com.vauthenticator.server.mfa.domain.MfaDeviceId
 import com.vauthenticator.server.mfa.domain.MfaMethod
-import com.vauthenticator.server.ticket.Ticket.Companion.MFA_CHANNEL_CONTEXT_KEY
-import com.vauthenticator.server.ticket.Ticket.Companion.MFA_DEVICE_ID_CONTEXT_KEY
-import com.vauthenticator.server.ticket.Ticket.Companion.MFA_METHOD_CONTEXT_KEY
-import com.vauthenticator.server.ticket.Ticket.Companion.MFA_NOT_SELF_ASSOCIATION_CONTEXT_VALUE
-import com.vauthenticator.server.ticket.Ticket.Companion.MFA_SELF_ASSOCIATION_CONTEXT_KEY
-import com.vauthenticator.server.ticket.Ticket.Companion.MFA_SELF_ASSOCIATION_CONTEXT_VALUE
+import com.vauthenticator.server.ticket.domain.Ticket.Companion.MFA_CHANNEL_CONTEXT_KEY
+import com.vauthenticator.server.ticket.domain.Ticket.Companion.MFA_DEVICE_ID_CONTEXT_KEY
+import com.vauthenticator.server.ticket.domain.Ticket.Companion.MFA_METHOD_CONTEXT_KEY
+import com.vauthenticator.server.ticket.domain.Ticket.Companion.MFA_NOT_SELF_ASSOCIATION_CONTEXT_VALUE
+import com.vauthenticator.server.ticket.domain.Ticket.Companion.MFA_SELF_ASSOCIATION_CONTEXT_KEY
+import com.vauthenticator.server.ticket.domain.Ticket.Companion.MFA_SELF_ASSOCIATION_CONTEXT_VALUE
 import java.time.Duration
 
 data class Ticket(

src/main/kotlin/com/vauthenticator/server/ticket/TicketCreator.kt → src/main/kotlin/com/vauthenticator/server/ticket/domain/TicketCreator.kt

@@ -1,4 +1,4 @@
-package com.vauthenticator.server.ticket
+package com.vauthenticator.server.ticket.domain
 
 import com.vauthenticator.server.account.Account
 import com.vauthenticator.server.extentions.expirationTimeStampInSecondFromNow

src/main/kotlin/com/vauthenticator/server/ticket/TicketRepository.kt → src/main/kotlin/com/vauthenticator/server/ticket/domain/TicketRepository.kt

@@ -1,4 +1,4 @@
-package com.vauthenticator.server.ticket
+package com.vauthenticator.server.ticket.domain
 
 import java.util.*
 

src/main/resources/data/schema.sql

@@ -45,12 +45,21 @@ CREATE TABLE KEYS
     key_type                      varchar(255) not null,
     encrypted_private_key         text,
     public_key                    text,
-    enabled                       boolean             not null default false,
-    key_expiration_date_timestamp bigint not null default 0
+    enabled                       boolean      not null default false,
+    key_expiration_date_timestamp bigint       not null default 0
 );
 
 CREATE INDEX keys_key_purpose ON KEYS (key_purpose);
 
+CREATE TABLE TICKET
+(
+    ticket                varchar(255) not null primary key,
+    ttl                   bigint       not null default 0,
+    user_name             varchar(255) not null,
+    client_application_id varchar(255) not null,
+    context               text         not null default '{}'
+);
+
 CREATE TABLE CLIENT_APPLICATION
 (
     client_app_id            varchar(255) not null PRIMARY KEY,

src/test/kotlin/com/vauthenticator/server/account/emailverification/SendVerifyEMailChallengeTest.kt

@@ -12,9 +12,9 @@ import com.vauthenticator.server.oauth2.clientapp.domain.Scopes
 import com.vauthenticator.server.support.A_CLIENT_APP_ID
 import com.vauthenticator.server.support.AccountTestFixture.anAccount
 import com.vauthenticator.server.support.ClientAppFixture.aClientApp
-import com.vauthenticator.server.ticket.Ticket
-import com.vauthenticator.server.ticket.Ticket.Companion.MFA_SELF_ASSOCIATION_CONTEXT_VALUE
-import com.vauthenticator.server.ticket.TicketId
+import com.vauthenticator.server.ticket.domain.Ticket
+import com.vauthenticator.server.ticket.domain.Ticket.Companion.MFA_SELF_ASSOCIATION_CONTEXT_VALUE
+import com.vauthenticator.server.ticket.domain.TicketId
 import io.mockk.every
 import io.mockk.impl.annotations.MockK
 import io.mockk.junit5.MockKExtension

src/test/kotlin/com/vauthenticator/server/account/emailverification/VerifyEMailChallengeTest.kt

@@ -5,9 +5,9 @@ import com.vauthenticator.server.mfa.domain.MfaMethodsEnrollmentAssociation
 import com.vauthenticator.server.oauth2.clientapp.domain.ClientAppId
 import com.vauthenticator.server.support.AccountTestFixture
 import com.vauthenticator.server.support.TicketFixture
-import com.vauthenticator.server.ticket.InvalidTicketException
-import com.vauthenticator.server.ticket.TicketId
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.domain.InvalidTicketException
+import com.vauthenticator.server.ticket.domain.TicketId
+import com.vauthenticator.server.ticket.domain.TicketRepository
 import io.mockk.every
 import io.mockk.impl.annotations.MockK
 import io.mockk.junit5.MockKExtension

src/test/kotlin/com/vauthenticator/server/mfa/api/MfaEnrolmentAssociationEndPointTest.kt

@@ -11,7 +11,7 @@ import com.vauthenticator.server.support.A_CLIENT_APP_ID
 import com.vauthenticator.server.support.AccountTestFixture
 import com.vauthenticator.server.support.MfaFixture.mfaDeviceId
 import com.vauthenticator.server.support.SecurityFixture.principalFor
-import com.vauthenticator.server.ticket.TicketId
+import com.vauthenticator.server.ticket.domain.TicketId
 import com.vauthenticator.server.web.ExceptionAdviceController
 import io.mockk.every
 import io.mockk.impl.annotations.MockK

src/test/kotlin/com/vauthenticator/server/mfa/domain/MfaMethodsEnrollmentAssociationTest.kt

@@ -4,10 +4,10 @@ import com.vauthenticator.server.keys.domain.Kid
 import com.vauthenticator.server.oauth2.clientapp.domain.ClientAppId
 import com.vauthenticator.server.support.AccountTestFixture
 import com.vauthenticator.server.support.TicketFixture
-import com.vauthenticator.server.ticket.InvalidTicketException
-import com.vauthenticator.server.ticket.Ticket
-import com.vauthenticator.server.ticket.TicketId
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.domain.InvalidTicketException
+import com.vauthenticator.server.ticket.domain.Ticket
+import com.vauthenticator.server.ticket.domain.TicketId
+import com.vauthenticator.server.ticket.domain.TicketRepository
 import io.mockk.every
 import io.mockk.impl.annotations.MockK
 import io.mockk.junit5.MockKExtension

src/test/kotlin/com/vauthenticator/server/mfa/domain/MfaMethodsEnrollmentTest.kt

@@ -10,8 +10,8 @@ import com.vauthenticator.server.support.MfaFixture.email
 import com.vauthenticator.server.support.MfaFixture.mfaDeviceId
 import com.vauthenticator.server.support.MfaFixture.notAssociatedMfaAccountMethod
 import com.vauthenticator.server.support.TicketFixture.ticketContext
-import com.vauthenticator.server.ticket.TicketCreator
-import com.vauthenticator.server.ticket.TicketId
+import com.vauthenticator.server.ticket.domain.TicketCreator
+import com.vauthenticator.server.ticket.domain.TicketId
 import io.mockk.every
 import io.mockk.impl.annotations.MockK
 import io.mockk.junit5.MockKExtension

src/test/kotlin/com/vauthenticator/server/password/resetpassword/ResetAccountPasswordTest.kt

@@ -7,9 +7,9 @@ import com.vauthenticator.server.password.PasswordPolicy
 import com.vauthenticator.server.password.VAuthenticatorPasswordEncoder
 import com.vauthenticator.server.support.AccountTestFixture.anAccount
 import com.vauthenticator.server.support.TicketFixture
-import com.vauthenticator.server.ticket.InvalidTicketException
-import com.vauthenticator.server.ticket.TicketId
-import com.vauthenticator.server.ticket.TicketRepository
+import com.vauthenticator.server.ticket.domain.InvalidTicketException
+import com.vauthenticator.server.ticket.domain.TicketId
+import com.vauthenticator.server.ticket.domain.TicketRepository
 import io.mockk.every
 import io.mockk.impl.annotations.MockK
 import io.mockk.junit5.MockKExtension

src/test/kotlin/com/vauthenticator/server/password/resetpassword/ResetPasswordEndPointTest.kt

@@ -10,7 +10,7 @@ import com.vauthenticator.server.support.ClientAppFixture.aClientApp
 import com.vauthenticator.server.support.EMAIL
 import com.vauthenticator.server.support.SecurityFixture.principalFor
 import com.vauthenticator.server.support.VAUTHENTICATOR_ADMIN
-import com.vauthenticator.server.ticket.TicketId
+import com.vauthenticator.server.ticket.domain.TicketId
 import io.mockk.every
 import io.mockk.impl.annotations.MockK
 import io.mockk.junit5.MockKExtension

src/test/kotlin/com/vauthenticator/server/password/resetpassword/SendResetPasswordMailChallengeTest.kt

@@ -4,8 +4,8 @@ import com.vauthenticator.server.account.repository.AccountRepository
 import com.vauthenticator.server.communication.domain.EMailSenderService
 import com.vauthenticator.server.oauth2.clientapp.domain.ClientAppId
 import com.vauthenticator.server.support.AccountTestFixture.anAccount
-import com.vauthenticator.server.ticket.TicketCreator
-import com.vauthenticator.server.ticket.TicketId
+import com.vauthenticator.server.ticket.domain.TicketCreator
+import com.vauthenticator.server.ticket.domain.TicketId
 import io.mockk.every
 import io.mockk.impl.annotations.MockK
 import io.mockk.junit5.MockKExtension

src/test/kotlin/com/vauthenticator/server/support/JdbcUtils.kt

@@ -29,6 +29,7 @@ object JdbcUtils {
             jdbcTemplate.execute("DROP TABLE IF EXISTS ACCOUNT CASCADE;")
             jdbcTemplate.execute("DROP TABLE IF EXISTS ACCOUNT_ROLE;")
             jdbcTemplate.execute("DROP TABLE IF EXISTS KEYS;")
+            jdbcTemplate.execute("DROP TABLE IF EXISTS TICKET;")
             jdbcTemplate.execute("DROP TABLE IF EXISTS oauth2_authorization;")
             jdbcTemplate.execute(Files.readString(Paths.get("src/main/resources/data/schema.sql")))
         } catch (e: java.lang.Exception) {

src/test/kotlin/com/vauthenticator/server/support/TicketFixture.kt

@@ -1,9 +1,9 @@
 package com.vauthenticator.server.support
 
 import com.vauthenticator.server.mfa.domain.MfaMethod
-import com.vauthenticator.server.ticket.Ticket
-import com.vauthenticator.server.ticket.TicketContext
-import com.vauthenticator.server.ticket.TicketId
+import com.vauthenticator.server.ticket.domain.Ticket
+import com.vauthenticator.server.ticket.domain.TicketContext
+import com.vauthenticator.server.ticket.domain.TicketId
 
 object TicketFixture {