update the package name
[dmaap/messagerouter/msgrtr.git] / src / main / java / org / onap / dmaap / dmf / mr / exception / DMaaPWebExceptionMapper.java
1 /*******************************************************************************
2  *  ============LICENSE_START=======================================================
3  *  org.onap.dmaap
4  *  ================================================================================
5  *  Copyright © 2017 AT&T Intellectual Property. All rights reserved.
6  *  ================================================================================
7  *  Licensed under the Apache License, Version 2.0 (the "License");
8  *  you may not use this file except in compliance with the License.
9  *  You may obtain a copy of the License at
10  *        http://www.apache.org/licenses/LICENSE-2.0
11 *  
12  *  Unless required by applicable law or agreed to in writing, software
13  *  distributed under the License is distributed on an "AS IS" BASIS,
14  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  *  See the License for the specific language governing permissions and
16  *  limitations under the License.
17  *  ============LICENSE_END=========================================================
18  *  
19  *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
20  *  
21  *******************************************************************************/
22 package org.onap.dmaap.dmf.mr.exception;
23
24 import javax.inject.Singleton;
25 import javax.ws.rs.BadRequestException;
26 import javax.ws.rs.InternalServerErrorException;
27 import javax.ws.rs.NotAllowedException;
28 import javax.ws.rs.NotAuthorizedException;
29 import javax.ws.rs.NotFoundException;
30 import javax.ws.rs.ServiceUnavailableException;
31 import javax.ws.rs.WebApplicationException;
32 import javax.ws.rs.core.MediaType;
33 import javax.ws.rs.core.Response;
34 import javax.ws.rs.ext.ExceptionMapper;
35 import javax.ws.rs.ext.Provider;
36
37 import org.apache.http.HttpStatus;
38
39 import org.springframework.beans.factory.annotation.Autowired;
40
41 import com.att.eelf.configuration.EELFLogger;
42 import com.att.eelf.configuration.EELFManager;
43
44 /**
45  * Exception Mapper class to handle
46  * Jersey Exceptions
47  * @author rajashree.khare
48  *
49  */
50 @Provider
51 @Singleton
52 public class DMaaPWebExceptionMapper implements ExceptionMapper<WebApplicationException>{
53         
54         
55         private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(DMaaPWebExceptionMapper.class);
56         private ErrorResponse errRes;
57         
58         @Autowired
59         private DMaaPErrorMessages msgs;
60         
61         public DMaaPWebExceptionMapper() {
62                 super();
63                 LOGGER.info("WebException Mapper Created..");
64         }
65
66         @Override
67         public Response toResponse(WebApplicationException ex) {
68                 
69                 LOGGER.info("Reached WebException Mapper");
70                 
71                 /**
72                  * Resource Not Found
73                  */
74                 if(ex instanceof NotFoundException)
75                 {
76                         errRes = new ErrorResponse(HttpStatus.SC_NOT_FOUND,DMaaPResponseCode.RESOURCE_NOT_FOUND.getResponseCode(),msgs.getNotFound());
77                         
78                         LOGGER.info(errRes.toString());
79                         
80                         return Response.status(errRes.getHttpStatusCode()).entity(errRes).type(MediaType.APPLICATION_JSON)
81                             .build();
82                         
83                 }
84                 
85                 if(ex instanceof InternalServerErrorException)
86                 {
87                         errRes = new ErrorResponse(HttpStatus.SC_INTERNAL_SERVER_ERROR,DMaaPResponseCode.SERVER_UNAVAILABLE.getResponseCode(),msgs.getServerUnav());
88                         
89                         LOGGER.info(errRes.toString());
90                         return Response.status(errRes.getHttpStatusCode()).entity(errRes).type(MediaType.APPLICATION_JSON)
91                             .build();
92                         
93                 }
94                 
95                 if(ex instanceof NotAuthorizedException)
96                 {
97                         errRes = new ErrorResponse(HttpStatus.SC_UNAUTHORIZED,DMaaPResponseCode.ACCESS_NOT_PERMITTED.getResponseCode(),msgs.getAuthFailure());
98                         
99                         LOGGER.info(errRes.toString());
100                         return Response.status(errRes.getHttpStatusCode()).entity(errRes).type(MediaType.APPLICATION_JSON)
101                             .build();
102                 }
103                 
104                 if(ex instanceof BadRequestException)
105                 {
106                         errRes = new ErrorResponse(HttpStatus.SC_BAD_REQUEST,DMaaPResponseCode.INCORRECT_JSON.getResponseCode(),msgs.getBadRequest());
107                         
108                         LOGGER.info(errRes.toString());
109                         return Response.status(errRes.getHttpStatusCode()).entity(errRes).type(MediaType.APPLICATION_JSON)
110                             .build();
111                 }
112                 if(ex instanceof NotAllowedException)
113                 {
114                         errRes = new ErrorResponse(HttpStatus.SC_METHOD_NOT_ALLOWED,DMaaPResponseCode.METHOD_NOT_ALLOWED.getResponseCode(),msgs.getMethodNotAllowed());
115                         
116                         LOGGER.info(errRes.toString());
117                         return Response.status(errRes.getHttpStatusCode()).entity(errRes).type(MediaType.APPLICATION_JSON)
118                             .build();
119                 }
120                 
121                 if(ex instanceof ServiceUnavailableException)
122                 {
123                         errRes = new ErrorResponse(HttpStatus.SC_SERVICE_UNAVAILABLE,DMaaPResponseCode.SERVER_UNAVAILABLE.getResponseCode(),msgs.getServerUnav());
124                         
125                         LOGGER.info(errRes.toString());
126                         return Response.status(errRes.getHttpStatusCode()).entity(errRes).type(MediaType.APPLICATION_JSON)
127                             .build();
128                 }
129                 
130                 
131                 return Response.serverError().build();
132         }
133
134         
135
136         
137 }