자동화테스트

.github/CODEOWNERS

@@ -0,0 +1 @@
+*.java @gaaji/test

.github/PR_TEMPLATE.md

@@ -0,0 +1,30 @@
+# Issue# - Issue
+## Description
+> 
+
+## PR Type
+- [ ] Hotfix
+- [ ] Feature
+- [ ] Code style update
+- [ ] Refactor (code, package, etc.)
+- [ ] Build (gradle, spring, etc) 
+- [ ] Documentation content changes (api docs, etc.)
+- [ ] Infra (cloud, security, etc.)
+- [ ] Other... Please describe :
+
+## Related Issues
+- 
+
+## Issues
+
+### Test
+
+*** 
+
+## Related Files
+- `file`
+
+## Think About..  
+
+## Conclusion  
+> 

.github/workflows/ci.yml

@@ -0,0 +1,78 @@
+
+
+name: Java CI with Gradle
+
+on:
+  pull_request:
+
+
+permissions:
+  contents: read
+
+env:
+  DOCKER_IMAGE: ghcr.io/gaaji/auth-service
+  VERSION: ${{ github.sha }}
+
+
+jobs:
+  build:
+
+    runs-on: ubuntu-latest
+
+    steps:
+    - uses: actions/checkout@v3
+    - name: Set up JDK 17
+      uses: actions/setup-java@v3
+      with:
+        java-version: '17'
+        distribution: 'temurin'
+    - name: Create secret.yml
+      env:
+        SECRET_CODE: ${{ secrets.SECRET }}
+        SECRET_DIR: src/main/resources
+        SECRET_FILE_NAME: secret.yml
+      run: echo $SECRET_CODE | base64 --decode > $SECRET_DIR/$SECRET_FILE_NAME
+
+    - name: Create oauth.yml
+      env:
+       SECRET_CODE: ${{ secrets.OAUTH }}
+       SECRET_DIR: src/main/resources
+       SECRET_FILE_NAME: oauth.yml
+      run: echo $SECRET_CODE | base64 --decode > $SECRET_DIR/$SECRET_FILE_NAME
+    - name: Create kafka.yml
+      env:
+        SECRET_CODE: ${{ secrets.KAFKA }}
+        SECRET_DIR: src/main/resources
+        SECRET_FILE_NAME: kafka.yml
+      run: echo $SECRET_CODE | base64 --decode > $SECRET_DIR/$SECRET_FILE_NAME
+    - name: Grant execute permission for gradlew
+      run: chmod +x gradlew
+
+
+    - name: Build with Gradle
+      uses: gradle/gradle-build-action@67421db6bd0bf253fb4bd25b31ebb98943c375e1
+      with:
+        arguments: build
+
+    - name: Set up docker buildx
+      id: buildx
+      uses: docker/setup-buildx-action@v1
+
+    - name: Login to ghcr
+      uses: docker/login-action@v1
+      with:
+        registry: ghcr.io
+        username: ${{ github.actor }}
+        password: ${{ secrets.GHCR_TOKEN }}
+
+    - name: show directory
+      run: ls
+
+    - name: Build and push
+      id: docker_build
+      uses: docker/build-push-action@v2
+      with:
+        context: . 			# dockerfile이 있는 위치랑 맞춰주자
+        file: ./Dockerfile	# 빌드할 Dockerfile이 있는 디렉토리
+        push: true
+        tags: ${{ env.DOCKER_IMAGE }}:local

.gitignore

@@ -37,4 +37,7 @@ out/
 .vscode/
 
 ### security
-/src/main/resources/application-oauth.yml
+/src/main/resources/oauth.yml
+/src/main/resources/secret.yml
+/src/main/resources/kafka.yml
+/spy.log

Dockerfile

@@ -0,0 +1,5 @@
+FROM openjdk:17-alpine
+VOLUME /tmp
+COPY build/libs/auth-0.0.1-SNAPSHOT.jar api.jar
+EXPOSE 8080
+ENTRYPOINT ["java","-jar","-Dspring.profiles.active=docker", "api.jar"]

build.gradle

@@ -28,8 +28,13 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-data-redis'
     implementation 'org.springframework.boot:spring-boot-starter-oauth2-client'
     implementation 'org.springframework.boot:spring-boot-starter-security'
+    implementation 'org.springframework.kafka:spring-kafka'
+
+
+    implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-client'
+    implementation 'org.springframework.cloud:spring-cloud-starter-aws:2.2.6.RELEASE'
+
 
-//    implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-client'
     implementation("com.github.gavlyukovskiy:p6spy-spring-boot-starter:1.8.0")
     implementation 'io.jsonwebtoken:jjwt:0.9.1'
 
@@ -40,6 +45,7 @@ dependencies {
     annotationProcessor 'org.projectlombok:lombok'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testImplementation 'org.springframework.security:spring-security-test'
+    testImplementation 'org.springframework.kafka:spring-kafka-test'
 }
 
 dependencyManagement {

pull_request_template.md

@@ -0,0 +1,30 @@
+# Issue# - Issue
+## Description
+> 
+
+## PR Type
+- [ ] Hotfix
+- [ ] Feature
+- [ ] Code style update
+- [ ] Refactor (code, package, etc.)
+- [ ] Build (gradle, spring, etc) 
+- [ ] Documentation content changes (api docs, etc.)
+- [ ] Infra (cloud, security, etc.)
+- [ ] Other... Please describe :
+
+## Related Issues
+- 
+
+## Issues
+
+### Test
+
+*** 
+
+## Related Files
+- `file`
+
+## Think About..  
+
+## Conclusion  
+> 

src/main/java/com/gaaji/auth/AuthApplication.java

@@ -2,7 +2,9 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 
+@EnableEurekaClient
 @SpringBootApplication
 public class AuthApplication {
 

src/main/java/com/gaaji/auth/adaptor/KafkaProducer.java

@@ -0,0 +1,9 @@
+package com.gaaji.auth.adaptor;
+
+import com.gaaji.auth.event.NicknameChangedEvent;
+
+public interface KafkaProducer {
+
+    void publishNicknameChangedEvent(NicknameChangedEvent event);
+
+}

src/main/java/com/gaaji/auth/adaptor/KafkaProducerImpl.java

@@ -0,0 +1,28 @@
+package com.gaaji.auth.adaptor;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.gaaji.auth.event.NicknameChangedEvent;
+import lombok.RequiredArgsConstructor;
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.stereotype.Service;
+
+@RequiredArgsConstructor
+@Service
+public class KafkaProducerImpl implements KafkaProducer {
+
+    private final KafkaTemplate<String,String> kafkaTemplate;
+
+    @Override
+    public void publishNicknameChangedEvent(NicknameChangedEvent event) {
+
+        String nicknameChangedEvent = null;
+        try {
+            nicknameChangedEvent = new ObjectMapper().writeValueAsString(event);
+            kafkaTemplate.send("nickname-changed",nicknameChangedEvent);
+        } catch (JsonProcessingException e) {
+            throw new RuntimeException(e);
+        }
+
+    }
+}

src/main/java/com/gaaji/auth/adaptor/S3Uploader.java

@@ -0,0 +1,7 @@
+package com.gaaji.auth.adaptor;
+
+import org.springframework.web.multipart.MultipartFile;
+
+public interface S3Uploader {
+    String upload(MultipartFile multipartFile);
+}

src/main/java/com/gaaji/auth/adaptor/S3UploaderImpl.java

@@ -0,0 +1,87 @@
+package com.gaaji.auth.adaptor;
+
+import com.amazonaws.services.s3.AmazonS3Client;
+import com.amazonaws.services.s3.model.CannedAccessControlList;
+import com.amazonaws.services.s3.model.PutObjectRequest;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.util.Objects;
+import java.util.Optional;
+import java.util.UUID;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+@RequiredArgsConstructor
+@Service
+public class S3UploaderImpl implements S3Uploader {
+
+
+    private final AmazonS3Client amazonS3Client;
+    @Value("${cloud.aws.s3.bucket}")
+    private String bucket;
+
+    @Override
+    public String upload(MultipartFile multipartFile) {
+        try {
+            validateIsClientSendImageFile(multipartFile);
+            return uploadFiles(multipartFile, "gaaji/profile");
+        } catch (IOException e) {
+            throw new IllegalArgumentException();
+        }
+    }
+
+    private void validateIsClientSendImageFile(MultipartFile multipartFile) {
+        if (!Objects.requireNonNull(multipartFile.getContentType()).contains("image")) {
+            throw new RuntimeException(); // FileTypeNotImageFileException()
+        }
+    }
+
+    private String uploadFiles(MultipartFile multipartFile, String dirName) throws IOException {
+        File uploadFile = convert(multipartFile)  // 파일 변환할 수 없으면 에러
+                .orElseThrow(() -> new IllegalArgumentException(
+                        "error: MultipartFile -> File convert fail"));
+        return upload(uploadFile, dirName);
+    }
+
+    private String upload(File uploadFile, String filePath) {
+        String fileName =
+                filePath + "/" + UUID.randomUUID() + uploadFile.getName();   // S3에 저장된 파일 이름
+        String uploadImageUrl = putS3(uploadFile, fileName); // s3로 업로드
+        removeNewFile(uploadFile);
+        return uploadImageUrl;
+    }
+
+    // S3로 업로드
+    private String putS3(File uploadFile, String fileName) {
+        amazonS3Client.putObject(new PutObjectRequest(bucket, fileName, uploadFile).withCannedAcl(
+                CannedAccessControlList.PublicRead));
+        return amazonS3Client.getUrl(bucket, fileName).toString();
+    }
+
+    // 로컬에 저장된 이미지 지우기
+    private void removeNewFile(File targetFile) {
+        if (targetFile.delete()) {
+            System.out.println("File delete success");
+            return;
+        }
+        System.out.println("File delete fail");
+    }
+
+    // 로컬에 파일 업로드 하기
+    private Optional<File> convert(MultipartFile file) throws IOException {
+        File convertFile = new File(
+                System.getProperty("user.dir") + "/" + file.getOriginalFilename());
+        if (convertFile.createNewFile()) { // 바로 위에서 지정한 경로에 File이 생성됨 (경로가 잘못되었다면 생성 불가능)
+            try (FileOutputStream fos = new FileOutputStream(
+                    convertFile)) { // FileOutputStream 데이터를 파일에 바이트 스트림으로 저장하기 위함
+                fos.write(file.getBytes());
+            }
+            return Optional.of(convertFile);
+        }
+        return Optional.empty();
+    }
+
+}

src/main/java/com/gaaji/auth/applicationservice/AuthRetrieveService.java

@@ -0,0 +1,8 @@
+package com.gaaji.auth.applicationservice;
+
+import com.gaaji.auth.controller.dto.RetrieveResponse;
+
+public interface AuthRetrieveService {
+
+    RetrieveResponse retrieveAuth(String authId);
+}

src/main/java/com/gaaji/auth/applicationservice/AuthRetrieveServiceImpl.java

@@ -0,0 +1,26 @@
+package com.gaaji.auth.applicationservice;
+
+import com.gaaji.auth.controller.dto.RetrieveResponse;
+import com.gaaji.auth.domain.Auth;
+import com.gaaji.auth.domain.AuthId;
+import com.gaaji.auth.exception.AuthIdNotFoundException;
+import com.gaaji.auth.repository.AuthRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@RequiredArgsConstructor
+@Transactional
+@Service
+public class AuthRetrieveServiceImpl implements
+        AuthRetrieveService {
+
+    private final AuthRepository authRepository;
+
+    @Override
+    public RetrieveResponse retrieveAuth(String authId) {
+        Auth auth = authRepository.findById(authId)
+                .orElseThrow(AuthIdNotFoundException::new);
+        return RetrieveResponse.of(authId, auth.getNickname(), auth.getMannerTemperature(), auth.getProfilePictureUrl());
+    }
+}

src/main/java/com/gaaji/auth/applicationservice/MannerRetriveService.java

@@ -0,0 +1,14 @@
+package com.gaaji.auth.applicationservice;
+
+import java.util.List;
+
+import com.gaaji.auth.domain.BadManner;
+import com.gaaji.auth.domain.GoodManner;
+
+public interface MannerRetriveService {
+
+	List<GoodManner> retriveGoodMannerList();
+
+	List<BadManner> retriveBadMannerList();
+
+}