Merge pull request #105 from Review-zip/dev

[Feat] 카카오 소셜로그인

build.gradle

@@ -44,6 +44,7 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-oauth2-client'
 	implementation 'io.jsonwebtoken:jjwt:0.9.1' // 자바 jwt 라이브러리
 	implementation 'io.jsonwebtoken:jjwt-api:0.11.2'
+	annotationProcessor "org.springframework.boot:spring-boot-configuration-processor"
 	implementation 'javax.xml.bind:jaxb-api:2.3.1' // XML 문서와 Java 객체 간 매핑을 자동화
 	implementation 'org.springframework.cloud:spring-cloud-starter-aws:2.2.6.RELEASE' // aws s3
 

src/main/java/com/example/ReviewZIP/domain/follow/Follows.java

@@ -3,13 +3,13 @@
 import com.example.ReviewZIP.domain.user.Users;
 import com.example.ReviewZIP.global.entity.BaseEntity;
 import jakarta.persistence.*;
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-import lombok.Setter;
+import lombok.*;
 
 @Entity
 @Getter
 @Setter
+@Builder
+@AllArgsConstructor
 @NoArgsConstructor
 @Table(name = "follows")
 public class Follows extends BaseEntity {

src/main/java/com/example/ReviewZIP/domain/follow/FollowsController.java

@@ -0,0 +1,52 @@
+package com.example.ReviewZIP.domain.follow;
+
+import com.example.ReviewZIP.global.response.ApiResponse;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.Parameters;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.responses.ApiResponses;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/v1/follows")
+public class FollowsController {
+    private final FollowsService followsService;
+
+    @PostMapping("/users/{userId}")
+    @Operation(summary = "유저 팔로우 하기 API",description = "유저의 id를 받아 해당 유저 팔로우")
+    @ApiResponses({
+            @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "COMMON200",description = "OK, 성공"),
+            @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "USER404", description = "팔로우 할 유저가 존재하지 않습니다",content = @Content(schema = @Schema(implementation = ApiResponse.class))),
+    })
+    @Parameters({
+            @Parameter(name = "userId", description = "팔로우할 유저의 아이디"),
+    })
+    public ApiResponse<Void> follow(@PathVariable(name="userId") Long userId) {
+        Follows follows = followsService.createFollowing(userId);
+
+        return ApiResponse.onSuccess(null);
+    }
+
+    @DeleteMapping("/users/{userId}")
+    @Operation(summary = " 유저 언팔로우 하기 API",description = "유저의 id를 받아 해당 유저 언팔로우")
+    @ApiResponses({
+            @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "COMMON200",description = "OK, 성공"),
+            @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "USER404", description = "언팔로우 할 유저가 존재하지 않습니다",content = @Content(schema = @Schema(implementation = ApiResponse.class))),
+    })
+    @Parameters({
+            @Parameter(name = "userId", description = "팔로우 취소할 유저의 아이디"),
+    })
+    public ApiResponse<Void> unfollowUser(@PathVariable(name="userId")Long userId){
+        followsService.unfollowUser(userId);
+
+        return ApiResponse.onSuccess(null);
+    }
+}

src/main/java/com/example/ReviewZIP/domain/follow/FollowsConverter.java

@@ -0,0 +1,13 @@
+package com.example.ReviewZIP.domain.follow;
+
+import com.example.ReviewZIP.domain.user.Users;
+
+public class FollowsConverter {
+    public static Follows toFollows(Users sender, Users receiver){
+        return Follows.builder()
+                .sender(sender)
+                .receiver(receiver)
+                .build();
+    }
+
+}

src/main/java/com/example/ReviewZIP/domain/follow/FollowsRepository.java

@@ -6,8 +6,11 @@
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 
+
 @Repository
 public interface FollowsRepository extends JpaRepository<Follows, Long> {
     Page<Follows> findAllBySender(Users sender, PageRequest pageRequest);
     Page<Follows> findAllByReceiver(Users user, PageRequest pageRequest);
+
+    Follows getBySenderAndReceiver(Users sender, Users receiver);
 }

src/main/java/com/example/ReviewZIP/domain/follow/FollowsService.java

@@ -0,0 +1,38 @@
+package com.example.ReviewZIP.domain.follow;
+
+
+import com.example.ReviewZIP.domain.user.Users;
+import com.example.ReviewZIP.domain.user.UsersRepository;
+import com.example.ReviewZIP.global.response.code.resultCode.ErrorStatus;
+import com.example.ReviewZIP.global.response.exception.handler.UsersHandler;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+public class FollowsService {
+    private final FollowsRepository followsRepository;
+    private final UsersRepository usersRepository;
+
+
+    @Transactional
+    public Follows createFollowing(Long userId) {
+        Users sender = usersRepository.getById(1L);
+        Users receiver = usersRepository.findById(userId).orElseThrow(() -> new UsersHandler(ErrorStatus.USER_NOT_FOUND));
+
+        Follows newFollow = FollowsConverter.toFollows(sender, receiver);
+        return followsRepository.save(newFollow);
+    }
+
+    @Transactional
+    public void unfollowUser(Long userId){
+        Users sender = usersRepository.findById(1L).orElseThrow(()->new UsersHandler(ErrorStatus.USER_NOT_FOUND));
+        Users receiver = usersRepository.findById(userId).orElseThrow(()->new  UsersHandler(ErrorStatus.USER_NOT_FOUND));
+
+        Follows unfollow = followsRepository.getBySenderAndReceiver(sender, receiver);
+
+        followsRepository.delete(unfollow);
+    }
+}

src/main/java/com/example/ReviewZIP/domain/jwt/JwtProperties.java

@@ -0,0 +1,20 @@
+package com.example.ReviewZIP.domain.jwt;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Getter
+@Setter
+@Component
+@ConfigurationProperties("jwt")
+public class JwtProperties {
+    @Value("${jwt.issuer}")
+    private String issuer;
+
+    @Value("${jwt.secretKey}")
+    private String secretKey;
+}

src/main/java/com/example/ReviewZIP/domain/jwt/TokenProvider.java

@@ -0,0 +1,54 @@
+package com.example.ReviewZIP.domain.jwt;
+
+import io.jsonwebtoken.Claims;
+import io.jsonwebtoken.Header;
+import io.jsonwebtoken.Jwts;
+import io.jsonwebtoken.SignatureAlgorithm;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+@RequiredArgsConstructor
+@Service
+public class TokenProvider {
+    private final JwtProperties jwtProperties;
+
+    public String makeToken(Long userId){
+        Date now = new Date();
+        Date exp = new Date(now.getTime() + 3600000); //1시간 만료 기준
+        Claims claims = Jwts.claims();
+        claims.put("userid", userId);
+
+        return Jwts.builder()
+                .setHeaderParam(Header.TYPE, Header.JWT_TYPE)
+                .setIssuer(jwtProperties.getIssuer())
+                .setIssuedAt(now)
+                .setExpiration(exp)
+                .setClaims(claims)
+                //.setSubject(userId.toString())
+                .signWith(SignatureAlgorithm.HS256, jwtProperties.getSecretKey())
+                .compact();
+    }
+
+    public Long getUserId(String token){
+        Claims claims = Jwts.parser()
+                .setSigningKey(jwtProperties.getSecretKey())
+                .parseClaimsJws(token)
+                .getBody();
+        return claims.get("userId", Long.class);
+    }
+
+    public boolean validToken(String token){
+        try{
+            Jwts.parser()
+                    .setSigningKey(jwtProperties.getSecretKey())
+                    .parseClaimsJws(token);
+            return true;
+        } catch(Exception e){
+            return false;
+        }
+    }
+
+
+}

src/main/java/com/example/ReviewZIP/domain/oauth/KakaoController.java

@@ -0,0 +1,29 @@
+package com.example.ReviewZIP.domain.oauth;
+
+import com.example.ReviewZIP.domain.jwt.TokenProvider;
+import com.example.ReviewZIP.domain.oauth.dto.request.OauthRequestDto;
+import com.example.ReviewZIP.global.response.ApiResponse;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/v1/oauth")
+public class KakaoController {
+
+    private final OauthService oauthService;
+
+    // 유저 관련 token 받은 후 해당 정보로 accessToken 발급
+    @PostMapping("/kakao")
+    public ApiResponse<Map<String, Object>> sendAccessToken(@RequestBody OauthRequestDto.kakaoTokenRequest request) throws JsonProcessingException {
+
+        List<String> kakaoUserInfoList = oauthService.getKakaoUserInfo(request);
+
+        return ApiResponse.onSuccess(oauthService.generateAccessToken(kakaoUserInfoList.get(0),kakaoUserInfoList.get(1) , kakaoUserInfoList.get(2)));
+
+    }
+}

src/main/java/com/example/ReviewZIP/domain/oauth/OauthService.java

@@ -0,0 +1,92 @@
+package com.example.ReviewZIP.domain.oauth;
+
+import com.example.ReviewZIP.domain.jwt.TokenProvider;
+import com.example.ReviewZIP.domain.oauth.dto.request.OauthRequestDto;
+import com.example.ReviewZIP.domain.user.Users;
+import com.example.ReviewZIP.domain.user.UsersRepository;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.*;
+
+@Service
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+public class OauthService {
+    private final UsersRepository usersRepository;
+    private final TokenProvider tokenProvider;
+
+    @Transactional
+    public Long createUser(String id, String nickname, String email){
+        Users newUser = Users.builder()
+                .social(id)
+                .nickname(nickname)
+                .name(nickname)
+                .email(email)
+                .build();
+        usersRepository.save(newUser);
+
+        return newUser.getId();
+    }
+
+    @Transactional
+    public Map<String, Object> generateAccessToken(String id, String nickname, String email){
+        boolean exist = usersRepository.existsBySocial(id);
+        Long userId;
+
+        if(!exist) {
+            // 유저가 존재하지 않을때 -> 유저 생성
+            userId = createUser(id, nickname, email);
+        } else {
+            // 존재할 경우 해당 유저의 userId 반환
+            userId = usersRepository.getBySocial(id).getId();
+        }
+
+        String accessToken = tokenProvider.makeToken(userId);
+
+        Map<String, Object> map = new LinkedHashMap<>();
+        map.put("accessToken", accessToken);
+
+        return map;
+    }
+
+    public List<String> getKakaoUserInfo(OauthRequestDto.kakaoTokenRequest request) throws JsonProcessingException {
+        String token = request.getToken();
+
+        HttpHeaders headers = new HttpHeaders();
+        headers.set("Content-type", "application/x-www-form-urlencoded;charset=utf-8");
+        headers.set("Authorization", "Bearer " + token);
+
+        HttpEntity<MultiValueMap<String, String>> kakaoProfileRequest = new HttpEntity<>(null, headers);
+
+        RestTemplate restTemplate = new RestTemplate();
+
+        ResponseEntity<String> response = restTemplate.exchange(
+                "https://kapi.kakao.com/v2/user/me",
+                HttpMethod.POST,
+                kakaoProfileRequest,
+                String.class
+        );
+
+        ObjectMapper objectMapper = new ObjectMapper();
+        String responseBody = response.getBody();
+        JsonNode jsonNode = objectMapper.readTree(responseBody);
+        String id = jsonNode.get("id").asText();
+        String nickname = jsonNode.get("properties").get("nickname").asText();
+        String email = jsonNode.get("kakao_account").get("email").asText();
+
+        List<String> kakaoUserInfoList = Arrays.asList(id, nickname, email);
+
+        return kakaoUserInfoList;
+    }
+}

src/main/java/com/example/ReviewZIP/domain/oauth/dto/Response/OauthResponseDto.java

@@ -0,0 +1,9 @@
+package com.example.ReviewZIP.domain.oauth.dto.Response;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.*;
+
+
+public class OauthResponseDto {
+
+}

src/main/java/com/example/ReviewZIP/domain/oauth/dto/request/OauthRequestDto.java

@@ -0,0 +1,12 @@
+package com.example.ReviewZIP.domain.oauth.dto.request;
+
+import lombok.Getter;
+
+
+public class OauthRequestDto {
+
+    @Getter
+    public static class kakaoTokenRequest{
+        String token;
+    }
+}

src/main/java/com/example/ReviewZIP/domain/post/Posts.java

@@ -7,6 +7,7 @@
 import com.example.ReviewZIP.domain.store.Stores;
 import com.example.ReviewZIP.domain.user.Users;
 import com.example.ReviewZIP.global.entity.BaseEntity;
+
 import jakarta.persistence.*;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
@@ -21,6 +22,7 @@
 @NoArgsConstructor
 @Table(name = "posts")
 public class Posts extends BaseEntity {
+
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     @Column(name = "id")

src/main/java/com/example/ReviewZIP/domain/post/PostsController.java

@@ -32,7 +32,7 @@ public class PostsController {
     @Operation(summary = "특정 게시글의 정보 가져오기 API",description = "게시글의 id를 이용하여 상세정보 출력, UserInfoDto & ImageListDto & PostInfoDto 이용")
     @ApiResponses({
             @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "COMMON200",description = "OK, 성공"),
-            @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "POST401", description = "해당 게시물이 존재하지 않음",content = @Content(schema = @Schema(implementation = ApiResponse.class))),
+            @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "POST401", description = "해당 게시물이 존재하지 않습니다.",content = @Content(schema = @Schema(implementation = ApiResponse.class))),
     })
     @Parameters({
             @Parameter(name = "postId", description = "게시글의 아이디"),