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.v1_1.Configuration;
  42 import locate.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          * Note: "id" is put in, in case we need to filter, or direct data change in the future by Permission
 133          */
 134         @Override
 135         public Result<Configuration> getConfig(AuthzTrans trans, String id, String type) {
 136             Result<List<Data>> dr = configDAO.readName(trans, type);
 137             Configuration c = new Configuration();
 138             c.setName(type);
 139             Props p;
 140
 141             if (dr.isOKhasData()) {
 142                 for (ConfigDAO.Data data : dr.value) {
 143                     p = new Props();
 144                     p.setTag(data.tag);
 145                     p.setValue(data.value);
 146                     c.getProps().add(p);
 147                 }
 148             }
 149             return Result.ok(c);
 150         }
 151
 152
 153 //////////////// APIs ///////////////////
 154 };