Merge pull request #12 from team-xquare/138-github-oauth

Author: jaemin05

git-application/src/main/kotlin/com/xquare/git/git/exceptions/GitExceptions.kt

@@ -11,8 +11,11 @@ sealed class GitExceptions(
 
     class AlreadyExists(message: String = ALREADY_EXISTS) : GitExceptions(409, message)
 
+    class UnauthorizedToken(message: String = UNAUTHORIZED_TOKEN) : GitExceptions(401, message)
+
     companion object {
         private const val NOT_FOUND = "Not Found"
         private const val ALREADY_EXISTS = "Already Exists"
+        private const val UNAUTHORIZED_TOKEN = "Unauthorized Token"
     }
 }

git-application/src/main/kotlin/com/xquare/git/git/facade/GitFacade.kt

@@ -2,27 +2,31 @@ package com.xquare.git.git.facade
 
 import com.xquare.git.git.dto.FindAllUserResponse
 import com.xquare.git.git.dto.FindUserElement
-import com.xquare.git.git.usecase.CheckUsernameUseCase
 import com.xquare.git.git.usecase.FindAllGitUseCase
 import com.xquare.git.git.usecase.FindGitByCurrentUserIdUseCase
 import com.xquare.git.git.usecase.SaveUsernameUseCase
 import com.xquare.git.git.usecase.UpdateGitUseCase
+import com.xquare.git.github.usecase.GetGithubAccessTokenUseCase
+import com.xquare.git.github.usecase.GetGithubUserInfoUseCase
 import com.xquare.git.user.usecase.GetUserIdUseCase
 import org.springframework.stereotype.Component
 import org.springframework.transaction.annotation.Transactional
 
 @Component
 open class GitFacade(
     private val saveUsernameUseCase: SaveUsernameUseCase,
-    private val checkUsernameUseCase: CheckUsernameUseCase,
     private val findAllGitUseCase: FindAllGitUseCase,
     private val updateGitUseCase: UpdateGitUseCase,
     private val getUserIdUseCase: GetUserIdUseCase,
     private val findGitByCurrentUserId: FindGitByCurrentUserIdUseCase,
+    private val getGithubAccessTokenUseCase: GetGithubAccessTokenUseCase,
+    private val getGithubUserInfoUseCase: GetGithubUserInfoUseCase,
 ) {
-    open suspend fun saveUsername(currentUserId: String?, username: String) {
-        checkUsernameUseCase.execute(username)
+    open suspend fun saveUsername(currentUserId: String?, code: String) {
         val userId = getUserIdUseCase.execute(currentUserId)
+        val token = getGithubAccessTokenUseCase.execute(code)
+        val username = getGithubUserInfoUseCase.execute(token)
+
         saveUsernameUseCase.execute(userId, username)
     }
 

git-application/src/main/kotlin/com/xquare/git/github/dto/GetGithubUserInfoResponse.kt

@@ -0,0 +1,5 @@
+package com.xquare.git.github.dto
+
+data class GetGithubUserInfoResponse(
+    val login: String?,
+)

git-application/src/main/kotlin/com/xquare/git/github/dto/TokenResponse.kt

@@ -0,0 +1,8 @@
+package com.xquare.git.github.dto
+
+import com.fasterxml.jackson.annotation.JsonProperty
+
+data class TokenResponse(
+    @JsonProperty("access_token")
+    val accessToken: String?,
+)

git-application/src/main/kotlin/com/xquare/git/github/spi/GithubPort.kt

@@ -0,0 +1,3 @@
+package com.xquare.git.github.spi
+
+interface GithubPort : QueryGithubPort

git-application/src/main/kotlin/com/xquare/git/github/spi/QueryGithubPort.kt

@@ -0,0 +1,9 @@
+package com.xquare.git.github.spi
+
+import com.xquare.git.github.dto.GetGithubUserInfoResponse
+import com.xquare.git.github.dto.TokenResponse
+
+interface QueryGithubPort {
+    suspend fun getAccessToken(code: String): TokenResponse
+    suspend fun getGithubUserInfo(token: String): GetGithubUserInfoResponse
+}

git-application/src/main/kotlin/com/xquare/git/github/usecase/GetGithubAccessTokenUseCase.kt

@@ -0,0 +1,15 @@
+package com.xquare.git.github.usecase
+
+import com.xquare.git.annotations.UseCase
+import com.xquare.git.git.exceptions.GitExceptions
+import com.xquare.git.github.spi.QueryGithubPort
+
+@UseCase
+class GetGithubAccessTokenUseCase(
+    private val queryGithubPort: QueryGithubPort,
+) {
+    suspend fun execute(code: String): String {
+        return queryGithubPort.getAccessToken(code).accessToken
+            ?: throw GitExceptions.UnauthorizedToken()
+    }
+}

git-application/src/main/kotlin/com/xquare/git/github/usecase/GetGithubUserInfoUseCase.kt

@@ -0,0 +1,15 @@
+package com.xquare.git.github.usecase
+
+import com.xquare.git.annotations.UseCase
+import com.xquare.git.git.exceptions.GitExceptions
+import com.xquare.git.github.spi.QueryGithubPort
+
+@UseCase
+class GetGithubUserInfoUseCase(
+    private val queryGithubPort: QueryGithubPort,
+) {
+    suspend fun execute(token: String): String {
+        return queryGithubPort.getGithubUserInfo(token).login
+            ?: throw GitExceptions.NotFound()
+    }
+}

git-infrastructure/src/main/kotlin/com/xquare/git/persistence/github/spi/GithubPersistenceAdapter.kt

@@ -0,0 +1,51 @@
+package com.xquare.git.persistence.github.spi
+
+import com.xquare.git.github.dto.GetGithubUserInfoResponse
+import com.xquare.git.github.dto.TokenResponse
+import com.xquare.git.github.spi.GithubPort
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.http.MediaType
+import org.springframework.stereotype.Component
+import org.springframework.web.reactive.function.client.WebClient
+import org.springframework.web.reactive.function.client.awaitBody
+
+@Component
+class GithubPersistenceAdapter(
+    private val webClient: WebClient,
+
+    @Value("\${auth.github.client-id}")
+    private val clientId: String,
+
+    @Value("\${auth.github.client-secret}")
+    private val clientSecret: String,
+) : GithubPort {
+    override suspend fun getAccessToken(code: String): TokenResponse {
+        return webClient.get()
+            .uri {
+                it.scheme("https")
+                    .host("github.com")
+                    .path("/login/oauth/access_token")
+                    .queryParam("client_id", clientId)
+                    .queryParam("client_secret", clientSecret)
+                    .queryParam("code", code)
+                    .build()
+            }
+            .accept(MediaType.APPLICATION_JSON)
+            .retrieve()
+            .awaitBody()
+    }
+
+    override suspend fun getGithubUserInfo(token: String): GetGithubUserInfoResponse {
+        return webClient.get()
+            .uri {
+                it.scheme("https")
+                    .host("api.github.com")
+                    .path("/user")
+                    .build()
+            }
+            .header("Authorization", "token $token")
+            .accept(MediaType.APPLICATION_JSON)
+            .retrieve()
+            .awaitBody()
+    }
+}

git-presentation/src/main/kotlin/com/xquare/git/GitHandler.kt

@@ -16,8 +16,8 @@ class GitHandler(
     ) {
     suspend fun saveUsername(serverRequest: ServerRequest): ServerResponse {
         val currentUserId = serverRequest.headers().firstHeader("Request-User-Id")
-        val username = serverRequest.queryParam("username").orElse("")
-        gitFacade.saveUsername(currentUserId, username)
+        val code = serverRequest.queryParam("code").orElse("")
+        gitFacade.saveUsername(currentUserId, code)
 
         return ServerResponse.created(URI("/gits")).buildAndAwait()
     }