summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att/mr/filter
diff options
context:
space:
mode:
authorsunil unnava <sunil.unnava@att.com>2018-10-23 12:18:59 -0400
committersunil unnava <sunil.unnava@att.com>2018-10-23 12:22:02 -0400
commit3504265229c589ecc166e3ad4c33bb198b11e4ce (patch)
tree022235018aa3ad863eaf24862543bbd509f35a21 /src/main/java/com/att/mr/filter
parent8a3dfd3fe521f18ce07c2d24202a51b28d424fa2 (diff)
update the package name1.1.11
Issue-ID: DMAAP-858 Change-Id: I49ae6eb9c51a261b64b911e607fcbbca46c5423c Signed-off-by: sunil unnava <sunil.unnava@att.com>
Diffstat (limited to 'src/main/java/com/att/mr/filter')
-rw-r--r--src/main/java/com/att/mr/filter/ContentLengthFilter.java134
-rw-r--r--src/main/java/com/att/mr/filter/DefaultLength.java37
2 files changed, 0 insertions, 171 deletions
diff --git a/src/main/java/com/att/mr/filter/ContentLengthFilter.java b/src/main/java/com/att/mr/filter/ContentLengthFilter.java
deleted file mode 100644
index 26f58e0..0000000
--- a/src/main/java/com/att/mr/filter/ContentLengthFilter.java
+++ /dev/null
@@ -1,134 +0,0 @@
-/*******************************************************************************
- * ============LICENSE_START=======================================================
- * org.onap.dmaap
- * ================================================================================
- * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * http://www.apache.org/licenses/LICENSE-2.0
-*
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- *
- * ECOMP is a trademark and service mark of AT&T Intellectual Property.
- *
- *******************************************************************************/
-package com.att.mr.filter;
-
-import java.io.IOException;
-
-import javax.servlet.Filter;
-import javax.servlet.FilterChain;
-import javax.servlet.FilterConfig;
-import javax.servlet.ServletException;
-import javax.servlet.ServletRequest;
-import javax.servlet.ServletResponse;
-import javax.servlet.http.HttpServletRequest;
-
-import org.apache.http.HttpStatus;
-import org.json.JSONObject;
-import org.springframework.context.ApplicationContext;
-import org.springframework.web.context.support.WebApplicationContextUtils;
-
-import com.att.dmf.mr.CambriaApiException;
-import com.att.dmf.mr.exception.DMaaPErrorMessages;
-import com.att.dmf.mr.exception.DMaaPResponseCode;
-import com.att.dmf.mr.exception.ErrorResponse;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-
-/**
- * Servlet Filter implementation class ContentLengthFilter
- */
-public class ContentLengthFilter implements Filter {
-
- private DefaultLength defaultLength;
-
- private FilterConfig filterConfig = null;
- DMaaPErrorMessages errorMessages = null;
-
- private static final EELFLogger log = EELFManager.getInstance().getLogger(ContentLengthFilter.class);
- /**
- * Default constructor.
- */
-
- public ContentLengthFilter() {
- // TODO Auto-generated constructor stub
- }
-
- /**
- * @see Filter#destroy()
- */
- public void destroy() {
- // TODO Auto-generated method stub
- }
-
- /**
- * @see Filter#doFilter(ServletRequest, ServletResponse, FilterChain)
- */
- public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) throws IOException,
- ServletException {
- // TODO Auto-generated method stub
- // place your code here
- log.info("inside servlet do filter content length checking before pub/sub");
- HttpServletRequest request = (HttpServletRequest) req;
- JSONObject jsonObj = null;
- int requestLength = 0;
- try {
- // retrieving content length from message header
-
- if (null != request.getHeader("Content-Length")) {
- requestLength = Integer.parseInt(request.getHeader("Content-Length"));
- }
- // retrieving encoding from message header
- String transferEncoding = request.getHeader("Transfer-Encoding");
- // checking for no encoding, chunked and requestLength greater then
- // default length
- if (null != transferEncoding && !(transferEncoding.contains("chunked"))
- && (requestLength > Integer.parseInt(defaultLength.getDefaultLength()))) {
- jsonObj = new JSONObject().append("defaultlength", defaultLength)
- .append("requestlength", requestLength);
- log.error("message length is greater than default");
- throw new CambriaApiException(jsonObj);
- } else if (null == transferEncoding && (requestLength > Integer.parseInt(defaultLength.getDefaultLength()))) {
- jsonObj = new JSONObject().append("defaultlength", defaultLength.getDefaultLength()).append(
- "requestlength", requestLength);
- log.error("Request message is not chunked or request length is greater than default length");
- throw new CambriaApiException(jsonObj);
- } else {
- chain.doFilter(req, res);
- }
- } catch (CambriaApiException | NumberFormatException e) {
- log.error("message size is greater then default");
- ErrorResponse errRes = new ErrorResponse(HttpStatus.SC_EXPECTATION_FAILED,
- DMaaPResponseCode.MSG_SIZE_EXCEEDS_MSG_LIMIT.getResponseCode(), errorMessages.getMsgSizeExceeds()
- + jsonObj.toString());
- log.info(errRes.toString());
-
- }
-
- }
-
- /**
- * @see Filter#init(FilterConfig)
- */
- public void init(FilterConfig fConfig) throws ServletException {
- // TODO Auto-generated method stub
- this.filterConfig = fConfig;
- log.info("Filter Content Length Initialize");
- ApplicationContext ctx = WebApplicationContextUtils.getRequiredWebApplicationContext(fConfig
- .getServletContext());
- DefaultLength defLength = (DefaultLength) ctx.getBean("defLength");
- DMaaPErrorMessages errorMessages = (DMaaPErrorMessages) ctx.getBean("DMaaPErrorMessages");
- this.errorMessages = errorMessages;
- this.defaultLength = defLength;
-
- }
-
-}
diff --git a/src/main/java/com/att/mr/filter/DefaultLength.java b/src/main/java/com/att/mr/filter/DefaultLength.java
deleted file mode 100644
index 43169e5..0000000
--- a/src/main/java/com/att/mr/filter/DefaultLength.java
+++ /dev/null
@@ -1,37 +0,0 @@
-/*******************************************************************************
- * ============LICENSE_START=======================================================
- * org.onap.dmaap
- * ================================================================================
- * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * http://www.apache.org/licenses/LICENSE-2.0
-*
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- *
- * ECOMP is a trademark and service mark of AT&T Intellectual Property.
- *
- *******************************************************************************/
-package com.att.mr.filter;
-
-
-public class DefaultLength {
-
- String defaultLength;
-
- public String getDefaultLength() {
- return defaultLength;
- }
-
- public void setDefaultLength(String defaultLength) {
- this.defaultLength = defaultLength;
- }
-
-}