Noti api 설계하기

                                    client

1. 인플루언서 A로부터 noti생성
- User A는 1만명의 팔로워를 보유한 인플루언서이다.
- A는 오늘 낮에 "친구들과 깜짝파티. 너무 즐겁고 행복한 순간을 만들어줘서 고마워친구들아. 항상행복하자 우리"
 라는 메세지와 여러 파티사진이 담긴 포스터를 발행하였다.

2. 팔로워 B로 부터 noti 요청
- User B는 A의를 팔로우중인 A의 팬이다. 그는 오늘 점심시간에 밥을 먹으며
X를 보던 중이었는데 UserA가 새로 발행한 "친구들과 깜짝파티. 너무 즐겁고 행복한 순간을..."이라는
noti를 받게된다.

                                    CREATE TABLE notifications(
    id BIGINT PRIMARY KEY Auto_increment,
    publisher_id BIGINT,
    receiver_id BIGINT,
    created_at datetime,
    noti_type int,
    board_id int,
)

CREATE INDEX idx_noti_receiver
ON notifications(receiver_id)

                                    @Service
class NotificationApiService(
    private val webConfig: WebConfig,
    private val circuitBreakerRegistry: CircuitBreakerRegistry,
    private val userRepository: UserRepository,
    private val boardRepository: BoardRepository,
    private val messageSource: MessageSource
)

                                    @CircuitBreaker(
        name = "notificationApiCircuitBreaker",
        fallbackMethod = "getInitFallbackMethod"
    )
    fun fetchInitAll(receiverId: Long, language: String): List<NotificationGetResult>  {
        val notiServerWebClient = webConfig.createWebClient(baseUrl, language)
        val response = notiServerWebClient.post()
            .uri { uriBuilder: UriBuilder ->
                uriBuilder
                    .path("/notification/init")
                    .build()
            }
            .bodyValue(
                receiverId
            )
            .retrieve()
            .onStatus({ it.isError }) { clientResponse ->
                // HTTP 상태코드가 에러일 때 처리
                clientResponse.bodyToMono(String::class.java).flatMap { errorBody ->
                    // 이곳에서 에러 내용 로깅
                    logger.error {"HTTP Error: ${clientResponse.statusCode()} / Body: $errorBody"}
                    throw RuntimeException("HTTP Error: ${clientResponse.statusCode()} - $errorBody")
                }
            }
                .bodyToMono(NotificationGetServerResponse::class.java)
            .block()

        val results = response?.serverResults ?: emptyList()
        logger.info { "response: $results" }

        return results.map {
            // make message by result's parameter
            val username = findUserNameById(it.publisherId)
            val imgYrl = findUserImgUrlById(it.publisherId)
            val targetBoard = it.targetBoardId?.let {
                id -> boardRepository.findById(id).orElse(null)
            }

            val message = makeMessage(it, username, language, targetBoard)
            NotificationGetResult.of(it, username, imgYrl, message)
        }
        // return noti server response
    }