mdsal-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/resource/mdsal/ConfigResource.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * openECOMP : SDN-C
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T 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.onap.ccsdk.sli.adaptors.resource.mdsal;
  23
  24 import java.util.Map;
  25 import java.util.Properties;
  26
  27 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
  28 import org.onap.ccsdk.sli.core.sli.SvcLogicException;
  29 import org.onap.ccsdk.sli.core.sli.SvcLogicResource;
  30 import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
  31 import org.slf4j.Logger;
  32 import org.slf4j.LoggerFactory;
  33 import org.w3c.dom.Document;
  34
  35 public class ConfigResource implements SvcLogicResource {
  36
  37     private static final Logger LOG = LoggerFactory.getLogger(ConfigResource.class);
  38
  39     private RestService restService;
  40
  41     public ConfigResource(MdsalResourcePropertiesProvider propProvider) {
  42         LOG.info("Loading ConfigResource using property provider");
  43         Properties props = propProvider.getProperties();
  44
  45         String sdncUser = props.getProperty("org.onap.ccsdk.sli.adaptors.resource.mdsal.sdnc-user", "admin");
  46         String sdncPasswd = props.getProperty("org.onap.ccsdk.sli.adaptors.resource.mdsal.sdnc-passwd", "admin");
  47         String sdncHost = props.getProperty("org.onap.ccsdk.sli.adaptors.resource.mdsal.sdnc-host", "localhost");
  48         String sdncProtocol = props.getProperty("org.onap.ccsdk.sli.adaptors.resource.mdsal.sdnc-protocol", "https");
  49         String sdncPort = props.getProperty("org.onap.ccsdk.sli.adaptors.resource.mdsal.sdnc-port", "8443");
  50
  51         restService = new RestService(sdncProtocol, sdncHost, sdncPort, sdncUser, sdncPasswd, RestService.PayloadType.XML);
  52
  53     }
  54
  55     public ConfigResource(String sdncProtocol, String sdncHost, String sdncPort, String sdncUser, String sdncPasswd)
  56     {
  57         restService = new RestService(sdncProtocol, sdncHost, sdncPort, sdncUser, sdncPasswd, RestService.PayloadType.XML);
  58     }
  59
  60     public ConfigResource(RestService restService) {
  61                 this.restService = restService;
  62     }
  63
  64     @Override
  65     public QueryStatus isAvailable(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
  66     {
  67         return(query(resource, false, null, key, prefix, null, null));
  68     }
  69
  70     @Override
  71     public QueryStatus exists(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
  72     {
  73
  74         return(query(resource, false, null, key, prefix, null, null));
  75
  76     }
  77
  78     @Override
  79     public QueryStatus query(String resource, boolean localOnly, String select, String key, String prefix,
  80             String orderBy, SvcLogicContext ctx) throws SvcLogicException {
  81
  82
  83         String module = resource;
  84         StringBuffer restQuery = new StringBuffer();
  85
  86         String[] keyParts = key.split("/");
  87
  88         for (String keyPart : keyParts) {
  89             if (restQuery.length() > 0) {
  90                 restQuery.append("/");
  91             }
  92             if (keyPart.startsWith("$")) {
  93
  94                 restQuery.append(ctx.resolve(keyPart.substring(1)));
  95             } else {
  96                 restQuery.append(keyPart);
  97             }
  98         }
  99
 100         String restQueryStr = restQuery.toString();
 101         if ((restQueryStr.startsWith("'") && restQueryStr.endsWith("'")) ||
 102                 (restQueryStr.startsWith("\"") && restQueryStr.endsWith("\""))) {
 103             restQueryStr = restQueryStr.substring(1, restQueryStr.length()-1);
 104         }
 105
 106         String urlString = "restconf/config/" + module + ":" + restQueryStr;
 107
 108                 LOG.info("Querying resource: " + resource + ". At URL: " + urlString);
 109
 110         Document results = restService.get(urlString);
 111
 112
 113         if (results == null) {
 114             return(QueryStatus.NOT_FOUND);
 115         } else {
 116
 117             if (ctx != null) {
 118                 ctx.mergeDocument(prefix, results);
 119             }
 120             return(QueryStatus.SUCCESS);
 121         }
 122
 123     }
 124
 125     @Override
 126     public QueryStatus reserve(String resource, String select, String key, String prefix,
 127             SvcLogicContext ctx) throws SvcLogicException {
 128
 129
 130         return(QueryStatus.SUCCESS);
 131
 132     }
 133
 134     @Override
 135     public QueryStatus release(String resource, String key, SvcLogicContext ctx) throws SvcLogicException {
 136
 137         return(QueryStatus.SUCCESS);
 138     }
 139
 140     @Override
 141     public QueryStatus delete(String arg0, String arg1, SvcLogicContext arg2)
 142             throws SvcLogicException {
 143         // TODO Auto-generated method stub
 144         return(QueryStatus.SUCCESS);
 145     }
 146
 147     @Override
 148     public QueryStatus save(String arg0, boolean arg1, boolean localOnly, String arg2,
 149             Map<String, String> arg3, String arg4, SvcLogicContext arg5)
 150             throws SvcLogicException {
 151         // TODO Auto-generated method stub
 152         return(QueryStatus.SUCCESS);
 153     }
 154
 155     @Override
 156     public QueryStatus notify(String resource, String action, String key,
 157             SvcLogicContext ctx) throws SvcLogicException {
 158         return(QueryStatus.SUCCESS);
 159     }
 160
 161
 162     public QueryStatus update(String resource, String key,
 163             Map<String, String> parms, String prefix, SvcLogicContext ctx)
 164             throws SvcLogicException {
 165         return(QueryStatus.SUCCESS);
 166     }
 167
 168
 169
 170 }