2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights
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
12 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
22 package org.onap.ccsdk.sli.adaptors.resource.mdsal;
25 import java.util.Properties;
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;
35 public class ConfigResource implements SvcLogicResource {
37 private static final Logger LOG = LoggerFactory.getLogger(ConfigResource.class);
39 private RestService restService;
41 public ConfigResource(MdsalResourcePropertiesProvider propProvider) {
42 LOG.info("Loading ConfigResource using property provider");
43 Properties props = propProvider.getProperties();
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");
51 restService = new RestService(sdncProtocol, sdncHost, sdncPort, sdncUser, sdncPasswd, RestService.PayloadType.XML);
55 public ConfigResource(String sdncProtocol, String sdncHost, String sdncPort, String sdncUser, String sdncPasswd)
57 restService = new RestService(sdncProtocol, sdncHost, sdncPort, sdncUser, sdncPasswd, RestService.PayloadType.XML);
60 public ConfigResource(RestService restService) {
61 this.restService = restService;
65 public QueryStatus isAvailable(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
67 return(query(resource, false, null, key, prefix, null, null));
71 public QueryStatus exists(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
74 return(query(resource, false, null, key, prefix, null, null));
79 public QueryStatus query(String resource, boolean localOnly, String select, String key, String prefix,
80 String orderBy, SvcLogicContext ctx) throws SvcLogicException {
83 String module = resource;
84 StringBuffer restQuery = new StringBuffer();
86 String[] keyParts = key.split("/");
88 for (String keyPart : keyParts) {
89 if (restQuery.length() > 0) {
90 restQuery.append("/");
92 if (keyPart.startsWith("$")) {
94 restQuery.append(ctx.resolve(keyPart.substring(1)));
96 restQuery.append(keyPart);
100 String restQueryStr = restQuery.toString();
101 if ((restQueryStr.startsWith("'") && restQueryStr.endsWith("'")) ||
102 (restQueryStr.startsWith("\"") && restQueryStr.endsWith("\""))) {
103 restQueryStr = restQueryStr.substring(1, restQueryStr.length()-1);
106 String urlString = "restconf/config/" + module + ":" + restQueryStr;
108 LOG.info("Querying resource: " + resource + ". At URL: " + urlString);
110 Document results = restService.get(urlString);
113 if (results == null) {
114 return(QueryStatus.NOT_FOUND);
118 ctx.mergeDocument(prefix, results);
120 return(QueryStatus.SUCCESS);
126 public QueryStatus reserve(String resource, String select, String key, String prefix,
127 SvcLogicContext ctx) throws SvcLogicException {
130 return(QueryStatus.SUCCESS);
135 public QueryStatus release(String resource, String key, SvcLogicContext ctx) throws SvcLogicException {
137 return(QueryStatus.SUCCESS);
141 public QueryStatus delete(String arg0, String arg1, SvcLogicContext arg2)
142 throws SvcLogicException {
143 // TODO Auto-generated method stub
144 return(QueryStatus.SUCCESS);
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);
156 public QueryStatus notify(String resource, String action, String key,
157 SvcLogicContext ctx) throws SvcLogicException {
158 return(QueryStatus.SUCCESS);
162 public QueryStatus update(String resource, String key,
163 Map<String, String> parms, String prefix, SvcLogicContext ctx)
164 throws SvcLogicException {
165 return(QueryStatus.SUCCESS);