fix(repository): GitHub API 호출 과정에서 발생할 수 있는 NPE 수정

fix(repository): GitHub API 호출 과정에서 발생할 수 있는 NPE 수정

Author: Hyeseung-OH

backend/build.gradle.kts

@@ -52,6 +52,9 @@ dependencies {
     implementation("org.springframework.boot:spring-boot-starter-security")
     implementation("org.springframework.retry:spring-retry")
     implementation("org.springframework.boot:spring-boot-starter-aop")
+    testCompileOnly("org.projectlombok:lombok:1.18.32")
+    testAnnotationProcessor("org.projectlombok:lombok:1.18.32")
+
 }
 
 tasks.withType<Test> {

backend/src/main/java/com/backend/domain/repository/dto/response/github/RepoResponse.java

@@ -12,6 +12,7 @@ public record RepoResponse(
         @JsonProperty("html_url") String htmlUrl,
         String language,
         @JsonProperty("default_branch") String defaultBranch,
-        @JsonProperty("created_at") OffsetDateTime createdAt
+        @JsonProperty("created_at") OffsetDateTime createdAt,
+        Integer size
 ) {
 }

backend/src/main/java/com/backend/domain/repository/service/RepositoryService.java

@@ -73,6 +73,9 @@ public RepositoryData fetchCompleteRepositoryData(String owner, String repo, Lon
             // 1. 기본 정보 수집 및 매핑 + Repositories 테이블 저장
             sseProgressNotifier.notify(userId, "status", "GitHub 연결 중");
             RepoResponse repoInfo = gitHubDataFetcher.fetchRepositoryInfo(owner, repo);
+
+            validateRepositorySize(repoInfo.size());
+
             repositoryInfoMapper.mapBasicInfo(data, repoInfo);
 
             // 2. 커밋 데이터 수집 및 매핑
@@ -167,4 +170,18 @@ public List<Language> getLanguageByRepositoriesId(Long repositoriesId) {
                 .map(RepositoryLanguage::getLanguage)
                 .toList();
     }
+
+    // 저장소 크기 검증
+    private void validateRepositorySize(Integer sizeInKb) {
+        if (sizeInKb == null) {
+            return;
+        }
+
+        final int MAX_SIZE_KB = 1_000_000;
+
+        if (sizeInKb > MAX_SIZE_KB) {
+            log.warn("저장소 크기 초과: {}KB (제한: {}KB)", sizeInKb, MAX_SIZE_KB);
+            throw new BusinessException(ErrorCode.GITHUB_REPO_TOO_LARGE);
+        }
+    }
 }

backend/src/main/java/com/backend/domain/repository/service/fetcher/GitHubDataFetcher.java

@@ -48,7 +48,12 @@ public RepoResponse fetchRepositoryInfo(String owner, String repoName) {
     public Optional<String> fetchReadmeContent(String owner, String repoName) {
         try {
             String content = gitHubApiClient.getRaw("/repos/{owner}/{repo}/readme", owner, repoName);
-            return Optional.ofNullable(content);
+
+            if (content == null || content.trim().isEmpty()) {
+                return Optional.empty();
+            }
+
+            return Optional.of(content);
         } catch (BusinessException e) {
             if (e.getErrorCode() == ErrorCode.GITHUB_REPO_NOT_FOUND) {
                 return Optional.empty();
@@ -65,9 +70,17 @@ public Optional<String> fetchReadmeContent(String owner, String repoName) {
             backoff = @Backoff(delay = 1000)
     )
     public List<CommitResponse> fetchCommitInfo(String owner, String repoName, String since) {
-        return gitHubApiClient.getList(
-                "/repos/{owner}/{repo}/commits?since={since}&per_page=100", CommitResponse.class, owner, repoName, since
-        );
+        try {
+            return gitHubApiClient.getList(
+                    "/repos/{owner}/{repo}/commits?since={since}&per_page=100",
+                    CommitResponse.class, owner, repoName, since
+            );
+        } catch (BusinessException e) {
+            if (e.getErrorCode() == ErrorCode.GITHUB_REPO_NOT_FOUND) {
+                return Collections.emptyList();
+            }
+            throw e;
+        }
     }
 
     @Retryable(
@@ -83,7 +96,12 @@ public Optional<TreeResponse> fetchRepositoryTreeInfo(String owner, String repoN
                     "/repos/{owner}/{repo}/git/trees/{sha}?recursive=1",
                     TreeResponse.class, owner, repoName, defaultBranch
             );
-            return Optional.ofNullable(tree);
+
+            if (tree == null || tree.tree() == null || tree.tree().isEmpty()) {
+                return Optional.empty();
+            }
+
+            return Optional.of(tree);
         } catch (BusinessException e) {
             if (e.getErrorCode() == ErrorCode.GITHUB_REPO_NOT_FOUND) {
                 return Optional.empty();
@@ -155,14 +173,25 @@ public List<PullRequestResponse> fetchPullRequestInfo(String owner, String repoN
             backoff = @Backoff(delay = 1000)
     )
     public Map<String, Integer> fetchLanguages(String owner, String repoName) {
-        return gitHubApiClient.get("/repos/{owner}/{repo}/languages", Map.class, owner, repoName);
+        try {
+            return gitHubApiClient.get("/repos/{owner}/{repo}/languages", Map.class, owner, repoName);
+        } catch (BusinessException e) {
+            if (e.getErrorCode() == ErrorCode.GITHUB_REPO_NOT_FOUND) {
+                return Collections.emptyMap();
+            }
+            throw e;
+        }
     }
 
     private LocalDateTime getSixMonthsAgo() {
         return LocalDateTime.now().minusMonths(COMMUNITY_ANALYSIS_MONTHS);
     }
 
     private LocalDateTime parseGitHubDate(String dateString) {
-        return LocalDateTime.parse(dateString, DateTimeFormatter.ISO_OFFSET_DATE_TIME);
+        try {
+            return LocalDateTime.parse(dateString, DateTimeFormatter.ISO_OFFSET_DATE_TIME);
+        } catch (Exception e) {
+            return LocalDateTime.MIN;
+        }
     }
 }

backend/src/main/java/com/backend/domain/repository/service/mapper/CicdInfoMapper.java

@@ -67,7 +67,7 @@ public class CicdInfoMapper {
     );
 
     public void mapCicdInfo(RepositoryData data, TreeResponse response) {
-        if (response == null || response.tree().isEmpty()) {
+        if (response == null || response.tree() == null || response.tree().isEmpty()) {
             setEmptyCicdData(data);
             return;
         }

backend/src/main/java/com/backend/domain/repository/service/mapper/CommitInfoMapper.java

@@ -25,7 +25,14 @@ public void mapCommitInfo(RepositoryData data, List<CommitResponse> response) {
         }
 
         // 마지막 커밋 시점
-        LocalDateTime lastCommitDate = parseCommitDate(response.get(0).commit().author().date());
+        CommitResponse.CommitDetails commit = response.get(0).commit();
+        if (commit == null) {
+            setDefaultValues(data);
+            return;
+        }
+        LocalDateTime lastCommitDate = commit.author() != null
+                ? parseCommitDate(commit.author().date())
+                : LocalDateTime.now();
         data.setLastCommitDate(lastCommitDate);
 
         // 마지막 커밋 이후 경과일
@@ -72,6 +79,7 @@ private int calculateDaysSinceLastCommit(LocalDateTime date) {
 
     private List<RepositoryData.CommitInfo> extractRecentCommitMessages(List<CommitResponse> commitResponses) {
         return commitResponses.stream()
+                .filter(commitResponse -> commitResponse != null)
                 .limit(10)
                 .map(this::createCommitInfoFromMessage)
                 .collect(Collectors.toList());
@@ -80,18 +88,21 @@ private List<RepositoryData.CommitInfo> extractRecentCommitMessages(List<CommitR
     private RepositoryData.CommitInfo createCommitInfoFromMessage(CommitResponse commitResponse) {
         RepositoryData.CommitInfo commitInfo = new RepositoryData.CommitInfo();
 
-        String message = Optional.ofNullable(commitResponse.commit().message())
+        CommitResponse.CommitDetails commit = commitResponse.commit();
+
+        String message = Optional.ofNullable(commit)
+                .map(CommitResponse.CommitDetails::message)
                 .map(String::trim)
                 .map(this::cleanCommitMessage)
                 .filter(msg -> !msg.isEmpty())
                 .orElse("No commit message");
 
         commitInfo.setMessage(message);
 
-        if (commitResponse.commit().author() != null) {
-            LocalDateTime commitDate = parseCommitDate(commitResponse.commit().author().date());
-            commitInfo.setCommittedDate(commitDate);
-        }
+        Optional.ofNullable(commit)
+                .map(CommitResponse.CommitDetails::author)
+                .map(author -> parseCommitDate(author.date()))
+                .ifPresent(commitInfo::setCommittedDate);
 
         return commitInfo;
     }

backend/src/main/java/com/backend/domain/repository/service/mapper/IssueInfoMapper.java

@@ -19,17 +19,21 @@ public void mapIssueInfo(RepositoryData data, List<IssueResponse> response) {
             return;
         }
 
+        List<IssueResponse> validIssues = response.stream()
+                .filter(issue -> issue != null)
+                .collect(Collectors.toList());
+
         // 최근 6개월 이슈 수
-        data.setIssueCountLast6Months(response.size());
+        data.setIssueCountLast6Months(validIssues.size());
 
         // 6개월 내 해결된 이슈 수
-        long closedIssueCount = response.stream()
+        long closedIssueCount = validIssues.stream()
                 .filter(IssueResponse::isClosed)
                 .count();
         data.setClosedIssueCountLast6Months((int) closedIssueCount);
 
         // 최근 5-10개 이슈
-        List<RepositoryData.IssueInfo> recentIssues = response.stream()
+        List<RepositoryData.IssueInfo> recentIssues = validIssues.stream()
                 .limit(10)
                 .map(this::convertToIssueInfo)
                 .collect(Collectors.toList());

backend/src/main/java/com/backend/domain/repository/service/mapper/PullRequestInfoMapper.java

@@ -19,17 +19,21 @@ public void mapPullRequestInfo(RepositoryData data, List<PullRequestResponse> re
             return;
         }
 
+        List<PullRequestResponse> validPrs = response.stream()
+                .filter(pr -> pr != null)
+                .collect(Collectors.toList());
+
         // 최근 6개월 PR 수
-        data.setPullRequestCountLast6Months(response.size());
+        data.setPullRequestCountLast6Months(validPrs.size());
 
         // 6개월 내 머지된 PR 수
-        long mergedPRCount = response.stream()
+        long mergedPRCount = validPrs.stream()
                 .filter(pr -> pr.merged_at() != null)
                 .count();
         data.setMergedPullRequestCountLast6Months((int) mergedPRCount);
 
         // 최근 5-10개 PR
-        List<RepositoryData.PullRequestInfo> recentPRs = response.stream()
+        List<RepositoryData.PullRequestInfo> recentPRs = validPrs.stream()
                 .limit(10)
                 .map(this::convertToPullRequestInfo)
                 .collect(Collectors.toList());

backend/src/main/java/com/backend/domain/repository/service/mapper/RepositoryInfoMapper.java

@@ -4,7 +4,6 @@
 import com.backend.domain.repository.dto.response.github.RepoResponse;
 import org.springframework.stereotype.Component;
 
-import java.time.LocalDateTime;
 import java.time.ZoneId;
 
 @Component
@@ -21,9 +20,10 @@ public void mapBasicInfo(RepositoryData data, RepoResponse response) {
         data.setPrimaryLanguage(response.language());
         // Repository 생성 날짜
         ZoneId kst = ZoneId.of("Asia/Seoul");
-        LocalDateTime createdAtKST = response.createdAt()
-                .atZoneSameInstant(kst)
-                .toLocalDateTime();
-        data.setRepositoryCreatedAt(createdAtKST);
+        data.setRepositoryCreatedAt(
+                response.createdAt() != null
+                        ? response.createdAt().atZoneSameInstant(ZoneId.of("Asia/Seoul")).toLocalDateTime()
+                        : null
+        );
     }
 }

backend/src/main/java/com/backend/domain/repository/service/mapper/SecurityInfoMapper.java

@@ -88,7 +88,7 @@ public class SecurityInfoMapper {
     );
 
     public void mapSecurityInfo(RepositoryData data, TreeResponse response) {
-        if (response == null || response.tree().isEmpty()) {
+        if (response == null || response.tree() == null || response.tree().isEmpty()) {
             setEmptySecurityData(data);
             return;
         }