Merge pull request #18 from EntryDSM/feature/13-gRPC

Feature/13 gRPC

Author: coehgns

casper-schedule/src/main/kotlin/hs/kr/entrydsm/schedule/infrastructure/grpc/server/ScheduleGrpcService.kt

@@ -0,0 +1,38 @@
+package hs.kr.entrydsm.schedule.infrastructure.grpc.server
+
+import hs.kr.entrydsm.casper.schedule.proto.ScheduleServiceGrpcKt
+import hs.kr.entrydsm.casper.schedule.proto.ScheduleServiceProto
+import hs.kr.entrydsm.schedule.domain.schedule.application.port.`in`.QueryScheduleByTypeUseCase
+import hs.kr.entrydsm.schedule.infrastructure.grpc.dto.response.InternalScheduleResponse
+import hs.kr.entrydsm.schedule.infrastructure.grpc.server.mapper.ScheduleGrpcMapper
+import net.devh.boot.grpc.server.service.GrpcService
+
+/**
+ * gRPC 서버 구현체로, 스케줄 관련 gRPC 요청을 처리합니다.
+ * ScheduleService gRPC 서비스 정의를 구현하며, 클라이언트로부터의 스케줄 조회 요청을 처리합니다.
+ *
+ * @property scheduleGrpcMapper 도메인 모델과 gRPC 메시지 간의 변환을 담당하는 매퍼
+ * @property queryScheduleByTypeUseCase 특정 유형의 스케줄을 조회하기 위한 유스케이스
+ */
+@GrpcService
+class ScheduleGrpcService(
+    private val scheduleGrpcMapper: ScheduleGrpcMapper,
+    private val queryScheduleByTypeUseCase: QueryScheduleByTypeUseCase
+) : ScheduleServiceGrpcKt.ScheduleServiceCoroutineImplBase() {
+
+    /**
+     * 주어진 타입에 해당하는 스케줄을 조회합니다.
+     *
+     * @param request 조회할 스케줄의 타입이 포함된 요청 메시지
+     * @return 조회된 스케줄 정보가 포함된 응답 메시지
+     * @throws hs.kr.entrydsm.common.exception.BusinessException 해당 타입의 스케줄이 존재하지 않는 경우 발생
+     */
+    override suspend fun getScheduleByType(request: ScheduleServiceProto.TypeRequest): ScheduleServiceProto.GetScheduleResponse {
+        val schedule = queryScheduleByTypeUseCase.execute(request.type.toString())
+        val internalScheduleResponse = InternalScheduleResponse(
+            type = schedule.type,
+            date = schedule.date.toString()
+        )
+        return scheduleGrpcMapper.toGetScheduleByTypeResponse(internalScheduleResponse)
+    }
+}

casper-schedule/src/main/kotlin/hs/kr/entrydsm/schedule/infrastructure/grpc/server/dto/response/InternalScheduleResponse.kt

@@ -0,0 +1,15 @@
+package hs.kr.entrydsm.schedule.infrastructure.grpc.dto.response
+
+import hs.kr.entrydsm.schedule.domain.schedule.model.type.Type
+
+/**
+ * 내부적으로 사용되는 스케줄 응답 데이터 클래스입니다.
+ * 이 클래스는 도메인 계층과 인프라스트럭처 계층 간의 데이터 전달에 사용됩니다.
+ *
+ * @property type 스케줄의 유형 (시작일, 1차 발표일 등)
+ * @property date 스케줄 날짜 (문자열 형식)
+ */
+data class InternalScheduleResponse(
+    val type: Type,
+    val date: String
+)

casper-schedule/src/main/kotlin/hs/kr/entrydsm/schedule/infrastructure/grpc/server/mapper/ScheduleGrpcMapper.kt

@@ -0,0 +1,50 @@
+package hs.kr.entrydsm.schedule.infrastructure.grpc.server.mapper
+
+import hs.kr.entrydsm.casper.schedule.proto.ScheduleServiceProto
+import hs.kr.entrydsm.schedule.domain.schedule.model.type.Type
+import hs.kr.entrydsm.schedule.infrastructure.grpc.dto.response.InternalScheduleResponse
+import org.springframework.stereotype.Component
+
+/**
+ * 도메인 모델과 gRPC 메시지 간의 변환을 담당하는 매퍼 클래스입니다.
+ * 이 클래스는 내부 도메인 모델과 gRPC 프로토콜 버퍼 메시지 간의 변환 로직을 캡슐화합니다.
+ */
+@Component
+class ScheduleGrpcMapper {
+    companion object {
+        /**
+         * 도메인 타입과 gRPC 프로토 타입 간의 매핑을 정의한 맵입니다.
+         * 이 맵은 도메인 모델의 Type과 프로토콜 버퍼의 Type 간의 변환을 위해 사용됩니다.
+         */
+        private val DOMAIN_TO_PROTO_MAP = mapOf(
+            Type.START_DATE to ScheduleServiceProto.Type.START_DATE,
+            Type.FIRST_ANNOUNCEMENT to ScheduleServiceProto.Type.FIRST_ANNOUNCEMENT,
+            Type.INTERVIEW to ScheduleServiceProto.Type.INTERVIEW,
+            Type.SECOND_ANNOUNCEMENT to ScheduleServiceProto.Type.SECOND_ANNOUNCEMENT,
+            Type.END_DATE to ScheduleServiceProto.Type.END_DATE
+        )
+    }
+
+    /**
+     * 내부 스케줄 응답을 gRPC 응답 메시지로 변환합니다.
+     *
+     * @param response 변환할 내부 스케줄 응답 객체
+     * @return gRPC 프로토콜 버퍼 형식의 응답 메시지
+     * @throws NoSuchElementException 매핑된 프로토 타입을 찾을 수 없는 경우 발생
+     */
+    fun toGetScheduleByTypeResponse(response: InternalScheduleResponse): ScheduleServiceProto.GetScheduleResponse {
+        return ScheduleServiceProto.GetScheduleResponse.newBuilder()
+            .setType(toProtoType(response.type))
+            .setDate(response.date)
+            .build()
+    }
+
+    /**
+     * 도메인 타입을 gRPC 프로토 타입으로 변환합니다.
+     *
+     * @param type 변환할 도메인 타입
+     * @return 변환된 gRPC 프로토 타입
+     * @throws NoSuchElementException 매핑된 프로토 타입을 찾을 수 없는 경우 발생
+     */
+    private fun toProtoType(type: Type): ScheduleServiceProto.Type = DOMAIN_TO_PROTO_MAP[type]!!
+}