-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: CF-00004/CF-00005 케이스 핸들링 (#47)
* chore: 로깅 중복 로직 수정 * refactor/style: 리팩토링 및 스타일 포맷팅 * feat: CF-00004/CF-00005 케이스 Exception Handling * refactor: 로깅부 분리
- Loading branch information
Showing
17 changed files
with
411 additions
and
340 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,185 @@ | ||
| package io.codef.api; | ||
|
|
||
| import com.alibaba.fastjson2.JSON; | ||
| import io.codef.api.dto.EasyCodefResponse; | ||
| import io.codef.api.util.JsonUtil; | ||
| import org.apache.hc.client5.http.classic.methods.HttpPost; | ||
| import org.apache.hc.core5.http.ClassicHttpResponse; | ||
| import org.slf4j.Logger; | ||
| import org.slf4j.LoggerFactory; | ||
|
|
||
| import java.time.LocalDateTime; | ||
| import java.util.List; | ||
| import java.util.Optional; | ||
|
|
||
| import static io.codef.api.constants.CodefResponseCode.*; | ||
|
|
||
| public class EasyCodefLogger { | ||
| private static final Logger log = LoggerFactory.getLogger(EasyCodefLogger.class); | ||
|
|
||
| private EasyCodefLogger() { | ||
| } | ||
|
|
||
| public static void logRequest(HttpPost request) { | ||
| log.info("[{}] Codef API Request", request.hashCode()); | ||
| log.info("> Request Host: {}://{}", | ||
| request.getScheme(), | ||
| request.getAuthority() | ||
| ); | ||
| log.info("> Request URI: {}\n", request.getRequestUri()); | ||
| } | ||
|
|
||
| public static void logResponse( | ||
| int requestHashCode, | ||
| ClassicHttpResponse response, | ||
| Object result | ||
| ) { | ||
| log.info("[{}] Codef API Response", requestHashCode); | ||
| log.info("> Response Status: {}", response.getCode()); | ||
| log.info("> Response → \n{}\n", JsonUtil.toPrettyJson(result)); | ||
| } | ||
|
|
||
| public static void logResponseStatus(EasyCodefResponse response) { | ||
| logBasicInfo(response); | ||
|
|
||
| switch (response.code()) { | ||
| case CF_00000: | ||
| logSuccessResponse(); | ||
| break; | ||
|
|
||
| case CF_03002: | ||
| logAddAuthRequired(response); | ||
| break; | ||
|
|
||
| case CF_12872: | ||
| logAuthExceeded(); | ||
| break; | ||
|
|
||
| default: | ||
| logError(response); | ||
| break; | ||
| } | ||
| } | ||
|
|
||
| public static void logStatusSummary(List<EasyCodefResponse> responses) { | ||
| long successCount = responses.stream().filter(ResponseHandler::isSuccessResponse).count(); | ||
| long addAuthCount = responses.stream().filter(ResponseHandler::isAddAuthResponse).count(); | ||
| long failureCount = responses.stream().filter(ResponseHandler::isFailureResponse).count(); | ||
|
|
||
| log.info("Total Responses Count = {}\n", responses.size()); | ||
| logStatus(successCount, addAuthCount, failureCount); | ||
| } | ||
|
|
||
| private static void logBasicInfo(EasyCodefResponse response) { | ||
| log.info("Response Status Code : {}", response.code()); | ||
| log.info("Transaction Id : {}", response.transactionId()); | ||
| } | ||
|
|
||
| private static void logSuccessResponse() { | ||
| log.info("Successfully returned Value from Codef API\n"); | ||
| } | ||
|
|
||
| private static void logAddAuthRequired(EasyCodefResponse response) { | ||
| Object data = response.data(); | ||
| String addAuthMethod = JSON.parseObject(data.toString()).getString("method"); | ||
| log.warn("Additional authentication required | method : {}\n", addAuthMethod); | ||
| } | ||
|
|
||
| private static void logAuthExceeded() { | ||
| log.error("Retry limit for additional authentication exceeded. " | ||
| + "Please restart the process from the initial request.\n"); | ||
| } | ||
|
|
||
| private static void logError(EasyCodefResponse response) { | ||
| log.error("Failed to get proper scrapping response. Check the Error errorMessage And StatusCode"); | ||
| log.error("> message : {}", response.result().message()); | ||
| log.error("> extraMessage : {}", response.result().extraMessage()); | ||
| } | ||
|
|
||
| private static void logStatus( | ||
| long successCount, | ||
| long addAuthCount, | ||
| long failureCount | ||
| ) { | ||
| Optional.of(successCount) | ||
| .filter(EasyCodefLogger::isExist) | ||
| .ifPresent(count -> log.info("Success Response Status [ {} ] Count : {}", CF_00000, count)); | ||
|
|
||
| Optional.of(addAuthCount) | ||
| .filter(EasyCodefLogger::isExist) | ||
| .ifPresent(count -> log.info("AddAuth Response Status [ {} ] Count : {}", CF_03002, count)); | ||
|
|
||
| Optional.of(failureCount) | ||
| .filter(EasyCodefLogger::isExist) | ||
| .ifPresentOrElse( | ||
| count -> log.warn("Failure Response Status [ Else ] Count : {}\n", count), | ||
| () -> log.info("No Failure Responses\n") | ||
| ); | ||
| } | ||
|
|
||
| private static boolean isExist(Long count) { | ||
| return count > 0; | ||
| } | ||
|
|
||
| protected static void logInitializeSuccessfully() { | ||
| log.info(""" | ||
| ------. ,-----. ,--. ,---.\s | ||
| | .---' ,--,--. ,---.,--. ,--.' .--./ ,---. ,-| |,---. / .-'\s | ||
| | `--, ' ,-. |( .-' \\ ' / | | | .-. |' .-. | .-. :| `-,\s | ||
| | `---.\\ '-' |.-' `) \\ ' ' '--'\\' '-' '\\ `-' \\ --.| .-'\s | ||
| `------' `--`--'`----'.-' / `-----' `---' `---' `----'`--' \s | ||
| > EasyCodef v2.0.0-beta-005 Successfully Initialized! Hello worlds! | ||
| """ | ||
| ); | ||
| } | ||
|
|
||
| protected static void logOAuthTokenCreation(String oauthToken) { | ||
| log.info("Codef OAuth Token : {}", oauthToken); | ||
| log.info("Codef OAuth Token successfully initialized.\n"); | ||
| } | ||
|
|
||
| protected static void logAccessTokenCreation( | ||
| String accessToken, | ||
| LocalDateTime expiresAt | ||
| ) { | ||
| logAccessToken(accessToken); | ||
| log.info( | ||
| "Codef API AccessToken expiry at {}. Also, EasyCodef will handle automatic renewal.", | ||
| expiresAt | ||
| ); | ||
| log.info("Codef API AccessToken successfully initialized.\n"); | ||
| } | ||
|
|
||
| protected static void logTokenRefreshStart(LocalDateTime expiresAt) { | ||
| log.info( | ||
| "Codef API AccessToken expiry at {} so EasyCodef refresh token", | ||
| expiresAt | ||
| ); | ||
| } | ||
|
|
||
| public static void logAwaitResponseCounts(List<EasyCodefResponse> results) { | ||
| log.info("Await Responses Count = {}", results.size()); | ||
| } | ||
|
|
||
| public static void logAwaitResponse(String transactionId) { | ||
| log.info("Await Responses called By transactionId: {}", transactionId); | ||
| } | ||
|
|
||
| protected static void logTokenRefreshCompletion( | ||
| String accessToken, | ||
| LocalDateTime expiresAt | ||
| ) { | ||
| logAccessToken(accessToken); | ||
| log.info( | ||
| "AccessToken Refresh completed. Now, Codef accessToken expiry at {}.", | ||
| expiresAt | ||
| ); | ||
| } | ||
|
|
||
| private static void logAccessToken(String accessToken) { | ||
| log.info("Codef API AccessToken : {}", accessToken); | ||
| } | ||
| } |
Oops, something went wrong.