feat: Receive Kakao Server Access Token (OAuth2)

build.gradle.kts

@@ -5,77 +5,82 @@ val imageTag = System.getenv("IMAGE_TAG") ?: "latest"
 val repoURL: String? = System.getenv("IMAGE_REPO_URL")
 
 plugins {
-	id("org.springframework.boot") version "3.2.3"
-	id("io.spring.dependency-management") version "1.1.4"
-	id("com.google.cloud.tools.jib") version "3.4.1"
-	kotlin("jvm") version "1.9.22"
-	kotlin("plugin.spring") version "1.9.22"
-	kotlin("plugin.jpa") version "1.9.22"
-	kotlin("plugin.allopen") version "1.9.22"
+    id("org.springframework.boot") version "3.2.3"
+    id("io.spring.dependency-management") version "1.1.4"
+    id("com.google.cloud.tools.jib") version "3.4.1"
+    kotlin("jvm") version "1.9.22"
+    kotlin("plugin.spring") version "1.9.22"
+    kotlin("plugin.jpa") version "1.9.22"
+    kotlin("plugin.allopen") version "1.9.22"
 }
 
 group = "com.vacgom"
 version = "0.0.1-SNAPSHOT"
 
 java {
-	sourceCompatibility = JavaVersion.VERSION_17
+    sourceCompatibility = JavaVersion.VERSION_17
 }
 
 repositories {
-	mavenCentral()
+    mavenCentral()
 }
 
 dependencies {
-	implementation("org.springframework.boot:spring-boot-starter-data-jpa")
-	implementation("org.springframework.boot:spring-boot-starter-security")
-	implementation("org.springframework.boot:spring-boot-starter-web")
-	implementation("org.springframework.boot:spring-boot-starter-validation")
+    implementation("org.springframework.boot:spring-boot-starter-data-jpa")
+    implementation("org.springframework.boot:spring-boot-starter-security")
+    implementation("org.springframework.boot:spring-boot-starter-web")
+    implementation("org.springframework.boot:spring-boot-starter-validation")
 
-	implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
-	implementation("org.flywaydb:flyway-core")
-	implementation("org.flywaydb:flyway-mysql")
-	implementation("org.jetbrains.kotlin:kotlin-reflect")
-	developmentOnly("org.springframework.boot:spring-boot-devtools")
-	runtimeOnly("com.mysql:mysql-connector-j")
-	testImplementation("org.springframework.boot:spring-boot-starter-test")
-	testImplementation("org.springframework.security:spring-security-test")
+    implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
+    implementation("org.flywaydb:flyway-core")
+    implementation("org.flywaydb:flyway-mysql")
+    implementation("org.jetbrains.kotlin:kotlin-reflect")
+    developmentOnly("org.springframework.boot:spring-boot-devtools")
+    runtimeOnly("com.mysql:mysql-connector-j")
+    testImplementation("org.springframework.boot:spring-boot-starter-test")
+    testImplementation("org.springframework.security:spring-security-test")
+
+    implementation("io.jsonwebtoken:jjwt-api:0.11.5")
+    implementation("io.jsonwebtoken:jjwt-gson:0.11.5")
+    runtimeOnly("io.jsonwebtoken:jjwt-impl:0.11.5")
+    annotationProcessor("org.springframework.boot:spring-boot-configuration-processor")
 }
 
 tasks.withType<KotlinCompile> {
-	kotlinOptions {
-		freeCompilerArgs += "-Xjsr305=strict"
-		jvmTarget = "17"
-	}
+    kotlinOptions {
+        freeCompilerArgs += "-Xjsr305=strict"
+        jvmTarget = "17"
+    }
 }
 
 tasks.withType<Test> {
-	useJUnitPlatform()
+    useJUnitPlatform()
 }
 
 tasks.processResources {
-	dependsOn("initConfig")
+    dependsOn("initConfig")
 }
 
 tasks.register<Copy>("initConfig") {
-	from("./CONFIG")
-	include("*.yml")
-	into("./src/main/resources")
+    from("./CONFIG")
+    include("*.yml")
+    into("./src/main/resources")
 }
 
 jib {
-	from {
-		image = "amazoncorretto:17-alpine3.18"
-	}
-	to {
-		image = repoURL
-		tags = setOf(imageTag)
-	}
-	container {
-		jvmFlags = listOf(
-			"-Dspring.profiles.active=${activeProfile}",
-			"-Dserver.port=8080",
-			"-XX:+UseContainerSupport",
-		)
-		ports = listOf("8080")
-	}
+    from {
+        image = "amazoncorretto:17-alpine3.18"
+    }
+    to {
+        image = repoURL
+        tags = setOf(imageTag)
+    }
+    container {
+        jvmFlags = listOf(
+                "-Dspring.profiles.active=${activeProfile}",
+                "-Dserver.port=8080",
+                "-XX:+UseContainerSupport",
+        )
+        ports = listOf("8080")
+    }
 }

src/main/kotlin/com/vacgom/backend/application/auth/AuthFactory.kt

@@ -0,0 +1,30 @@
+package com.vacgom.backend.application.auth
+
+import com.vacgom.backend.domain.auth.oauth.OauthConnector
+import com.vacgom.backend.domain.auth.oauth.OauthUriGenerator
+import com.vacgom.backend.domain.auth.oauth.constants.ProviderType
+import com.vacgom.backend.global.exception.error.BusinessException
+import com.vacgom.backend.global.security.exception.AuthError
+import org.springframework.stereotype.Component
+
+@Component
+class AuthFactory(
+        private val connectors: List<OauthConnector>,
+        private val uriProviders: List<OauthUriGenerator>
+) {
+    fun getAuthConnector(provider: String): OauthConnector {
+        val providerType = ProviderType.from(provider)
+
+        return connectors.firstOrNull {
+            it.isSupported(providerType)
+        } ?: throw BusinessException(AuthError.UNSUPPORTED_PROVIDER)
+    }
+
+    fun getAuthUriGenerator(provider: String): OauthUriGenerator {
+        val providerType = ProviderType.from(provider)
+
+        return uriProviders.firstOrNull {
+            it.isSupported(providerType)
+        } ?: throw BusinessException(AuthError.UNSUPPORTED_PROVIDER)
+    }
+}

src/main/kotlin/com/vacgom/backend/application/auth/AuthService.kt

@@ -0,0 +1,55 @@
+package com.vacgom.backend.application.auth
+
+import com.vacgom.backend.application.auth.dto.LoginResponse
+import com.vacgom.backend.application.auth.dto.MemberResponse
+import com.vacgom.backend.application.auth.dto.TokenResponse
+import com.vacgom.backend.domain.auth.constants.Role.ROLE_TEMP_USER
+import com.vacgom.backend.domain.auth.oauth.constants.ProviderType
+import com.vacgom.backend.domain.member.Member
+import com.vacgom.backend.global.security.jwt.JwtService
+import com.vacgom.backend.infrastructure.member.persistence.MemberRepository
+import jakarta.transaction.Transactional
+import org.springframework.http.HttpHeaders
+import org.springframework.stereotype.Component
+import java.net.URI
+
+@Component
+class AuthService(
+        private val authFactory: AuthFactory,
+        private val jwtService: JwtService,
+        private val memberRepository: MemberRepository
+) {
+    fun createRedirectHeaders(redirectUri: URI): HttpHeaders {
+        val headers = HttpHeaders()
+        headers.location = redirectUri
+        return headers
+    }
+
+    fun getAuthorizationUri(provider: String): URI {
+        return authFactory.getAuthUriGenerator(provider).generate()
+    }
+
+    @Transactional
+    fun login(
+            providerType: String,
+            code: String
+    ): LoginResponse {
+        val authConnector = authFactory.getAuthConnector(providerType)
+        val oauthToken = authConnector.fetchOauthToken(code)
+        val memberInfo = authConnector.fetchMemberInfo(oauthToken.accessToken)
+        val member = findOrCreateMember(memberInfo.id, ProviderType.from(providerType))
+
+        val memberResponse = MemberResponse(member.id!!, member.role)
+        val tokenResponse = TokenResponse(jwtService.createAccessToken(member))
+
+        return LoginResponse(memberResponse, tokenResponse)
+    }
+
+    private fun findOrCreateMember(
+            kakaoProviderId: Long,
+            providerType: ProviderType
+    ): Member {
+        return memberRepository.findByProviderIdAndProviderType(kakaoProviderId, providerType)
+                ?: memberRepository.save(Member(kakaoProviderId, providerType, ROLE_TEMP_USER))
+    }
+}

src/main/kotlin/com/vacgom/backend/application/auth/dto/LoginResponse.kt

@@ -0,0 +1,6 @@
+package com.vacgom.backend.application.auth.dto
+
+data class LoginResponse(
+        val member: MemberResponse,
+        val token: TokenResponse
+)

src/main/kotlin/com/vacgom/backend/application/auth/dto/MemberResponse.kt

@@ -0,0 +1,9 @@
+package com.vacgom.backend.application.auth.dto
+
+import com.vacgom.backend.domain.auth.constants.Role
+import java.util.*
+
+data class MemberResponse(
+        val memberId: UUID,
+        val role: Role
+)

src/main/kotlin/com/vacgom/backend/application/auth/dto/OauthTokenResponse.kt

@@ -0,0 +1,7 @@
+package com.vacgom.backend.application.auth.dto
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies
+import com.fasterxml.jackson.databind.annotation.JsonNaming
+
+@JsonNaming(value = PropertyNamingStrategies.SnakeCaseStrategy::class)
+data class OauthTokenResponse(val accessToken: String)

src/main/kotlin/com/vacgom/backend/application/auth/dto/ResourceIdResponse.kt

@@ -0,0 +1,5 @@
+package com.vacgom.backend.application.auth.dto
+
+data class ResourceIdResponse(
+        var id: Long
+)

src/main/kotlin/com/vacgom/backend/application/auth/dto/TokenResponse.kt

@@ -0,0 +1,6 @@
+package com.vacgom.backend.application.auth.dto
+
+
+data class TokenResponse(
+        val accessToken: String
+)

src/main/kotlin/com/vacgom/backend/domain/auth/RefreshToken.kt

@@ -0,0 +1,24 @@
+package com.vacgom.backend.domain.auth
+
+import com.vacgom.backend.domain.member.Member
+import com.vacgom.backend.global.auditing.BaseEntity
+import jakarta.persistence.*
+import java.time.LocalDateTime
+
+
+@Entity
+@Table(name = "t_refresh_token")
+class RefreshToken(
+        @ManyToOne(fetch = FetchType.LAZY)
+        @JoinColumn(name = "member_id", nullable = false)
+        var member: Member,
+        var token: String,
+        var userAgent: String,
+        var expiredAt: LocalDateTime
+) : BaseEntity() {
+    @Id
+    @GeneratedValue
+    @Column(name = "rt_id")
+    private val id: Long? = null
+}
+

src/main/kotlin/com/vacgom/backend/domain/auth/constants/Role.kt

@@ -0,0 +1,19 @@
+package com.vacgom.backend.domain.auth.constants
+
+enum class Role {
+    ROLE_GUEST,
+    ROLE_TEMP_USER,
+    ROLE_USER;
+
+    fun isGuest(role: Role): Boolean {
+        return role == ROLE_GUEST
+    }
+
+    fun isTempUser(role: Role): Boolean {
+        return role == ROLE_TEMP_USER
+    }
+
+    fun isUser(role: Role): Boolean {
+        return role == ROLE_USER
+    }
+}

src/main/kotlin/com/vacgom/backend/domain/auth/oauth/OauthConnector.kt

@@ -0,0 +1,11 @@
+package com.vacgom.backend.domain.auth.oauth
+
+import com.vacgom.backend.application.auth.dto.OauthTokenResponse
+import com.vacgom.backend.application.auth.dto.ResourceIdResponse
+import com.vacgom.backend.domain.auth.oauth.constants.ProviderType
+
+interface OauthConnector {
+    fun isSupported(provider: ProviderType): Boolean
+    fun fetchOauthToken(code: String): OauthTokenResponse
+    fun fetchMemberInfo(accessToken: String): ResourceIdResponse
+}

src/main/kotlin/com/vacgom/backend/domain/auth/oauth/OauthUriGenerator.kt

@@ -0,0 +1,9 @@
+package com.vacgom.backend.domain.auth.oauth
+
+import com.vacgom.backend.domain.auth.oauth.constants.ProviderType
+import java.net.URI
+
+interface OauthUriGenerator {
+    fun isSupported(provider: ProviderType): Boolean
+    fun generate(): URI
+}

src/main/kotlin/com/vacgom/backend/domain/auth/oauth/constants/ProviderType.kt

@@ -0,0 +1,19 @@
+package com.vacgom.backend.domain.auth.oauth.constants
+
+import com.vacgom.backend.global.exception.error.BusinessException
+import com.vacgom.backend.global.security.exception.AuthError
+
+enum class ProviderType(val provider: String) {
+    KAKAO("kakao");
+
+    companion object {
+        fun from(provider: String): ProviderType {
+            return entries.firstOrNull { it.provider == provider }
+                    ?: throw BusinessException(AuthError.UNSUPPORTED_PROVIDER)
+        }
+    }
+
+    fun isKakao(): Boolean {
+        return this == KAKAO
+    }
+}

src/main/kotlin/com/vacgom/backend/domain/member/Member.kt

@@ -1,21 +1,25 @@
 package com.vacgom.backend.domain.member
 
+import com.vacgom.backend.domain.auth.constants.Role
+import com.vacgom.backend.domain.auth.oauth.constants.ProviderType
 import com.vacgom.backend.global.auditing.BaseEntity
 import jakarta.persistence.*
+import org.hibernate.annotations.GenericGenerator
+import java.util.*
 
 @Entity
 @Table(name = "t_member")
-class Member(nickname: String) : BaseEntity() {
+class Member(
+        var providerId: Long,
+        @Enumerated(EnumType.STRING) var providerType: ProviderType,
+        @Enumerated(EnumType.STRING) var role: Role,
+) : BaseEntity() {
 
     @Id
-    @Column(name = "member_id")
-    @GeneratedValue(strategy = GenerationType.IDENTITY)
-    var id: Long? = null
+    @GeneratedValue(generator = "uuid2")
+    @GenericGenerator(name = "uuid2", strategy = "uuid2")
+    @Column(columnDefinition = "BINARY(16)", name = "member_id")
+    val id: UUID? = null
 
-    @Column(name = "nickname")
-    val nickname: String
-
-    init {
-        this.nickname = nickname
-    }
+    var name: String? = null
 }

src/main/kotlin/com/vacgom/backend/exception/member/MemberError.kt

@@ -0,0 +1,13 @@
+package com.vacgom.backend.exception.member
+
+import com.vacgom.backend.global.exception.error.ErrorCode
+import org.springframework.http.HttpStatus
+
+
+enum class MemberError(
+        override val message: String,
+        override val status: HttpStatus,
+        override val code: String
+) : ErrorCode {
+    NOT_FOUND("사용자를 찾을 수 없습니다.", HttpStatus.NOT_FOUND, "M_001"),
+}