Dev-ton 발표용 main으로 merge

.github/workflows/merge-stage.yml

@@ -0,0 +1,17 @@
+name: Merge Webhook Alert
+
+on:
+  pull_request:
+    types: [closed]
+
+jobs:
+  deploy:
+    if: github.event.pull_request.merged == true && github.event.pull_request.base.ref == 'develop'
+    runs-on: ubuntu-latest
+    steps:
+      - name: Discord에 메시지 보내기 (develop 브랜치로 merge 됐을 때)
+        run: |
+          curl -X POST \
+          -H "Content-Type: application/json" \
+          -d "{\"content\": \":tada: '${{ github.event.pull_request.head.ref }}' 브랜치에서 develop 브랜치로 성공적으로 PR이 머지되었습니다!\n\n:bust_in_silhouette: 브랜치 작성자: ${{ github.event.pull_request.user.login }}\n:busts_in_silhouette: 머지한 사람: ${{ github.actor }}\n\n팀원 분들은 전부 Pull 받으세요~!!!\n```git pull origin develop```\"}" \
+          ${{secrets.DISCORD_WEBHOOK_MERGE_URL}}

.gitignore

@@ -38,3 +38,9 @@ out/
 
 ### custom ###
 src/main/resources/application.yml
+src/main/resources/samples/qna.sql
+src/main/resources/samples/user.sql
+src/main/resources/fb.json
+
+### Mac Os ###
+.DS_Store

build.gradle

@@ -20,23 +20,62 @@ configurations {
 }
 
 repositories {
+    google()
     mavenCentral()
 }
 
 dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
     implementation 'org.springframework.boot:spring-boot-starter-web'
+    implementation 'org.springframework.boot:spring-boot-starter-security'
+    implementation 'org.springframework.boot:spring-boot-starter-validation'
+    implementation 'org.springframework.boot:spring-boot-starter-mail'
+    testImplementation 'org.springframework.security:spring-security-test'
+    implementation 'org.springframework.boot:spring-boot-starter-security'
+    implementation 'org.springframework.boot:spring-boot-starter-validation'
+    implementation 'io.springfox:springfox-swagger-ui:3.0.0'
+    implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.0.2'
+
     compileOnly 'org.projectlombok:lombok'
     developmentOnly 'org.springframework.boot:spring-boot-devtools'
     runtimeOnly 'com.mysql:mysql-connector-j'
+
     annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
     annotationProcessor 'org.projectlombok:lombok'
+
+    testImplementation 'org.springframework.security:spring-security-test'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
-    implementation 'io.springfox:springfox-swagger-ui:3.0.0'
-    implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.0.2'
+
+    // firebase
+    implementation 'com.google.firebase:firebase-admin:9.2.0'
+    implementation 'com.google.firebase:firebase-database:20.1.0'
+
+    // aws
+    implementation platform('io.awspring.cloud:spring-cloud-aws-dependencies:3.1.1')
+    implementation("io.awspring.cloud:spring-cloud-aws-starter-s3:3.1.1")
+
+    // jwt
+    implementation 'io.jsonwebtoken:jjwt-api:0.11.5'
+    implementation 'io.jsonwebtoken:jjwt-impl:0.11.5'
+    implementation 'io.jsonwebtoken:jjwt-jackson:0.11.5'
+
+    // gson
+    implementation group: 'com.google.code.gson', name: 'gson', version: '2.8.9'
+
+    // UUID
+    implementation "com.fasterxml.uuid:java-uuid-generator:4.0.1"
+
+    // redis
+    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+
 }
 
-tasks.named('test') {
+
+test {
     useJUnitPlatform()
 }
+
+compileJava {
+    options.compilerArgs << '-parameters'
+}

src/main/java/com/esquad/esquadbe/EsquadBeApplication.java

@@ -2,8 +2,11 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
 
-@SpringBootApplication
+@SpringBootApplication(exclude = SecurityAutoConfiguration.class)
+@EnableJpaAuditing
 public class EsquadBeApplication {
 
     public static void main(String[] args) {

src/main/java/com/esquad/esquadbe/chat/controller/ChatController.java

@@ -0,0 +1,168 @@
+package com.esquad.esquadbe.chat.controller;
+
+import com.esquad.esquadbe.chat.dto.ChatEditMessage;
+import com.esquad.esquadbe.chat.dto.ChatMessage;
+import com.esquad.esquadbe.chat.exception.ChatAccessException;
+import com.esquad.esquadbe.chat.exception.ChatException;
+import com.esquad.esquadbe.chat.service.FirebaseService;
+import com.google.firebase.database.DataSnapshot;
+import com.google.firebase.database.DatabaseError;
+import com.google.firebase.database.DatabaseReference;
+import com.google.firebase.database.ValueEventListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+import java.security.Principal;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+
+@RestController
+@RequestMapping("/api/chat")
+public class ChatController {
+    @Autowired
+    private FirebaseService firebaseService;
+
+    @PostMapping("/send")
+    public ResponseEntity<Map<String, String>> sendMessage(@RequestBody ChatMessage chatMsg) {
+        Map<String, String> response = new HashMap<>();
+        try {
+            DatabaseReference roomRef = firebaseService.getReference("MESSAGES/" + chatMsg.getRoomId());
+            DatabaseReference messageRef = roomRef.push();
+            String newMessageId = messageRef.getKey();
+            chatMsg.setMessageId(newMessageId);
+
+            CompletableFuture<Void> future = new CompletableFuture<>();
+            messageRef.setValue(chatMsg, (error, ref) -> {
+                if (error != null) {
+                    response.put("status", "error");
+                    response.put("message", error.getMessage());
+                    future.completeExceptionally(error.toException());
+                } else {
+                    response.put("status", "success");
+                    response.put("messageId", newMessageId);
+                    future.complete(null);
+                }
+            });
+            future.join();
+            return ResponseEntity.ok(response);
+        } catch (Exception e) {
+            throw new ChatException();
+        }
+    }
+
+    @GetMapping("/messages/{roomId}")
+    public CompletableFuture<ResponseEntity<Map<String, Object>>> getMessages(@PathVariable String roomId) {
+        Map<String, Object> response = new HashMap<>();
+        CompletableFuture<ResponseEntity<Map<String, Object>>> futureResponse = new CompletableFuture<>();
+
+        DatabaseReference messagesRef = firebaseService.getReference("MESSAGES/" + roomId);
+        messagesRef.addListenerForSingleValueEvent(new ValueEventListener() {
+            @Override
+            public void onDataChange(DataSnapshot dataSnapshot) {
+                List<Map<String, Object>> messages = new ArrayList<>();
+                if (dataSnapshot.exists()) {
+                    for (DataSnapshot child : dataSnapshot.getChildren()) {
+                        Map<String, Object> message = (Map<String, Object>) child.getValue();
+                        if (message != null) {
+                            message.put("id", child.getKey());
+                            messages.add(message);
+                        }
+                    }
+                    response.put("messages", messages);
+                    response.put("status", "success");
+                } else {
+                    response.put("messages", new ArrayList<>());
+                    response.put("status", "success");
+                }
+                futureResponse.complete(ResponseEntity.ok(response));
+            }
+
+            @Override
+            public void onCancelled(DatabaseError databaseError) {
+                throw new ChatException();
+            }
+        });
+        return futureResponse;
+    }
+
+    @PutMapping("/{roomId}/{messageId}")
+    public CompletableFuture<ResponseEntity<Map<String, String>>> updateMessage(
+            @PathVariable String roomId,
+            @PathVariable String messageId,
+            @RequestBody ChatEditMessage request,
+            Principal principal) {
+
+        Map<String, String> response = new HashMap<>();
+        CompletableFuture<ResponseEntity<Map<String, String>>> futureResponse = new CompletableFuture<>();
+
+        DatabaseReference messageRef = firebaseService.getReference("MESSAGES/" + roomId + "/" + messageId);
+        String userId = principal.getName();
+
+        messageRef.child("userId").addListenerForSingleValueEvent(new ValueEventListener() {
+            @Override
+            public void onDataChange(DataSnapshot dataSnapshot) {
+                String originalUserId = dataSnapshot.getValue(String.class);
+
+                if (originalUserId != null && originalUserId.equals(userId)) {
+                    messageRef.child("message").setValue(request.getNewMessage(), (error, ref) -> {
+                        if (error != null) {
+                            response.put("status", "error");
+                            response.put("message", error.getMessage());
+                            futureResponse.complete(ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(response));
+                        } else {
+                            response.put("status", "success");
+                            futureResponse.complete(ResponseEntity.ok(response));
+                        }
+                    });
+                } else {
+                    throw new ChatAccessException();
+                }
+            }
+            @Override
+            public void onCancelled(DatabaseError databaseError) {
+               throw new ChatException();
+            }
+        });
+        return futureResponse;
+    }
+
+    @DeleteMapping("/{roomId}/{messageId}")
+    public CompletableFuture<ResponseEntity<Map<String, String>>> deleteMessage(
+            @PathVariable String roomId,
+            @PathVariable String messageId,
+            Principal principal) {
+
+        DatabaseReference messageRef = firebaseService.getReference("MESSAGES/" + roomId + "/" + messageId);
+        CompletableFuture<ResponseEntity<Map<String, String>>> futureResponse = new CompletableFuture<>();
+        Map<String, String> response = new HashMap<>();
+
+        String userId = principal.getName();
+
+        messageRef.child("userId").addListenerForSingleValueEvent(new ValueEventListener() {
+            @Override
+            public void onDataChange(DataSnapshot dataSnapshot) {
+                String originalUserId = dataSnapshot.getValue(String.class);
+
+                if (originalUserId != null && originalUserId.equals(userId)) {
+                    firebaseService.deleteMessage(roomId, messageId); // 메시지 삭제
+                    response.put("status", "success");
+                    futureResponse.complete(ResponseEntity.ok(response));
+                } else {
+                    response.put("status", "error");
+                    response.put("message", "Unauthorized");
+                    futureResponse.complete(ResponseEntity.status(HttpStatus.FORBIDDEN).body(response));
+                }
+            }
+
+            @Override
+            public void onCancelled(DatabaseError databaseError) {
+                throw new ChatAccessException();
+            }
+        });
+        return futureResponse;
+    }
+}

src/main/java/com/esquad/esquadbe/chat/dto/ChatEditMessage.java

@@ -0,0 +1,16 @@
+package com.esquad.esquadbe.chat.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+public class ChatEditMessage {
+    private String userId;
+    private String newMessage;
+}
+

src/main/java/com/esquad/esquadbe/chat/dto/ChatMessage.java

@@ -0,0 +1,22 @@
+package com.esquad.esquadbe.chat.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import java.time.LocalDate;
+
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+public class ChatMessage {
+    private String roomId;
+    private String userId;
+    private String message;
+    private String type;
+    private String messageId;
+    private String status;
+    private String fileUrl;
+    private LocalDate timestamp;
+}

src/main/java/com/esquad/esquadbe/chat/dto/FirebaseProperties.java

@@ -0,0 +1,23 @@
+package com.esquad.esquadbe.chat.dto;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Data
+@Component
+@ConfigurationProperties(prefix = "firebase")
+public class FirebaseProperties {
+    private String type;
+    private String projectId;
+    private String privateKeyId;
+    private String privateKey;
+    private String clientEmail;
+    private String clientId;
+    private String authUri;
+    private String tokenUri;
+    private String authProviderX509CertUrl;
+    private String clientX509CertUrl;
+    private String universeDomain;
+    private String databaseUrl;
+}

src/main/java/com/esquad/esquadbe/chat/exception/ChatAccessException.java

@@ -0,0 +1,9 @@
+package com.esquad.esquadbe.chat.exception;
+
+import com.esquad.esquadbe.global.exception.RestApiException;
+
+public class ChatAccessException extends RestApiException {
+    public ChatAccessException() {
+        super(ChatErrorCode.CHAT_NOT_CORRECT_ID);
+    }
+}

src/main/java/com/esquad/esquadbe/chat/exception/ChatErrorCode.java

@@ -0,0 +1,19 @@
+package com.esquad.esquadbe.chat.exception;
+
+import com.esquad.esquadbe.global.exception.ErrorCode;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpStatus;
+
+// 채팅 예외 클래스
+@Getter
+@RequiredArgsConstructor
+public enum ChatErrorCode implements ErrorCode{
+
+    CHAT_NOT_FOUND(HttpStatus.NOT_FOUND, "Chat Data not exists", "CHAT-0001"),
+    CHAT_NOT_CORRECT_ID(HttpStatus.FORBIDDEN, "Chat not correct id", "CHAT-0002"),;
+
+    private final HttpStatus httpStatus;
+    private final String message;
+    private final String code;
+}

src/main/java/com/esquad/esquadbe/chat/exception/ChatException.java

@@ -0,0 +1,9 @@
+package com.esquad.esquadbe.chat.exception;
+
+import com.esquad.esquadbe.global.exception.RestApiException;
+
+public class ChatException extends RestApiException {
+    public ChatException() {
+        super(ChatErrorCode.CHAT_NOT_FOUND);
+    }
+}