Feat/#14 user setting

src/main/java/com/teamEWSN/gitdeun/common/exception/ErrorCode.java

@@ -23,6 +23,7 @@ public enum ErrorCode {
     USER_NOT_FOUND_BY_EMAIL(HttpStatus.NOT_FOUND, "ACCOUNT-002", "해당 이메일의 회원을 찾을 수 없습니다."),
     ACCOUNT_ALREADY_LINKED(HttpStatus.CONFLICT, "ACCOUNT-003", "이미 다른 사용자와 연동된 소셜 계정입니다."),
     SOCIAL_CONNECTION_NOT_FOUND(HttpStatus.NOT_FOUND, "ACCOUNT-004", "연동된 소셜 계정 정보를 찾을 수 없습니다."),
+    USER_SETTING_NOT_FOUND_BY_ID(HttpStatus.NOT_FOUND, "ACCOUNT-005", "해당 아이디의 설정을 찾을 수 없습니다."),
 
     // 소셜 로그인 관련
     OAUTH_PROCESSING_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, "OAUTH-001", "소셜 로그인 처리 중 오류가 발생했습니다."),
@@ -31,7 +32,7 @@ public enum ErrorCode {
     OAUTH_COMMUNICATION_FAILED(HttpStatus.BAD_GATEWAY, "OAUTH-004", "소셜 플랫폼과의 통신에 실패했습니다."),
     SOCIAL_TOKEN_REFRESH_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "OAUTH-005", "소셜 플랫폼의 토큰 갱신에 실패했습니다."),
     SOCIAL_ACCOUNT_CONNECT_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "OAUTH-006", "소셜 계정 연동에 실패했습니다."),
-    GITHUB_TOKEN_REFRESH_NOT_SUPPORTED(HttpStatus.BAD_REQUEST, "OAUTH-007", "GitHub 토큰 갱신은 지원하지 않습니다. 재인증이 필요합니다."),
+    SOCIAL_TOKEN_REFRESH_NOT_SUPPORTED(HttpStatus.BAD_REQUEST, "OAUTH-007", "리프레시 토큰 갱신은 지원하지 않습니다. 재인증이 필요합니다."),
 
     // S3 파일 관련
     // Client Errors (4xx)

src/main/java/com/teamEWSN/gitdeun/common/oauth/entity/CustomOAuth2User.java → src/main/java/com/teamEWSN/gitdeun/common/oauth/dto/CustomOAuth2User.java

@@ -1,4 +1,4 @@
-package com.teamEWSN.gitdeun.common.oauth.entity;
+package com.teamEWSN.gitdeun.common.oauth.dto;
 
 import com.teamEWSN.gitdeun.user.entity.Role;
 import lombok.Getter;

src/main/java/com/teamEWSN/gitdeun/common/oauth/dto/GitHubEmailDto.java

@@ -0,0 +1,17 @@
+package com.teamEWSN.gitdeun.common.oauth.dto;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class GitHubEmailDto {
+
+    private String email;
+    private boolean primary;
+    private boolean verified;
+    private String visibility;
+}

src/main/java/com/teamEWSN/gitdeun/common/oauth/entity/SocialConnection.java

@@ -1,7 +1,7 @@
 package com.teamEWSN.gitdeun.common.oauth.entity;
 
 import com.teamEWSN.gitdeun.common.converter.CryptoConverter;
-import com.teamEWSN.gitdeun.common.util.BaseEntity;
+import com.teamEWSN.gitdeun.common.util.AuditedEntity;
 import com.teamEWSN.gitdeun.user.entity.User;
 import jakarta.persistence.*;
 import lombok.*;
@@ -10,7 +10,7 @@
 @Getter
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 @Table(name = "social_connection")
-public class SocialConnection extends BaseEntity {
+public class SocialConnection extends AuditedEntity {
 
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)

src/main/java/com/teamEWSN/gitdeun/common/oauth/handler/CustomOAuth2SuccessHandler.java

@@ -3,16 +3,18 @@
 import com.teamEWSN.gitdeun.common.cookie.CookieUtil;
 import com.teamEWSN.gitdeun.common.jwt.JwtToken;
 import com.teamEWSN.gitdeun.common.jwt.JwtTokenProvider;
-import com.teamEWSN.gitdeun.common.oauth.entity.CustomOAuth2User;
+import com.teamEWSN.gitdeun.common.oauth.service.OAuthStateService;
+import com.teamEWSN.gitdeun.user.service.AuthService;
 import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpServletResponse;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.security.core.Authentication;
+import org.springframework.security.oauth2.client.authentication.OAuth2AuthenticationToken;
+import org.springframework.security.oauth2.core.user.OAuth2User;
 import org.springframework.security.web.authentication.SimpleUrlAuthenticationSuccessHandler;
 import org.springframework.stereotype.Component;
-import org.springframework.web.util.UriComponentsBuilder;
 
 import java.io.IOException;
 
@@ -22,26 +24,31 @@
 public class CustomOAuth2SuccessHandler extends SimpleUrlAuthenticationSuccessHandler {
 
     private final JwtTokenProvider jwtTokenProvider;
+    private final OAuthStateService oAuthStateService;
+    private final AuthService authService;
     private final CookieUtil cookieUtil;
 
     @Value("${app.front-url}")
     private String frontUrl;
 
     @Override
     public void onAuthenticationSuccess(HttpServletRequest request, HttpServletResponse response, Authentication authentication) throws IOException {
-
-        // 우리 서비스의 JWT 생성
+        OAuth2AuthenticationToken authToken = (OAuth2AuthenticationToken) authentication;
+        OAuth2User oAuth2User = (OAuth2User) authentication.getPrincipal();
+        String state = request.getParameter("state");
+
+        String purpose = oAuthStateService.consumeState(state); // "connect:42" 또는 null
+        if (purpose != null && purpose.startsWith("connect:")) {
+            Long userId = Long.parseLong(purpose.split(":")[1]);
+            authService.connectGithubAccount(oAuth2User, userId);
+            response.sendRedirect(frontUrl + "/oauth/callback#connected=true");
+            return;
+        }
+
+        // 일반 로그인 흐름
         JwtToken jwtToken = jwtTokenProvider.generateToken(authentication);
-        log.info("JWT가 발급되었습니다. Access Token: {}", jwtToken.getAccessToken());
-
-        // Refresh Token은 HttpOnly 쿠키에 저장
         cookieUtil.setCookie(response, "refreshToken", jwtToken.getRefreshToken(), jwtTokenProvider.getRefreshTokenExpired());
-
-        // Access Token은 쿼리 파라미터로 프론트엔드에 전달
-        String targetUrl = UriComponentsBuilder.fromUriString(frontUrl + "/oauth/callback")
-            .queryParam("accessToken", jwtToken.getAccessToken())
-            .build().toUriString();
-
+        String targetUrl = frontUrl + "/oauth/callback#accessToken=" + jwtToken.getAccessToken();
         getRedirectStrategy().sendRedirect(request, response, targetUrl);
     }
 }

src/main/java/com/teamEWSN/gitdeun/common/oauth/record/GoogleTokenResponse.java

@@ -0,0 +1,12 @@
+package com.teamEWSN.gitdeun.common.oauth.record;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public record GoogleTokenResponse(
+    @JsonProperty("access_token") String accessToken,
+    @JsonProperty("refresh_token") String refreshToken,
+    @JsonProperty("token_type") String tokenType,
+    @JsonProperty("expires_in") Long expiresIn,
+    @JsonProperty("scope") String scope,
+    @JsonProperty("id_token") String idToken
+) {}

src/main/java/com/teamEWSN/gitdeun/common/oauth/service/CustomOAuth2UserService.java

@@ -2,6 +2,7 @@
 
 import com.teamEWSN.gitdeun.common.exception.GlobalException;
 import com.teamEWSN.gitdeun.common.exception.ErrorCode;
+import com.teamEWSN.gitdeun.common.oauth.dto.GitHubEmailDto;
 import com.teamEWSN.gitdeun.common.oauth.dto.provider.GitHubResponseDto;
 import com.teamEWSN.gitdeun.common.oauth.dto.provider.GoogleResponseDto;
 import com.teamEWSN.gitdeun.common.oauth.dto.provider.OAuth2ResponseDto;
@@ -11,7 +12,7 @@
 import com.teamEWSN.gitdeun.user.entity.User;
 import com.teamEWSN.gitdeun.common.oauth.repository.SocialConnectionRepository;
 import com.teamEWSN.gitdeun.user.repository.UserRepository;
-import com.teamEWSN.gitdeun.common.oauth.entity.CustomOAuth2User;
+import com.teamEWSN.gitdeun.common.oauth.dto.CustomOAuth2User;
 import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -21,6 +22,8 @@
 import org.springframework.security.oauth2.core.user.OAuth2User;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+import java.util.Map;
 import java.util.UUID;
 
 
@@ -29,6 +32,8 @@
 @RequiredArgsConstructor
 public class CustomOAuth2UserService extends DefaultOAuth2UserService {
 
+    private final GitHubApiHelper gitHubApiHelper;
+    private final SocialTokenRefreshService socialTokenRefreshService;
     private final UserRepository userRepository;
     private final SocialConnectionRepository socialConnectionRepository;
 
@@ -44,61 +49,68 @@ public OAuth2User loadUser(OAuth2UserRequest userRequest) throws OAuth2Authentic
             throw new GlobalException(ErrorCode.OAUTH_COMMUNICATION_FAILED);
         }
 
-        User user = processUserInTransaction(oAuth2User, userRequest);
+        User user = processUser(oAuth2User, userRequest);
         return new CustomOAuth2User(user.getId(), user.getRole());
     }
 
     // @Transactional
-    public User processUserInTransaction(OAuth2User oAuth2User, OAuth2UserRequest userRequest) {
-        OAuth2ResponseDto oAuth2ResponseDto = getOAuth2ResponseDto(oAuth2User, userRequest);
-
-        // 이메일 정보가 없는 경우 예외 처리 (GitHub 등)
-        if (oAuth2ResponseDto.getEmail() == null) {
-            throw new GlobalException(ErrorCode.EMAIL_NOT_PROVIDED);
-        }
-
-        OauthProvider provider = OauthProvider.valueOf(oAuth2ResponseDto.getProvider().toUpperCase());
-        String providerId = oAuth2ResponseDto.getProviderId();
-        String accessToken = userRequest.getAccessToken().getTokenValue();
+    public User processUser(OAuth2User oAuth2User, OAuth2UserRequest userRequest) {
+        OAuth2ResponseDto dto = getOAuth2ResponseDto(oAuth2User, userRequest);
+        OauthProvider provider = OauthProvider.valueOf(dto.getProvider().toUpperCase());
+        String providerId   = dto.getProviderId();
+        String accessToken  = userRequest.getAccessToken().getTokenValue();
         String refreshToken = (String) userRequest.getAdditionalParameters().get("refresh_token");
 
+        /* ② 이미 연결된 계정 → 토큰 갱신 로직 추상화  */
         return socialConnectionRepository.findByProviderAndProviderId(provider, providerId)
-            .map(connection -> {
-                log.info("기존 소셜 계정 정보를 업데이트합니다: {}", provider);
-                connection.updateTokens(accessToken, refreshToken);
-                return connection.getUser();
+            .map(conn -> {
+                // provider 별 refresh 정책
+                socialTokenRefreshService.refreshSocialToken(conn, accessToken, refreshToken);
+                return conn.getUser();
             })
-            .orElseGet(() -> {
-                // 다른 사용자가 이미 해당 이메일을 사용 중인지 확인
-                userRepository.findByEmailAndDeletedAtIsNull(oAuth2ResponseDto.getEmail())
-                    .ifPresent(existingUser -> {
-                        // 이메일은 같지만, 소셜 연동 정보가 없는 경우 -> 계정 연동
-                        log.info("기존 회원 계정에 소셜 계정을 연동합니다: {}", provider);
-                        connectSocialAccount(existingUser, provider, providerId, accessToken, refreshToken);
-                    });
-                // 위에서 연동했거나, 완전 신규 유저인 경우를 처리
-                // 다시 이메일로 조회하여 최종 유저를 반환하거나 새로 생성
-                return userRepository.findByEmailAndDeletedAtIsNull(oAuth2ResponseDto.getEmail())
-                    .orElseGet(() -> {
-                        log.info("신규 회원 및 소셜 계정을 생성합니다: {}", provider);
-                        return createNewUser(oAuth2ResponseDto, provider, providerId, accessToken, refreshToken);
-                    });
-            });
+            .orElseGet(() -> createOrConnect(dto, provider, providerId, accessToken, refreshToken));
     }
 
-    private static OAuth2ResponseDto getOAuth2ResponseDto(OAuth2User oAuth2User, OAuth2UserRequest userRequest) {
+    // OAuth2 공급자로부터 받은 사용자 정보를 기반으로 OAuth2ResponseDto를 생성(인스턴스 메서드)
+    private OAuth2ResponseDto getOAuth2ResponseDto(OAuth2User oAuth2User, OAuth2UserRequest userRequest) {
         String registrationId = userRequest.getClientRegistration().getRegistrationId();
+        Map<String, Object> attr = oAuth2User.getAttributes();
 
-        OAuth2ResponseDto oAuth2ResponseDto;
         if (registrationId.equalsIgnoreCase("google")) {
-            oAuth2ResponseDto = new GoogleResponseDto(oAuth2User.getAttributes());
-        } else if (registrationId.equalsIgnoreCase("github")) {
-            oAuth2ResponseDto = new GitHubResponseDto(oAuth2User.getAttributes());
+            return new GoogleResponseDto(attr);
+        }
+        if (registrationId.equalsIgnoreCase("github")) {
+            /* ① 기본 프로필에 e-mail 없으면 /user/emails 호출 */
+            if (attr.get("email") == null) {
+                // accessToken 으로 GitHub 보조 API 호출
+                List<GitHubEmailDto> emails =
+                    gitHubApiHelper.getPrimaryEmails(userRequest.getAccessToken().getTokenValue());
+                attr.put("email",
+                    emails.stream().filter(GitHubEmailDto::isPrimary)
+                        .findFirst().map(GitHubEmailDto::getEmail).orElse(null));
+            }
+            return new GitHubResponseDto(attr);
         } else {
             // 지원하지 않는 소셜 로그인 제공자
             throw new GlobalException(ErrorCode.UNSUPPORTED_OAUTH_PROVIDER);
         }
-        return oAuth2ResponseDto;
+    }
+
+    /**
+     * 사용자가 존재하면 계정을 연결하고, 존재하지 않으면 새로 생성합니다.
+     */
+    private User createOrConnect(OAuth2ResponseDto response, OauthProvider provider, String providerId, String accessToken, String refreshToken) {
+        // 이메일로 기존 사용자를 찾습니다.
+        return userRepository.findByEmailAndDeletedAtIsNull(response.getEmail())
+            .map(user -> {
+                // 사용자가 존재하면, 새 소셜 계정을 연결
+                connectSocialAccount(user, provider, providerId, accessToken, refreshToken);
+                return user;
+            })
+            .orElseGet(() -> {
+                // 사용자가 존재하지 않으면, 새 사용자를 생성
+                return createNewUser(response, provider, providerId, accessToken, refreshToken);
+            });
     }
 
     private User createNewUser(OAuth2ResponseDto response, OauthProvider provider, String providerId, String accessToken, String refreshToken) {

src/main/java/com/teamEWSN/gitdeun/common/oauth/service/GitHubApiHelper.java

@@ -2,21 +2,20 @@
 
 import com.teamEWSN.gitdeun.common.exception.ErrorCode;
 import com.teamEWSN.gitdeun.common.exception.GlobalException;
-import com.teamEWSN.gitdeun.common.oauth.dto.provider.GitHubResponseDto;
+import com.teamEWSN.gitdeun.common.oauth.dto.GitHubEmailDto;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.ParameterizedTypeReference;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.MediaType;
 import org.springframework.stereotype.Component;
-import org.springframework.util.LinkedMultiValueMap;
-import org.springframework.util.MultiValueMap;
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Mono;
 
 import java.nio.charset.StandardCharsets;
 import java.util.Base64;
+import java.util.List;
 import java.util.Map;
 
 @Slf4j
@@ -32,60 +31,28 @@ public class GitHubApiHelper {
     @Value("${spring.security.oauth2.client.registration.github.client-secret}")
     private String clientSecret;
 
-    @Value("${spring.security.oauth2.client.registration.github.redirect-uri}")
-    private String redirectUri;
 
     /**
-     * 인가 코드로 GitHub Access Token을 요청합니다.
-     * @param code GitHub에서 받은 인가 코드
-     * @return Access Token 문자열
-     */
-    public String getAccessToken(String code) {
-        String tokenUri = "https://github.com/login/oauth/access_token";
-
-        MultiValueMap<String, String> formData = new LinkedMultiValueMap<>();
-        formData.add("client_id", clientId);
-        formData.add("client_secret", clientSecret);
-        formData.add("code", code);
-        formData.add("redirect_uri", redirectUri);
-
-        Map<String, Object> response = webClient.post()
-            .uri(tokenUri)
-            .accept(MediaType.APPLICATION_JSON)
-            .bodyValue(formData)
-            .retrieve()
-            // 단순 map이 아닌 정확한 타입 정보를 런타임에도 잃어버리지 않도록 ParameterizedTypeReference를 사용
-            .bodyToMono(new ParameterizedTypeReference<Map<String, Object>>() {})
-            .block();
-
-        if (response == null || response.get("access_token") == null) {
-            log.error("GitHub Access Token 발급 실패: {}", response);
-            throw new GlobalException(ErrorCode.OAUTH_PROCESSING_ERROR);
-        }
-
-        return (String) response.get("access_token");
-    }
-
-    /**
-     * Access Token으로 GitHub 사용자 정보를 조회합니다.
+     * Access Token으로 사용자의 이메일 목록을 조회합니다.
+     * GitHub 기본 사용자 정보에 이메일이 포함되지 않은 경우 사용됩니다.
      * @param accessToken GitHub Access Token
-     * @return GitHub 사용자 정보를 담은 DTO
+     * @return 이메일 정보 DTO 리스트
      */
-    public GitHubResponseDto getUserInfo(String accessToken) {
-        String userInfoUri = "https://api.github.com/user";
+    public List<GitHubEmailDto> getPrimaryEmails(String accessToken) {
+        String emailsUri = "https://api.github.com/user/emails";
 
-        Map<String, Object> attributes = webClient.get()
-            .uri(userInfoUri)
-            .header(HttpHeaders.AUTHORIZATION, "token " + accessToken)
+        List<GitHubEmailDto> emails = webClient.get()
+            .uri(emailsUri)
+            .header(HttpHeaders.AUTHORIZATION, "Bearer " + accessToken)
             .retrieve()
-            .bodyToMono(new ParameterizedTypeReference<Map<String, Object>>() {})
+            .bodyToMono(new ParameterizedTypeReference<List<GitHubEmailDto>>() {})
             .block();
 
-        if (attributes == null) {
+        if (emails == null || emails.isEmpty()) {
+            log.error("GitHub 이메일 정보를 가져올 수 없습니다.");
             throw new GlobalException(ErrorCode.OAUTH_COMMUNICATION_FAILED);
         }
-
-        return new GitHubResponseDto(attributes);
+        return emails;
     }