blob: c52c8afb4afd8de33c228d99f812594a37e9a87e (
plain)
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
|
# Copyright (c) 2019 IBM, Bell Canada.
#
# 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.
import netconf_constant
from java.lang import Exception as JavaException
from netconfclient import NetconfClient
import json
from org.onap.ccsdk.cds.blueprintsprocessor.services.execution import AbstractScriptComponentFunction
from com.fasterxml.jackson.databind import ObjectMapper
class NetconfTest(AbstractScriptComponentFunction):
def process(self):
log = globals()[netconf_constant.SERVICE_LOG]
payload="""
<configuration xmlns:junos="http://xml.juniper.net/junos/17.4R1/junos">
<system xmlns="http://yang.juniper.net/junos-qfx/conf/system">
<host-name operation="delete" />
<host-name operation="create">Regression-Mock</host-name>
</system>
</configuration>
"""
responsePayload = '{"deploySuccess": false}'
try:
nc = NetconfClient(log, self, "netconf-connection")
nc.connect()
nc.lock()
nc.edit_config(message_content=payload, config_target="candidate")
operationResponse = nc.commit()
nc.unlock()
nc.disconnect()
responsePayload = json.dumps({"deploySuccess": operationResponse.isSuccess()})
except JavaException as err:
self.addError(err.message)
except Exception as err:
self.addError("Python error: {}".format(err))
self.setAttribute("response-data", ObjectMapper().readTree(responsePayload))
return None
def recover(self):
return None
|