1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
/*-
* ============LICENSE_START=======================================================
* Ran Simulator Controller
* ================================================================================
* Copyright (C) 2020 Wipro Limited.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*/
package org.onap.ransim.rest.client;
import java.nio.charset.Charset;
import java.util.List;
import java.util.Map;
import org.apache.log4j.Logger;
import org.eclipse.persistence.internal.oxm.conversion.Base64;
import org.onap.ransim.rest.api.controller.RansimControllerServices;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;
public class RestClient {
static Logger log = Logger.getLogger(RansimControllerServices.class.getName());
HttpHeaders createHeaders(String username, String password) {
return new HttpHeaders() {
{
String auth = username + ":" + password;
byte[] encodedAuth = Base64.base64Encode(auth.getBytes(Charset.forName("US-ASCII")));
String authHeader = "Basic " + new String(encodedAuth);
set("Authorization", authHeader);
set("Content-Type", "application/xml");
set("Accept", "application/xml");
}
};
}
/**
* Sends mount request to sdnr.
*
* @param serverId
* netconf server id name
* @param ip
* server ip address
* @param port
* port number
* @param agentIp
* agent ip address
* @param agentPort
* agent port number
* @param agentUsername
* agent username
* @param agentPassword
* agent password
* @return returns the message to be passed
*/
public String sendMountRequestToSdnr(String serverId, String ip, int port, String agentIp, String agentPort,
String agentUsername, String agentPassword) {
String requestBody = "<node xmlns=\"urn:TBD:params:xml:ns:yang:network-topology\"> <node-id> " + serverId + " </node-id> <username xmlns=\"urn:opendaylight:netconf-node-topology\">admin</username> <password xmlns=\"urn:opendaylight:netconf-node-topology\">admin</password> <host xmlns=\"urn:opendaylight:netconf-node-topology\">" + agentIp + "</host> <schema-cache-directory xmlns=\"urn:opendaylight:netconf-node-topology\">" + serverId + "</schema-cache-directory> <port xmlns=\"urn:opendaylight:netconf-node-topology\">" + agentPort + "</port> <tcp-only xmlns=\"urn:opendaylight:netconf-node-topology\">false</tcp-only> <schemaless xmlns=\"urn:opendaylight:netconf-node-topology\">false</schemaless> <max-connection-attempts xmlns=\"urn:opendaylight:netconf-node-topology\">0</max-connection-attempts> <connection-timeout-millis xmlns=\"urn:opendaylight:netconf-node-topology\">20000</connection-timeout-millis> <default-request-timeout-millis xmlns=\"urn:opendaylight:netconf-node-topology\">60000</default-request-timeout-millis> <sleep-factor xmlns=\"urn:opendaylight:netconf-node-topology\">1.1</sleep-factor> <between-attempts-timeout-millis xmlns=\"urn:opendaylight:netconf-node-topology\">2000</between-attempts-timeout-millis> <reconnect-on-changed-schema xmlns=\"urn:opendaylight:netconf-node-topology\">false</reconnect-on-changed-schema> <keepalive-delay xmlns=\"urn:opendaylight:netconf-node-topology\">60</keepalive-delay> <concurrent-rpc-limit xmlns=\"urn:opendaylight:netconf-node-topology\">0</concurrent-rpc-limit> <actor-response-wait-time xmlns=\"urn:opendaylight:netconf-node-topology\">60</actor-response-wait-time></node>";
HttpHeaders headers = createHeaders(agentUsername, agentPassword);
log.info("request : " + requestBody);
log.info("headers : " + headers);
for (Map.Entry<String, List<String>> entry : headers.entrySet()) {
log.info("Key:" + entry.getKey() + " , Value:" + entry.getValue());
}
RestTemplate restTemplate = new RestTemplate();
String url = "http://" + ip + ":" + port
+ "/restconf/config/network-topology:network-topology/topology/topology-netconf/node/" + serverId;
HttpEntity<String> entity = new HttpEntity<String>(requestBody, headers);
ResponseEntity<String> result = restTemplate.exchange(url, HttpMethod.PUT, entity, String.class);
log.info("request sent, result: " + result);
return result.toString();
}
/**
* Sends an unmount request to sdnr.
*
* @param serverId
* netconf server id name
* @param ip
* ip address
* @param port
* port number
* @param sdnrUsername
* sdnr username
* @param sdnrPassword
* sdnr password
* @return returns the message to be passed
*/
public String sendUnmountRequestToSdnr(String serverId, String ip, int port, String sdnrUsername,
String sdnrPassword) {
String url = "http://" + ip + ":" + port
+ "/restconf/config/network-topology:network-topology/topology/topology-netconf/node/" + serverId;
RestTemplate restTemplate = new RestTemplate();
HttpHeaders headers = createHeaders(sdnrUsername, sdnrPassword);
HttpEntity<String> entity = new HttpEntity<String>("parameters", headers);
ResponseEntity<String> result = restTemplate.exchange(url, HttpMethod.DELETE, entity, String.class);
log.info("request sent, result: " + result);
return result.toString();
}
}
|
