[Deploy] 거의다왔다 ver

build.gradle

@@ -50,8 +50,11 @@ dependencies {
     implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.7.0'
 
     // AWS S3 (파일 업로드 및 다운로드를 위한 라이브러리)
+    // AWS SDK v2 - S3 + presigned URL
+    implementation 'software.amazon.awssdk:s3:2.31.78'
     implementation 'com.amazonaws:aws-java-sdk-s3:1.12.673'
 
+
     // 이메일 발송 기능
     implementation 'org.springframework.boot:spring-boot-starter-mail'
 
@@ -72,7 +75,11 @@ dependencies {
     implementation 'io.sentry:sentry-spring-boot-starter:8.17.0'
     implementation 'io.sentry:sentry-logback:8.17.0'
 
+    // Apache Commons IO (파일 처리 등 유틸리티)
+    implementation 'commons-io:commons-io:2.16.1'
+
     // 테스트 관련 라이브러리
+    implementation 'org.springframework:spring-test'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testImplementation 'org.springframework.security:spring-security-test'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'

src/main/java/com/deepdirect/deepwebide_be/chat/controller/ChatReadOffsetController.java

@@ -0,0 +1,29 @@
+package com.deepdirect.deepwebide_be.chat.controller;
+
+import com.deepdirect.deepwebide_be.chat.dto.request.ChatReadOffsetRequest;
+import com.deepdirect.deepwebide_be.chat.service.ChatReadOffsetService;
+import com.deepdirect.deepwebide_be.global.dto.ApiResponseDto;
+import com.deepdirect.deepwebide_be.global.security.CustomUserDetails;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api/repositories/{repositoryId}/chat")
+public class ChatReadOffsetController {
+
+    private final ChatReadOffsetService chatReadOffsetService;
+
+    @PatchMapping("/read-offset")
+    public ResponseEntity<ApiResponseDto<Void>> saveReadOffset(
+            @PathVariable Long repositoryId,
+            @Valid @RequestBody ChatReadOffsetRequest request,
+            @AuthenticationPrincipal CustomUserDetails userDetails
+    ) {
+        chatReadOffsetService.saveOffset(repositoryId, userDetails.getId(), request.getLastReadMessageId());
+        return ResponseEntity.ok(ApiResponseDto.of(200, "읽음 처리 완료", null));
+    }
+}

src/main/java/com/deepdirect/deepwebide_be/chat/domain/ChatReadOffset.java

@@ -4,6 +4,7 @@
 import com.deepdirect.deepwebide_be.repository.domain.Repository;
 import jakarta.persistence.*;
 import lombok.AccessLevel;
+import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 
@@ -26,15 +27,38 @@ public class ChatReadOffset {
     @JoinColumn(name = "user_id", nullable = false)
     private User user;
 
-    @Column(name = "last_read_message_id", nullable = false)
-    private Long lastReadMessageId;
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "last_read_message_id", nullable = false)
+    private ChatMessage lastReadMessage;
 
-    @Column(name = "updated_at")
+    @Column(name = "updated_at", nullable = false)
     private LocalDateTime updatedAt;
 
     @PrePersist
     @PreUpdate
     public void setUpdatedAt() {
         this.updatedAt = LocalDateTime.now();
     }
+
+
+    @Builder
+    private ChatReadOffset(Repository repository, User user, ChatMessage lastReadMessage) {
+        this.repository = repository;
+        this.user = user;
+        this.lastReadMessage = lastReadMessage;
+        this.updatedAt = LocalDateTime.now();
+    }
+
+    public static ChatReadOffset of(Repository repository, User user, ChatMessage message) {
+        return ChatReadOffset.builder()
+                .repository(repository)
+                .user(user)
+                .lastReadMessage(message)
+                .build();
+    }
+
+    public void update(ChatMessage newMessage) {
+        this.lastReadMessage = newMessage;
+        this.updatedAt = LocalDateTime.now();
+    }
 }

src/main/java/com/deepdirect/deepwebide_be/chat/dto/request/ChatReadOffsetRequest.java

@@ -0,0 +1,22 @@
+package com.deepdirect.deepwebide_be.chat.dto.request;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+@Schema(description = "채팅 읽음 위치 저장 요청")
+public class ChatReadOffsetRequest {
+
+    @NotNull
+    @Schema(description = "마지막으로 읽은 메시지 ID", example = "152")
+    private Long lastReadMessageId;
+
+    @Builder
+    public ChatReadOffsetRequest(Long lastReadMessageId) {
+        this.lastReadMessageId = lastReadMessageId;
+    }
+}

src/main/java/com/deepdirect/deepwebide_be/chat/repository/ChatReadOffsetRepository.java

@@ -0,0 +1,11 @@
+package com.deepdirect.deepwebide_be.chat.repository;
+
+import com.deepdirect.deepwebide_be.chat.domain.ChatReadOffset;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.Optional;
+
+public interface ChatReadOffsetRepository extends JpaRepository<ChatReadOffset, Long> {
+
+    Optional<ChatReadOffset> findByRepositoryIdAndUserId(Long repositoryId, Long userId);
+}

src/main/java/com/deepdirect/deepwebide_be/chat/service/ChatReadOffsetService.java

@@ -0,0 +1,50 @@
+package com.deepdirect.deepwebide_be.chat.service;
+
+import com.deepdirect.deepwebide_be.chat.domain.ChatMessage;
+import com.deepdirect.deepwebide_be.chat.domain.ChatReadOffset;
+import com.deepdirect.deepwebide_be.chat.repository.ChatMessageRepository;
+import com.deepdirect.deepwebide_be.chat.repository.ChatReadOffsetRepository;
+import com.deepdirect.deepwebide_be.global.exception.ErrorCode;
+import com.deepdirect.deepwebide_be.global.exception.GlobalException;
+import com.deepdirect.deepwebide_be.member.domain.User;
+import com.deepdirect.deepwebide_be.member.repository.UserRepository;
+import com.deepdirect.deepwebide_be.repository.domain.Repository;
+import com.deepdirect.deepwebide_be.repository.repository.RepositoryRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+public class ChatReadOffsetService {
+
+    private final ChatReadOffsetRepository chatReadOffsetRepository;
+    private final RepositoryRepository repositoryRepository;
+    private final UserRepository userRepository;
+    private final ChatMessageRepository chatMessageRepository;
+
+    @Transactional
+    public void saveOffset(Long repositoryId, Long userId, Long messageId) {
+        Repository repository = repositoryRepository.findById(repositoryId)
+                .orElseThrow(() -> new GlobalException(ErrorCode.REPOSITORY_NOT_FOUND));
+
+        User user = userRepository.findById(userId)
+                .orElseThrow(() -> new GlobalException(ErrorCode.USER_NOT_FOUND));
+
+        ChatMessage message = chatMessageRepository.findById(messageId)
+                .orElseThrow(() -> new GlobalException(ErrorCode.CHAT_MESSAGE_NOT_FOUND));
+
+        chatReadOffsetRepository.findByRepositoryIdAndUserId(repositoryId, userId)
+                .ifPresentOrElse(
+                        offset -> {
+                            if (message.getId() > offset.getLastReadMessage().getId()) {
+                                offset.update(message);
+                            }
+                        },
+                        () -> {
+                            ChatReadOffset newOffset = ChatReadOffset.of(repository, user, message);
+                            chatReadOffsetRepository.save(newOffset);
+                        }
+                );
+    }
+}

src/main/java/com/deepdirect/deepwebide_be/global/exception/ErrorCode.java

@@ -1,7 +1,6 @@
 package com.deepdirect.deepwebide_be.global.exception;
 
 import lombok.Getter;
-import org.springframework.boot.actuate.autoconfigure.observation.ObservationProperties;
 import org.springframework.http.HttpStatus;
 
 @Getter
@@ -38,6 +37,10 @@ public enum ErrorCode {
     HISTORY_NOT_FOUND(HttpStatus.BAD_REQUEST, "해당 히스토리를 찾을 수 없습니다."),
     MISSING_WS_PARAMS(HttpStatus.BAD_REQUEST, "WebSocket 연결에 필요한 Param이 누락되었습니다."),
     INVALID_INPUT(HttpStatus.BAD_REQUEST,"검색 키워드를 입력해주세요."),
+    REPOSITORY_EXECUTION_FAILED(HttpStatus.BAD_REQUEST, "레포지토리를 찾을 수 없습니다."),
+    UNSUPPORTED_REPOSITORY_TYPE(HttpStatus.BAD_REQUEST, "지원하지 않는 레포지토리 타입입니다."),
+    REPOSITORY_FILES_NOT_FOUND(HttpStatus.BAD_REQUEST, "레포지토리 파일을 찾을 수 없습니다."),
+    FILE_TREE_CONVERSION_FAILED(HttpStatus.BAD_REQUEST, "파일 트리 변환에 실패했습니다."),
 
     // 401 UNAUTHORIZED
     UNAUTHORIZED(HttpStatus.UNAUTHORIZED, "인증되지 않았습니다."),
@@ -57,6 +60,7 @@ public enum ErrorCode {
     VERIFICATION_NOT_FOUND(HttpStatus.NOT_FOUND, "인증 요청 기록이 없습니다."),
     REPOSITORY_NOT_FOUND(HttpStatus.NOT_FOUND, "존재하지 않은 레포지토리 입니다."),
     ENTRY_CODE_NOT_FOUND(HttpStatus.NOT_FOUND, "입장 코드를 찾을 수 없습니다."),
+    CHAT_MESSAGE_NOT_FOUND(HttpStatus.NOT_FOUND, "채팅 메시지를 찾을 수 없습니다."),
 
 
     // 409 CONFLICT

src/main/java/com/deepdirect/deepwebide_be/global/exception/GlobalExceptionHandler.java

@@ -1,6 +1,7 @@
 package com.deepdirect.deepwebide_be.global.exception;
 
 import com.deepdirect.deepwebide_be.global.dto.ApiResponseDto;
+import com.deepdirect.deepwebide_be.sandbox.exception.SandboxException;
 import io.sentry.Sentry;
 import io.sentry.SentryLevel;
 import io.sentry.protocol.SentryId;
@@ -75,6 +76,13 @@ public ResponseEntity<ApiResponseDto<?>> handleOtherExceptions(Exception ex, Htt
                 .body(ApiResponseDto.error(500, responseMessage));
     }
 
+    @ExceptionHandler(SandboxException.class)
+    public ResponseEntity<ApiResponseDto<Void>> handleSandboxException(SandboxException e) {
+        log.error("Sandbox execution error", e);
+        return ResponseEntity.status(HttpStatus.SERVICE_UNAVAILABLE)
+                .body(ApiResponseDto.of(503, "코드 실행 서비스가 일시적으로 사용할 수 없습니다.", null));
+    }
+
     /** Sentry에 예외 정보 전송 */
     private SentryId sendToSentry(Exception ex, String errorType, SentryLevel level, HttpServletRequest request) {
         if (!Sentry.isEnabled()) {

src/main/java/com/deepdirect/deepwebide_be/global/security/SecurityConfiguration.java

@@ -11,7 +11,6 @@
 import org.springframework.security.crypto.password.PasswordEncoder;
 import org.springframework.security.web.SecurityFilterChain;
 import org.springframework.security.config.annotation.web.builders.HttpSecurity;
-import org.springframework.security.web.authentication.AuthenticationSuccessHandler;
 import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
 import org.springframework.security.web.util.matcher.AntPathRequestMatcher;
 import org.springframework.web.cors.CorsConfiguration;
@@ -91,9 +90,9 @@ public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Excepti
                                 new AntPathRequestMatcher("/redis-test"),
                                 new AntPathRequestMatcher("/test/**"), // Sentry 테스트용
                                 new AntPathRequestMatcher("/ws/**"),
-                                new AntPathRequestMatcher("/test/**"), // Sentry 테스트용
                                 new AntPathRequestMatcher("/login/oauth2/**"),
-                                new AntPathRequestMatcher("/oauth2/**")
+                                new AntPathRequestMatcher("/oauth2/**"),
+                                new AntPathRequestMatcher("/api/projects/**")
                         ).permitAll()
                         .requestMatchers(new AntPathRequestMatcher("/api/auth/signout")).authenticated()
                         .anyRequest().authenticated()

src/main/java/com/deepdirect/deepwebide_be/repository/controller/RepositoryRunController.java

@@ -0,0 +1,93 @@
+package com.deepdirect.deepwebide_be.repository.controller;
+
+import com.deepdirect.deepwebide_be.global.dto.ApiResponseDto;
+import com.deepdirect.deepwebide_be.global.exception.ErrorCode;
+import com.deepdirect.deepwebide_be.global.exception.GlobalException;
+import com.deepdirect.deepwebide_be.global.security.CustomUserDetails;
+import com.deepdirect.deepwebide_be.repository.dto.response.RepositoryExecuteResponse;
+import com.deepdirect.deepwebide_be.repository.dto.response.RepositoryStatusResponse;
+import com.deepdirect.deepwebide_be.repository.dto.response.RepositoryStopResponse;
+import com.deepdirect.deepwebide_be.repository.repository.RepositoryRepository;
+import com.deepdirect.deepwebide_be.repository.service.RepositoryRunService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
+
+import java.util.Map;
+
+
+@Slf4j
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api/repositories")
+@Tag(name = "RUN", description = "레포지토리 실행, 로그 반환 등 기능 API")
+public class RepositoryRunController {
+
+    private final RepositoryRunService repositoryRunService;
+    private final RepositoryRepository repositoryRepository;
+
+    @PostMapping("/{repositoryId}/execute")
+    @Operation(summary = "레포지토리 실행", description = "레포지토리를 실행하고 실행 결과를 반환합니다.")
+    public ResponseEntity<ApiResponseDto<RepositoryExecuteResponse>> executeRepository(
+            @AuthenticationPrincipal CustomUserDetails userDetails,
+            @PathVariable Long repositoryId
+    ) {
+        RepositoryExecuteResponse resp = repositoryRunService.executeRepository(repositoryId, userDetails.getId());
+        return ResponseEntity.ok(ApiResponseDto.of(200, "레포지토리 실행 요청 완료", resp));
+    }
+
+    /**
+     * 레포지토리 중지
+     */
+    @DeleteMapping("/{repositoryId}/stop")
+    @Operation(summary = "레포지토리 중지", description = "레포지토리를 중지하고 중지 결과를 반환합니다.")
+    public ResponseEntity<ApiResponseDto<RepositoryStopResponse>> stopRepository(
+            @AuthenticationPrincipal CustomUserDetails userDetails,
+            @PathVariable Long repositoryId
+    ) {
+        boolean success = repositoryRunService.stopRepository(repositoryId, userDetails.getId());
+
+        RepositoryStopResponse result = RepositoryStopResponse.builder()
+                .repositoryId(repositoryId)
+                .stopped(success)
+                .message(success ? "레포지토리가 중지되었습니다." : "중지할 컨테이너가 없습니다.")
+                .build();
+
+        return ResponseEntity.ok(ApiResponseDto.of(200, "레포지토리 중지 요청 완료", result));
+    }
+
+    /**
+     * 레포지토리 실행 상태 조회
+     */
+    @GetMapping("/{repositoryId}/status")
+    @Operation(summary = "레포지토리 상태 조회", description = "레포지토리의 실행 상태를 조회합니다.")
+    public ResponseEntity<ApiResponseDto<RepositoryStatusResponse>> getRepositoryStatus(
+            @AuthenticationPrincipal CustomUserDetails userDetails,
+            @PathVariable Long repositoryId
+    ) {
+        RepositoryStatusResponse status = repositoryRunService.getRepositoryStatus(repositoryId, userDetails.getId());
+        return ResponseEntity.ok(ApiResponseDto.of(200, "레포지토리 상태 조회 완료", status));
+    }
+
+    /**
+     * 레포지토리 실행 로그 조회
+     */
+    @GetMapping("/{repositoryId}/logs")
+    @Operation(summary = "레포지토리 로그 조회", description = "레포지토리의 실행 로그를 조회합니다.")
+    public ResponseEntity<ApiResponseDto<Map<String, Object>>> getRepositoryLogs(
+            @AuthenticationPrincipal CustomUserDetails userDetails,
+            @PathVariable Long repositoryId,
+            @RequestParam(defaultValue = "50") int lines,
+            @RequestParam(defaultValue = "5m") String since) {
+
+        Map<String, Object> logs = repositoryRunService.getRepositoryLogs(repositoryId, userDetails.getId(), lines, since);
+        return ResponseEntity.ok(ApiResponseDto.of(200, "레포지토리 로그 조회 완료", logs));
+    }
+}
+

src/main/java/com/deepdirect/deepwebide_be/repository/domain/PortRegistry.java

@@ -17,12 +17,26 @@ public class PortRegistry {
     @OneToOne
     private Repository repository;
 
-    public void setStatus(PortStatus status) {
-        this.status = status;
+//    public void setStatus(PortStatus status) {
+//        this.status = status;
+//    }
+//
+//    public void setRepository(Repository repository) {
+//        this.repository = repository;
+//    }
+
+    public void assignToRepository(Repository repository) {
+        this.status = PortStatus.IN_USE;
+        this.repository = repository;
     }
 
-    public void setRepository(Repository repository) {
-        this.repository = repository;
+    public void release() {
+        this.status = PortStatus.AVAILABLE;
+        this.repository = null;
+    }
+
+    public Integer getPort() {
+        return this.port;
     }
 }