aboutsummaryrefslogtreecommitdiffstats
path: root/src/python/netconf_server
diff options
context:
space:
mode:
Diffstat (limited to 'src/python/netconf_server')
-rw-r--r--src/python/netconf_server/netconf_change_listener.py (renamed from src/python/netconf_server/netconf_server.py)2
-rw-r--r--src/python/netconf_server/netconf_change_listener_factory.py (renamed from src/python/netconf_server/netconf_server_factory.py)8
-rw-r--r--src/python/netconf_server/netconf_rest_server.py50
3 files changed, 55 insertions, 5 deletions
diff --git a/src/python/netconf_server/netconf_server.py b/src/python/netconf_server/netconf_change_listener.py
index b790604..4bb748c 100644
--- a/src/python/netconf_server/netconf_server.py
+++ b/src/python/netconf_server/netconf_change_listener.py
@@ -24,7 +24,7 @@ from netconf_server.sysrepo_interface.config_change_data import ConfigChangeData
logger = logging.getLogger("netconf_saver")
-class NetconfServer(object):
+class NetconfChangeListener(object):
def __init__(self, subscriptions: list):
self.subscriptions = subscriptions
diff --git a/src/python/netconf_server/netconf_server_factory.py b/src/python/netconf_server/netconf_change_listener_factory.py
index 28297ad..00725dc 100644
--- a/src/python/netconf_server/netconf_server_factory.py
+++ b/src/python/netconf_server/netconf_change_listener_factory.py
@@ -19,22 +19,22 @@
###
import logging
-from netconf_server.netconf_server import NetconfServer
+from netconf_server.netconf_change_listener import NetconfChangeListener
from netconf_server.sysrepo_interface.config_change_subscriber import ConfigChangeSubscriber
logger = logging.getLogger("netconf_saver")
-class NetconfServerFactory(object):
+class NetconfChangeListenerFactory(object):
def __init__(self, modules_to_subscribe_names: list):
self.modules_to_subscribe_names = modules_to_subscribe_names
- def create(self) -> NetconfServer:
+ def create(self) -> NetconfChangeListener:
subscriptions = list()
for module_name in self.modules_to_subscribe_names:
subscriptions.append(
ConfigChangeSubscriber(module_name)
)
- return NetconfServer(subscriptions)
+ return NetconfChangeListener(subscriptions)
diff --git a/src/python/netconf_server/netconf_rest_server.py b/src/python/netconf_server/netconf_rest_server.py
new file mode 100644
index 0000000..2c44029
--- /dev/null
+++ b/src/python/netconf_server/netconf_rest_server.py
@@ -0,0 +1,50 @@
+###
+# ============LICENSE_START=======================================================
+# Netconf Server
+# ================================================================================
+# Copyright (C) 2021 Nokia. All rights reserved.
+# ================================================================================
+# 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=========================================================
+###
+
+import logging as sys_logging
+from flask import Flask, logging, make_response, Response
+
+
+class NetconfRestServer:
+ _rest_server: Flask = Flask("server")
+ sys_logging.basicConfig(level=sys_logging.DEBUG)
+ logger = logging.create_logger(_rest_server)
+
+ def __init__(self, host='0.0.0.0', port=6555):
+ self._host = host
+ self._port = port
+
+ def start(self):
+ Flask.run(
+ NetconfRestServer._rest_server,
+ host=self._host,
+ port=self._port
+ )
+
+ @staticmethod
+ @_rest_server.route("/healthcheck")
+ def __health_check():
+ return "UP"
+
+ @staticmethod
+ def __create_http_response(code, message):
+ return make_response(
+ Response(message, headers={'Content-Type': 'application/json'}),
+ code)