#323 [feat] 알림 서버 추가

hous-notification/src/main/java/hous/notification/NotificationApplication.java

@@ -0,0 +1,16 @@
+package hous.notification;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.domain.EntityScan;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+@EnableFeignClients(basePackages = "hous.external")
+@EntityScan("hous.core")
+@SpringBootApplication(scanBasePackages = {"hous.core", "hous.common", "hous.external", "hous.notification"})
+public class NotificationApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(NotificationApplication.class, args);
+	}
+}

hous-notification/src/main/java/hous/notification/controller/advice/ControllerExceptionAdvice.java

@@ -0,0 +1,189 @@
+package hous.notification.controller.advice;
+
+import static hous.common.exception.ErrorCode.*;
+
+import java.util.Objects;
+
+import javax.validation.ConstraintViolationException;
+
+import org.springframework.beans.TypeMismatchException;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.http.converter.HttpMessageNotReadableException;
+import org.springframework.validation.BindException;
+import org.springframework.validation.FieldError;
+import org.springframework.web.HttpMediaTypeException;
+import org.springframework.web.HttpMediaTypeNotAcceptableException;
+import org.springframework.web.HttpRequestMethodNotSupportedException;
+import org.springframework.web.bind.MissingRequestValueException;
+import org.springframework.web.bind.ServletRequestBindingException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import org.springframework.web.method.annotation.MethodArgumentTypeMismatchException;
+
+import com.fasterxml.jackson.databind.exc.InvalidFormatException;
+
+import hous.common.dto.ErrorResponse;
+import hous.common.exception.FeignClientException;
+import hous.common.exception.HousException;
+import hous.notification.service.slack.SlackService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@RestControllerAdvice
+@AllArgsConstructor
+public class ControllerExceptionAdvice {
+	private final SlackService slackService;
+
+	/**
+	 * Hous Custom Exception
+	 */
+	@ExceptionHandler(HousException.class)
+	protected ResponseEntity<ErrorResponse> handleBaseException(HousException exception) {
+		if (exception.getStatus() >= 400 && exception.getStatus() < 500) {
+			log.warn(exception.getMessage(), exception);
+		} else {
+			log.error(exception.getMessage(), exception);
+			slackService.sendSlackMessageProductError(exception);
+		}
+		return ResponseEntity.status(exception.getStatus())
+			.body(ErrorResponse.error(exception.getErrorCode()));
+	}
+
+	/**
+	 * Feign Client Exception
+	 */
+	@ExceptionHandler(FeignClientException.class)
+	protected ResponseEntity<ErrorResponse> handleFeignClientException(final FeignClientException exception) {
+		if (exception.getStatus() >= 400 && exception.getStatus() < 500) {
+			log.warn(exception.getMessage(), exception);
+		} else {
+			log.error(exception.getMessage(), exception);
+			slackService.sendSlackMessageProductError(exception);
+		}
+		if (exception.getStatus() == UNAUTHORIZED_INVALID_TOKEN_EXCEPTION.getStatus()) {
+			return ResponseEntity.status(UNAUTHORIZED_INVALID_TOKEN_EXCEPTION.getStatus())
+				.body(ErrorResponse.error(UNAUTHORIZED_INVALID_TOKEN_EXCEPTION));
+		}
+		return ResponseEntity.status(INTERNAL_SERVER_EXCEPTION.getStatus())
+			.body(ErrorResponse.error(INTERNAL_SERVER_EXCEPTION));
+	}
+
+	/**
+	 * 400 BadRequest
+	 * Spring Validation
+	 */
+	@ResponseStatus(HttpStatus.BAD_REQUEST)
+	@ExceptionHandler(BindException.class)
+	protected ErrorResponse handleBadRequest(final BindException exception) {
+		log.warn(exception.getMessage());
+		FieldError fieldError = Objects.requireNonNull(exception.getFieldError());
+		return ErrorResponse.error(VALIDATION_EXCEPTION,
+			String.format("%s (%s)", fieldError.getDefaultMessage(), fieldError.getField()));
+	}
+
+	/**
+	 * 400 BadRequest
+	 * Pageable에 허용하지 않는 정렬기준이 입력된 경우 발생하는 Exception
+	 */
+	@ResponseStatus(HttpStatus.BAD_REQUEST)
+	@ExceptionHandler(ConstraintViolationException.class)
+	protected ErrorResponse handleConstraintViolationException(final ConstraintViolationException exception) {
+		log.warn(exception.getMessage());
+		return ErrorResponse.error(VALIDATION_SORT_TYPE_EXCEPTION);
+	}
+
+	/**
+	 * 400 BadRequest
+	 * 잘못된 Enum 값이 입력된 경우 발생하는 Exception
+	 */
+	@ResponseStatus(HttpStatus.BAD_REQUEST)
+	@ExceptionHandler(HttpMessageNotReadableException.class)
+	protected ErrorResponse handleHttpMessageNotReadableException(final HttpMessageNotReadableException exception) {
+		log.warn(exception.getMessage());
+		return ErrorResponse.error(VALIDATION_ENUM_VALUE_EXCEPTION);
+	}
+
+	/**
+	 * 400 BadRequest
+	 * RequestParam, RequestPath, RequestPart 등의 필드가 입력되지 않은 경우 발생하는 Exception
+	 */
+	@ResponseStatus(HttpStatus.BAD_REQUEST)
+	@ExceptionHandler(MissingRequestValueException.class)
+	protected ErrorResponse handle(final MissingRequestValueException exception) {
+		log.warn(exception.getMessage());
+		return ErrorResponse.error(VALIDATION_REQUEST_MISSING_EXCEPTION);
+	}
+
+	/**
+	 * 400 BadRequest
+	 * 잘못된 타입이 입력된 경우 발생하는 Exception
+	 */
+	@ResponseStatus(HttpStatus.BAD_REQUEST)
+	@ExceptionHandler(TypeMismatchException.class)
+	protected ErrorResponse handleTypeMismatchException(final TypeMismatchException exception) {
+		log.warn(exception.getMessage());
+		return ErrorResponse.error(VALIDATION_WRONG_TYPE_EXCEPTION,
+			String.format("%s (%s)", VALIDATION_WRONG_TYPE_EXCEPTION.getMessage(), exception.getValue()));
+	}
+
+	/**
+	 * 400 BadRequest
+	 */
+	@ResponseStatus(HttpStatus.BAD_REQUEST)
+	@ExceptionHandler({
+		InvalidFormatException.class,
+		ServletRequestBindingException.class,
+		MethodArgumentTypeMismatchException.class
+	})
+	protected ErrorResponse handleInvalidFormatException(final Exception exception) {
+		log.warn(exception.getMessage());
+		return ErrorResponse.error(VALIDATION_EXCEPTION);
+	}
+
+	/**
+	 * 405 Method Not Allowed
+	 * 지원하지 않은 HTTP method 호출 할 경우 발생하는 Exception
+	 */
+	@ResponseStatus(HttpStatus.METHOD_NOT_ALLOWED)
+	@ExceptionHandler(HttpRequestMethodNotSupportedException.class)
+	protected ErrorResponse handleHttpRequestMethodNotSupportedException(
+		HttpRequestMethodNotSupportedException exception) {
+		log.warn(exception.getMessage());
+		return ErrorResponse.error(METHOD_NOT_ALLOWED_EXCEPTION);
+	}
+
+	/**
+	 * 406 Not Acceptable
+	 */
+	@ResponseStatus(HttpStatus.NOT_ACCEPTABLE)
+	@ExceptionHandler(HttpMediaTypeNotAcceptableException.class)
+	protected ErrorResponse handleHttpMediaTypeNotAcceptableException(HttpMediaTypeNotAcceptableException exception) {
+		log.warn(exception.getMessage());
+		return ErrorResponse.error(NOT_ACCEPTABLE_EXCEPTION);
+	}
+
+	/**
+	 * 415 UnSupported Media Type
+	 * 지원하지 않는 미디어 타입인 경우 발생하는 Exception
+	 */
+	@ResponseStatus(HttpStatus.UNSUPPORTED_MEDIA_TYPE)
+	@ExceptionHandler(HttpMediaTypeException.class)
+	protected ErrorResponse handleHttpMediaTypeException(final HttpMediaTypeException exception) {
+		log.warn(exception.getMessage(), exception);
+		return ErrorResponse.error(UNSUPPORTED_MEDIA_TYPE_EXCEPTION);
+	}
+
+	/**
+	 * 500 Internal Server
+	 */
+	@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
+	@ExceptionHandler(Exception.class)
+	protected ErrorResponse handleException(final Exception exception) {
+		log.error(exception.getMessage(), exception);
+		slackService.sendSlackMessageProductError(exception);
+		return ErrorResponse.error(INTERNAL_SERVER_EXCEPTION);
+	}
+}