mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/OperationalResource.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * openECOMP : SDN-C
   4  * ================================================================================
   5  * Copyright (C) 2017 ONAP Intellectual Property. All rights
   6  *                                              reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.openecomp.sdnc.sli.resource.mdsal;
  23
  24 import java.util.Map;
  25
  26 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
  27 import org.onap.ccsdk.sli.core.sli.SvcLogicException;
  28 import org.onap.ccsdk.sli.core.sli.SvcLogicResource;
  29 import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
  30 import org.slf4j.Logger;
  31 import org.slf4j.LoggerFactory;
  32 import org.w3c.dom.Document;
  33
  34 public class OperationalResource implements SvcLogicResource {
  35
  36         private static final Logger LOG = LoggerFactory.getLogger(OperationalResource.class);
  37
  38         private RestService restService;
  39
  40         public OperationalResource(String sdncProtocol, String sdncHost, String sdncPort, String sdncUser, String sdncPasswd)
  41         {
  42                 restService = new RestService(sdncProtocol, sdncHost, sdncPort, sdncUser, sdncPasswd, RestService.PayloadType.XML);
  43
  44
  45         }
  46
  47         @Override
  48         public QueryStatus isAvailable(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
  49         {
  50                 return(query(resource, false, null, key, prefix, null, null));
  51         }
  52
  53         @Override
  54         public QueryStatus exists(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
  55         {
  56
  57                 return(query(resource, false, null, key, prefix, null, null));
  58
  59         }
  60
  61         @Override
  62         public QueryStatus query(String resource, boolean localOnly, String select, String key, String prefix,
  63                         String orderBy, SvcLogicContext ctx) throws SvcLogicException {
  64
  65
  66                 String module = resource;
  67                 StringBuffer restQuery = new StringBuffer();
  68
  69                 String[] keyParts = key.split("/");
  70
  71                 for (String keyPart : keyParts) {
  72                         if (restQuery.length() > 0) {
  73                                 restQuery.append("/");
  74                         }
  75                         if (keyPart.startsWith("$")) {
  76
  77                                 restQuery.append(ctx.resolve(keyPart.substring(1)));
  78                         } else {
  79                                 restQuery.append(keyPart);
  80                         }
  81                 }
  82
  83         String restQueryStr = restQuery.toString();
  84         if ((restQueryStr.startsWith("'") && restQueryStr.endsWith("'")) ||
  85                 (restQueryStr.startsWith("\"") && restQueryStr.endsWith("\""))) {
  86             restQueryStr = restQueryStr.substring(1, restQueryStr.length()-1);
  87         }
  88
  89                 String urlString = "restconf/operational/" + module + ":" + restQueryStr;
  90
  91                 LOG.info("Querying resource: " + resource + ". At URL: " + urlString);
  92
  93                 Document results = restService.get(urlString);
  94
  95
  96                 if (results == null) {
  97                         return(QueryStatus.NOT_FOUND);
  98                 } else {
  99
 100                         if (ctx != null) {
 101                                 ctx.mergeDocument(prefix, results);
 102                         }
 103                         return(QueryStatus.SUCCESS);
 104                 }
 105
 106         }
 107
 108         @Override
 109         public QueryStatus reserve(String resource, String select, String key, String prefix,
 110                         SvcLogicContext ctx) throws SvcLogicException {
 111
 112
 113                 return(QueryStatus.SUCCESS);
 114
 115         }
 116
 117         @Override
 118         public QueryStatus release(String resource, String key, SvcLogicContext ctx) throws SvcLogicException {
 119
 120                 return(QueryStatus.SUCCESS);
 121         }
 122
 123         @Override
 124         public QueryStatus delete(String arg0, String arg1, SvcLogicContext arg2)
 125                         throws SvcLogicException {
 126                 // TODO Auto-generated method stub
 127                 return(QueryStatus.SUCCESS);
 128         }
 129
 130         @Override
 131         public QueryStatus save(String arg0, boolean arg1, boolean localOnly, String arg2,
 132                         Map<String, String> arg3, String arg4, SvcLogicContext arg5)
 133                         throws SvcLogicException {
 134                 // TODO Auto-generated method stub
 135                 return(QueryStatus.SUCCESS);
 136         }
 137
 138         @Override
 139         public QueryStatus notify(String resource, String action, String key,
 140                         SvcLogicContext ctx) throws SvcLogicException {
 141                 return(QueryStatus.SUCCESS);
 142         }
 143
 144         public QueryStatus update(String resource, String key,
 145                         Map<String, String> parms, String prefix, SvcLogicContext ctx)
 146                         throws SvcLogicException {
 147                 return(QueryStatus.SUCCESS);
 148         }
 149
 150
 151 }