auth/auth-locate/src/main/java/org/onap/aaf/auth/locate/service/LocateServiceImpl.java

   1 /**
   2  * ============LICENSE_START====================================================
   3  * org.onap.aaf
   4  * ===========================================================================
   5  * Copyright (c) 2018 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  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END====================================================
  19  *
  20  */
  21
  22 package org.onap.aaf.auth.locate.service;
  23
  24 import java.util.List;
  25 import java.util.UUID;
  26
  27 import org.onap.aaf.auth.dao.cass.ConfigDAO;
  28 import org.onap.aaf.auth.dao.cass.ConfigDAO.Data;
  29 import org.onap.aaf.auth.dao.cass.LocateDAO;
  30 import org.onap.aaf.auth.env.AuthzTrans;
  31 import org.onap.aaf.auth.layer.Result;
  32 import org.onap.aaf.auth.locate.AAF_Locate;
  33 import org.onap.aaf.auth.locate.mapper.Mapper;
  34 import org.onap.aaf.auth.locate.validation.LocateValidator;
  35 import org.onap.aaf.cadi.aaf.AAFPermission;
  36 import org.onap.aaf.misc.env.APIException;
  37
  38 import locate.v1_0.Endpoints;
  39 import locate.v1_0.MgmtEndpoint;
  40 import locate.v1_0.MgmtEndpoints;
  41 import locate_local.v1_1.Configuration;
  42 import locate_local.v1_1.Configuration.Props;
  43
  44 public class LocateServiceImpl<IN,OUT,ERROR>
  45           implements LocateService<IN,OUT,Endpoints,MgmtEndpoints,Configuration,ERROR> {
  46                 private Mapper<IN,OUT,Endpoints,MgmtEndpoints,Configuration,ERROR> mapper;
  47                 protected LocateDAO locateDAO;
  48                 private ConfigDAO configDAO;
  49                 private boolean permToRegister;
  50
  51                 public LocateServiceImpl(AuthzTrans trans, AAF_Locate locate, Mapper<IN,OUT,Endpoints,MgmtEndpoints,Configuration,ERROR> mapper) throws APIException {
  52                         this.mapper = mapper;
  53                         this.locateDAO = locate.locateDAO;
  54                         this.configDAO = locate.configDAO;
  55                         permToRegister = false; //TODO Setup a Configuration for this
  56                 }
  57
  58                 public Mapper<IN,OUT,Endpoints,MgmtEndpoints,Configuration,ERROR> mapper() {return mapper;}
  59
  60                 @Override
  61                 public Result<Endpoints> getEndPoints(AuthzTrans trans, String service, String version, String other) {
  62                         return mapper.endpoints(locateDAO.readByName(trans, service), version, other);
  63                 }
  64
  65                 /* (non-Javadoc)
  66                  * @see org.onap.aaf.auth.locate.service.GwService#putMgmtEndPoints(org.onap.aaf.auth.env.test.AuthzTrans, java.lang.Object)
  67                  */
  68                 @Override
  69                 public Result<Void> putMgmtEndPoints(AuthzTrans trans, MgmtEndpoints meps) {
  70                         LocateValidator v = new LocateValidator().mgmt_endpoints(meps, false);
  71                         if(v.err()) {
  72                                 return Result.err(Result.ERR_BadData,v.errs());
  73                         }
  74                         int count = 0;
  75                         for(MgmtEndpoint me : meps.getMgmtEndpoint()) {
  76                                 if(permToRegister) {
  77                                         int dot = me.getName().lastIndexOf('.'); // Note: Validator checks for NS for getName()
  78                                         AAFPermission p = new AAFPermission(me.getName().substring(0,dot)+".locator",me.getName(),"write");
  79                                         if(trans.fish(p)) {
  80                                                 LocateDAO.Data data = mapper.locateData(me);
  81                                                 locateDAO.update(trans, data, true);
  82                                                 ++count;
  83                                         } else {
  84                                                 return Result.err(Result.ERR_Denied,"May not register service (needs " + p.getKey() + ')');
  85                                         }
  86                                 } else { //TODO if(MechID is part of Namespace) {
  87                                         LocateDAO.Data data = mapper.locateData(me);
  88                                         locateDAO.update(trans, data, true);
  89                                         ++count;
  90                                 }
  91                         }
  92                         if(count>0) {
  93                                 return Result.ok();
  94                         } else {
  95                                 return Result.err(Result.ERR_NotFound, "No endpoints found");
  96                         }
  97                 }
  98
  99                 /* (non-Javadoc)
 100                  * @see org.onap.aaf.auth.locate.service.GwService#removeMgmtEndPoints(org.onap.aaf.auth.env.test.AuthzTrans, java.lang.Object)
 101                  */
 102                 @Override
 103                 public Result<Void> removeMgmtEndPoints(AuthzTrans trans, MgmtEndpoints meps) {
 104                         LocateValidator v = new LocateValidator().mgmt_endpoint_key(meps);
 105                         if(v.err()) {
 106                                 return Result.err(Result.ERR_BadData,v.errs());
 107                         }
 108                         int count = 0;
 109                         for(MgmtEndpoint me : meps.getMgmtEndpoint()) {
 110                                 int dot = me.getName().lastIndexOf('.'); // Note: Validator checks for NS for getName()
 111                                 AAFPermission p = new AAFPermission(me.getName().substring(0,dot)+".locator",me.getHostname(),"write");
 112                                 if(trans.fish(p)) {
 113                                         LocateDAO.Data data = mapper.locateData(me);
 114                                         data.port_key = UUID.randomUUID();
 115                                         locateDAO.delete(trans, data, false);
 116                                         ++count;
 117                                 } else {
 118                                         return Result.err(Result.ERR_Denied,"May not register service (needs " + p.getKey() + ')');
 119                                 }
 120                         }
 121                         if(count>0) {
 122                                 return Result.ok();
 123                         } else {
 124                                 return Result.err(Result.ERR_NotFound, "No endpoints found");
 125                         }
 126                 }
 127
 128                 /////   ADDED v1_1
 129                 /* (non-Javadoc)
 130                  * @see org.onap.aaf.auth.locate.service.LocateService#getConfig(org.onap.aaf.auth.env.AuthzTrans, java.lang.String, java.lang.String)
 131                  */
 132                 @Override
 133                 public Result<Configuration> getConfig(AuthzTrans trans, String id, String type) {
 134                         Result<List<Data>> dr = configDAO.readName(trans, type);
 135                         Configuration c = new Configuration();
 136                         c.setName(type);
 137                         Props p;
 138
 139                         if(dr.isOKhasData()) {
 140                                 for(ConfigDAO.Data data : dr.value) {
 141                                         p = new Props();
 142                                         p.setTag(data.tag);
 143                                         p.setValue(data.value);
 144                                         c.getProps().add(p);
 145                                 }
 146                         }
 147                         return Result.ok(c);
 148                         //return Result.err(Result.ERR_NotImplemented,"not done yet");
 149                 }
 150
 151
 152 //////////////// APIs ///////////////////
 153 };