223e8c5d1e51f30db362e0b6b382be81bf8ffe9c
[dmaap/messagerouter/msgrtr.git] / src / main / java / org / onap / dmaap / messagerouter / msgrtr / nsa / cambria / security / DMaaPAAFAuthenticatorImpl.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.messagerouter.msgrtr.nsa.cambria.security;
23
24 import java.util.Date;
25
26 import javax.servlet.http.HttpServletRequest;
27
28 import org.apache.http.HttpStatus;
29 import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
30 import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
31 import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPResponseCode;
32 import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.ErrorResponse;
33 import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Utils;
34
35
36 /**
37  * 
38  * @author author
39  *
40  */
41 public class DMaaPAAFAuthenticatorImpl implements DMaaPAAFAuthenticator {
42
43         /**
44          * @param req
45          * @param role
46          */
47         @Override
48         public boolean aafAuthentication(HttpServletRequest req, String role) {
49                 boolean auth = false;
50                 if(req.isUserInRole(role))
51                 {
52                         
53                         auth = true;
54                 }
55                 return auth;
56         }
57
58         @Override
59         public String aafPermissionString(String topicName, String action) throws CambriaApiException {
60                 
61                 
62                 String permission = "";
63                 String nameSpace ="";
64                 if(topicName.contains(".") && (topicName.contains("com.att")||topicName.contains("org"))) {
65                         //String topic = topicName.substring(topicName.lastIndexOf(".")+1);
66                         nameSpace = topicName.substring(0,topicName.lastIndexOf("."));
67                 }
68                 else {
69                         nameSpace = null;
70                          nameSpace= com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,"defaultNSforUEB");
71                         
72                         if(null==nameSpace)nameSpace="com.att.dmaap.mr.ueb";
73                         
74                         
75                         /*ErrorResponse errRes = new ErrorResponse(HttpStatus.SC_FORBIDDEN,
76                                         DMaaPResponseCode.TOPIC_NOT_IN_AAF.getResponseCode(), "Topic does not exist in AAF"
77                                                         , null, Utils.getFormattedDate(new Date()), topicName,
78                                         null, null, null, null);
79                                         
80                         throw new CambriaApiException(errRes);*/
81                 }
82                 
83                 permission = nameSpace+".mr.topic|:topic."+topicName+"|"+action;
84                 return permission;
85                 
86         }
87         
88         
89
90 }