Skip to content

Removes emoji characters from all log messages across service classes to improve log readability and maintain professional appearance in production environments. #35

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Yoo-SH merged 2 commits into from
Aug 21, 2025
Merged

Removes emoji characters from all log messages across service classes to improve log readability and maintain professional appearance in production environments. #35

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
56c050e
chore: translate all Korean comments and log messages to English
Yoo-SH Aug 21, 2025
81b6caf
chore: clean up log messages by removing emojis
Yoo-SH Aug 21, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions core/src/main/java/com/opencontext/controller/DocsSourceController.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ public interface DocsSourceController {
"ingestionStatus": "PENDING",
"message": "File uploaded successfully and is now pending for ingestion."
},
"message": "요청이 성공적으로 처리되었습니다.",
"message": "Request processed successfully.",
"errorCode": null,
"timestamp": "2025-08-07T11:50:00Z"
}
Expand Down Expand Up @@ -210,7 +210,7 @@ ResponseEntity<CommonResponse<SourceUploadResponse>> uploadFile(
"hasNext": true,
"hasPrevious": false
},
"message": "요청이 성공적으로 처리되었습니다.",
"message": "Request processed successfully.",
"timestamp": "2025-08-07T12:05:00Z"
}
"""
Expand Down Expand Up @@ -256,7 +256,7 @@ ResponseEntity<CommonResponse<PageResponse<SourceDocumentDto>>> getAllSourceDocu
{
"success": true,
"data": "Document re-ingestion has been queued successfully.",
"message": "요청이 성공적으로 처리되었습니다.",
"message": "Request processed successfully.",
"timestamp": "2025-08-07T12:05:00Z"
}
"""
Expand Down Expand Up @@ -304,7 +304,7 @@ ResponseEntity<CommonResponse<String>> resyncSourceDocument(
{
"success": true,
"data": "Document deletion has been queued successfully.",
"message": "요청이 성공적으로 처리되었습니다.",
"message": "Request processed successfully.",
"timestamp": "2025-08-07T12:05:00Z"
}
"""
Expand Down
12 changes: 6 additions & 6 deletions core/src/main/java/com/opencontext/controller/SearchController.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,8 @@
import java.util.List;

/**
* MCP 검색 API 컨트롤러
* find_knowledge와 get_content MCP 도구를 위한 엔드포인트 제공
* MCP Search API Controller
* Provides endpoints for find_knowledge and get_content MCP tools
*/
@Slf4j
@RestController
Expand All @@ -29,15 +29,15 @@ public class SearchController implements DocsSearchController {
private final ContentRetrievalService contentRetrievalService;

/**
* 하이브리드 검색 수행 - find_knowledge MCP 도구
* Performs hybrid search - find_knowledge MCP tool
*/
@Override
@GetMapping("/search")
public ResponseEntity<CommonResponse<SearchResultsResponse>> search(
@RequestParam String query,
@RequestParam(defaultValue = "50") Integer topK) {

log.info("검색 요청: query='{}', topK={}", query, topK);
log.info("Search request: query='{}', topK={}", query, topK);

if (query == null || query.trim().isEmpty()) {
return ResponseEntity.badRequest()
Expand All @@ -52,7 +52,7 @@ public ResponseEntity<CommonResponse<SearchResultsResponse>> search(
}

/**
* 청크 콘텐츠 조회 - get_content MCP 도구
* Retrieves chunk content - get_content MCP tool
*/
@Override
@PostMapping(value = "/get-content", consumes = MediaType.APPLICATION_JSON_VALUE)
Expand All @@ -67,7 +67,7 @@ public ResponseEntity<CommonResponse<GetContentResponse>> getContent(@jakarta.va
return ResponseEntity.badRequest()
.body(CommonResponse.error("maxTokens must be positive", "VALIDATION_FAILED"));
}
log.info("콘텐츠 조회 요청: chunkId={}, maxTokens={}", chunkId, maxTokens);
log.info("Content retrieval request: chunkId={}, maxTokens={}", chunkId, maxTokens);
GetContentResponse response = contentRetrievalService.getContent(chunkId, maxTokens);
return ResponseEntity.ok(CommonResponse.success(response, "Content retrieved successfully"));
}
Expand Down
96 changes: 48 additions & 48 deletions core/src/main/java/com/opencontext/controller/SourceController.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@
import java.util.UUID;

/**
* 소스 문서 관리를 위한 REST API 컨트롤러.
* REST API controller for managing source documents.
*
* REST API controller for managing source documents.
*
Expand Down Expand Up @@ -63,10 +63,10 @@ public class SourceController implements DocsSourceController{
private String indexName;

/**
* 파일 업로드 및 수집 파이프라인 시작
* File upload and ingestion pipeline start
*
* @param file 업로드할 파일 (multipart/form-data)
* @return 업로드 결과 및 문서 정보
* @param file File to upload (multipart/form-data)
* @return Upload result and document information
*/
@Override
@PostMapping(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
Expand All @@ -75,15 +75,15 @@ public ResponseEntity<CommonResponse<SourceUploadResponse>> uploadFile(
log.info("File upload requested: filename={}, size={}", file.getOriginalFilename(), file.getSize());

try {
// 파일 저장 및 문서 생성 (FileStorageService에서 검증 수행)
// File storage and document creation (validation performed in FileStorageService)
SourceDocument sourceDocument = fileStorageService.uploadFileWithMetadata(file);
log.info("File saved successfully: documentId={}, filename={}",
sourceDocument.getId(), sourceDocument.getOriginalFilename());

// 비동기 수집 파이프라인 시작
// Start asynchronous ingestion pipeline
processIngestionPipeline(sourceDocument.getId());

// 응답 생성
// Create response
SourceUploadResponse response = SourceUploadResponse.success(
sourceDocument.getId().toString(),
sourceDocument.getOriginalFilename()
Expand All @@ -99,17 +99,17 @@ public ResponseEntity<CommonResponse<SourceUploadResponse>> uploadFile(
} catch (Exception e) {
log.error("Unexpected error during file upload", e);
return ResponseEntity.internalServerError()
.body(CommonResponse.error("파일 업로드 중 오류가 발생했습니다: " + e.getMessage()));
.body(CommonResponse.error("An error occurred during file upload: " + e.getMessage()));
}
}

/**
* 업로드된 모든 문서의 최신 상태 목록 조회
* Retrieve latest status list of all uploaded documents
*
* @param page 페이지 번호 (0부터 시작)
* @param size 페이지 크기
* @param sort 정렬 조건
* @return 페이지네이션된 문서 목록
* @param page Page number (starting from 0)
* @param size Page size
* @param sort Sorting criteria
* @return Paginated document list
*/
@Override
@GetMapping
Expand All @@ -120,14 +120,14 @@ public ResponseEntity<CommonResponse<PageResponse<SourceDocumentDto>>> getAllSou
log.debug("Getting source documents: page={}, size={}, sort={}", page, size, sort);

try {
// 정렬 조건 파싱
// Parse sorting criteria
Sort sortObj = parseSort(sort);
Pageable pageable = PageRequest.of(page, size, sortObj);

// 문서 목록 조회
// Retrieve document list
Page<SourceDocument> documentPage = sourceDocumentRepository.findAll(pageable);

// DTO 변환
// Convert to DTO
List<SourceDocumentDto> documentDtos = documentPage.getContent().stream()
.map(this::convertToDto)
.toList();
Expand All @@ -149,43 +149,43 @@ public ResponseEntity<CommonResponse<PageResponse<SourceDocumentDto>>> getAllSou
} catch (Exception e) {
log.error("Failed to get source documents", e);
return ResponseEntity.internalServerError()
.body(CommonResponse.error("문서 목록 조회 중 오류가 발생했습니다: " + e.getMessage()));
.body(CommonResponse.error("An error occurred while retrieving document list: " + e.getMessage()));
}
}

/**
* 특정 문서를 강제로 재수집
* Force re-ingestion of a specific document
*
* @param sourceId 재수집할 문서 ID
* @return 재수집 시작 응답
* @param sourceId Document ID to re-ingest
* @return Re-ingestion start response
*/
@Override
@PostMapping("/{sourceId}/resync")
public ResponseEntity<CommonResponse<String>> resyncSourceDocument(@PathVariable UUID sourceId) {
log.info("Document resync requested: sourceId={}", sourceId);

try {
// 문서 존재 확인
// Check if document exists
SourceDocument sourceDocument = findSourceDocumentById(sourceId);

// 처리 중인 문서인지 확인
// Check if document is being processed
if (sourceDocument.isProcessing()) {
throw new BusinessException(ErrorCode.RESOURCE_IS_BEING_PROCESSED,
"문서가 이미 처리 중입니다.");
"Document is already being processed.");
}

// 상태를 PENDING으로 초기화
// Reset status to PENDING
sourceDocument.updateIngestionStatus(IngestionStatus.PENDING);
sourceDocument.clearErrorMessage();
sourceDocumentRepository.save(sourceDocument);

// 비동기 수집 파이프라인 시작
// Start asynchronous ingestion pipeline
processIngestionPipeline(sourceId);

log.info("Document resync started successfully: sourceId={}", sourceId);

return ResponseEntity.status(HttpStatus.ACCEPTED)
.body(CommonResponse.success("문서 재수집이 시작되었습니다."));
.body(CommonResponse.success("Document re-ingestion has started."));

} catch (BusinessException e) {
log.error("Document resync failed: sourceId={}, error={}", sourceId, e.getMessage());
Expand All @@ -194,42 +194,42 @@ public ResponseEntity<CommonResponse<String>> resyncSourceDocument(@PathVariable
} catch (Exception e) {
log.error("Unexpected error during document resync: sourceId={}", sourceId, e);
return ResponseEntity.internalServerError()
.body(CommonResponse.error("문서 재수집 중 오류가 발생했습니다: " + e.getMessage()));
.body(CommonResponse.error("An error occurred during document re-ingestion: " + e.getMessage()));
}
}

/**
* 특정 문서를 시스템에서 영구적으로 삭제
* Permanently delete a specific document from the system
*
* @param sourceId 삭제할 문서 ID
* @return 삭제 시작 응답
* @param sourceId Document ID to delete
* @return Deletion start response
*/
@Override
@DeleteMapping("/{sourceId}")
public ResponseEntity<CommonResponse<String>> deleteSourceDocument(@PathVariable UUID sourceId) {
log.info("Document deletion requested: sourceId={}", sourceId);

try {
// 문서 존재 확인
// Check if document exists
SourceDocument sourceDocument = findSourceDocumentById(sourceId);

// 처리 중인 문서인지 확인
// Check if document is being processed
if (sourceDocument.isProcessing()) {
throw new BusinessException(ErrorCode.RESOURCE_IS_BEING_PROCESSED,
"처리 중인 문서는 삭제할 수 없습니다.");
"Documents being processed cannot be deleted.");
}

// 삭제 상태로 변경
// Change status to DELETING
sourceDocument.updateIngestionStatus(IngestionStatus.DELETING);
sourceDocumentRepository.save(sourceDocument);

// 비동기 삭제 파이프라인 시작
// Start asynchronous deletion pipeline
processDeletionPipeline(sourceId);

log.info("Document deletion started successfully: sourceId={}", sourceId);

return ResponseEntity.status(HttpStatus.ACCEPTED)
.body(CommonResponse.success("문서 삭제가 시작되었습니다."));
.body(CommonResponse.success("Document deletion has started."));

} catch (BusinessException e) {
log.error("Document deletion failed: sourceId={}, error={}", sourceId, e.getMessage());
Expand All @@ -238,12 +238,12 @@ public ResponseEntity<CommonResponse<String>> deleteSourceDocument(@PathVariable
} catch (Exception e) {
log.error("Unexpected error during document deletion: sourceId={}", sourceId, e);
return ResponseEntity.internalServerError()
.body(CommonResponse.error("문서 삭제 중 오류가 발생했습니다: " + e.getMessage()));
.body(CommonResponse.error("An error occurred during document deletion: " + e.getMessage()));
}
}

/**
* 문서 수집 파이프라인을 비동기적으로 실행합니다.
* Executes the document ingestion pipeline asynchronously.
*/
@Async
@Transactional
Expand Down Expand Up @@ -293,7 +293,7 @@ public void processIngestionPipeline(UUID documentId) {
}

/**
* 문서 삭제 파이프라인을 비동기적으로 실행합니다.
* Executes the document deletion pipeline asynchronously.
*/
@Async
public void processDeletionPipeline(UUID documentId) {
Expand Down Expand Up @@ -326,12 +326,12 @@ public void processDeletionPipeline(UUID documentId) {


/**
* Elasticsearch에서 문서 관련 청크들을 삭제합니다.
* Deletes document-related chunks from Elasticsearch.
*/
@Transactional
private void deleteFromElasticsearch(UUID documentId) {
try {
// 문서 ID로 쿼리하여 관련 청크들을 삭제
// Query by document ID to delete related chunks
String query = String.format("""
{
"query": {
Expand Down Expand Up @@ -363,7 +363,7 @@ private void deleteFromElasticsearch(UUID documentId) {
}

/**
* PostgreSQL에서 문서 청크들을 삭제합니다.
* Deletes document chunks from PostgreSQL.
*/
@Transactional
private void deleteChunksFromPostgreSQL(UUID documentId) {
Expand All @@ -378,10 +378,10 @@ private void deleteChunksFromPostgreSQL(UUID documentId) {
}
}

// ===== 헬퍼 메소드들 =====
// ===== Helper Methods =====

/**
* 정렬 조건 파싱
* Parse sorting criteria
*/
private Sort parseSort(String sortParam) {
try {
Expand All @@ -401,7 +401,7 @@ private Sort parseSort(String sortParam) {
}

/**
* SourceDocument를 DTO로 변환
* Convert SourceDocument to DTO
*/
private SourceDocumentDto convertToDto(SourceDocument document) {
return SourceDocumentDto.builder()
Expand All @@ -418,16 +418,16 @@ private SourceDocumentDto convertToDto(SourceDocument document) {
}

/**
* ID로 SourceDocument 조회 (없으면 예외 발생)
* Find SourceDocument by ID (throws exception if not found)
*/
private SourceDocument findSourceDocumentById(UUID sourceId) {
return sourceDocumentRepository.findById(sourceId)
.orElseThrow(() -> new BusinessException(ErrorCode.SOURCE_DOCUMENT_NOT_FOUND,
"해당 ID의 문서를 찾을 수 없습니다: " + sourceId));
"Document with the specified ID not found: " + sourceId));
}

/**
* ErrorCode에 따른 HTTP 상태 코드 반환
* Return HTTP status code based on ErrorCode
*/
private HttpStatus getHttpStatusFromErrorCode(ErrorCode errorCode) {
return switch (errorCode) {
Expand Down
Loading