From: tierno Date: Wed, 22 May 2019 09:56:05 +0000 (+0000) Subject: adding wim fake connector X-Git-Tag: v6.0.0~13 X-Git-Url: https://osm.etsi.org/gitweb/?a=commitdiff_plain;h=refs%2Fchanges%2F86%2F7486%2F2;p=osm%2FRO.git adding wim fake connector Change-Id: I03fa422d5fe57f4bb5f82aa3f059ab049f466de9 Signed-off-by: tierno --- diff --git a/osm_ro/wim/schemas.py b/osm_ro/wim/schemas.py index 6692ac59..1e2a1072 100644 --- a/osm_ro/wim/schemas.py +++ b/osm_ro/wim/schemas.py @@ -39,7 +39,7 @@ from ..openmano_schemas import ( ) # WIM ------------------------------------------------------------------------- -wim_types = ["tapi", "onos", "odl", "dynpac"] +wim_types = ["ietftapi", "onos", "odl", "dynpac", "fake"] dpid_type = { "type": "string", diff --git a/osm_ro/wim/wim_thread.py b/osm_ro/wim/wim_thread.py index f8d52bbe..3e23a48d 100644 --- a/osm_ro/wim/wim_thread.py +++ b/osm_ro/wim/wim_thread.py @@ -51,7 +51,7 @@ from time import time, sleep from six import reraise from six.moves import queue -from . import wan_link_actions, wimconn_odl, wimconn_dynpac # wimconn_tapi +from . import wan_link_actions from ..utils import ensure, partition, pipe from .actions import IGNORE, PENDING, REFRESH from .errors import ( @@ -62,16 +62,20 @@ from .errors import ( ) from .failing_connector import FailingConnector from .wimconn import WimConnectorError +from .wimconn_dynpac import DynpacConnector +from .wimconn_fake import FakeConnector +from .wimconn_ietfl2vpn import WimconnectorIETFL2VPN ACTIONS = { 'instance_wim_nets': wan_link_actions.ACTIONS } CONNECTORS = { - "odl": wimconn_odl.OdlConnector, - # "tapi": wimconn_tapi + # "odl": wimconn_odl.OdlConnector, + "dynpac": DynpacConnector, + "fake": FakeConnector, + "ietfl2vpn": WimconnectorIETFL2VPN, # Add extra connectors here - "dynpac": wimconn_dynpac.DynpacConnector } diff --git a/osm_ro/wim/wimconn_fake.py b/osm_ro/wim/wimconn_fake.py new file mode 100644 index 00000000..36929f4c --- /dev/null +++ b/osm_ro/wim/wimconn_fake.py @@ -0,0 +1,137 @@ +# -*- coding: utf-8 -*- +## +# Copyright 2018 Telefonica +# 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. + +""" +This WIM does nothing and allows using it for testing and when no WIM is needed +""" + +import logging +from uuid import uuid4 +from .wimconn import WimConnector + +__author__ = "Alfonso Tierno " + + +class FakeConnector(WimConnector): + """Abstract base class for all the WIM connectors + + Arguments: + wim (dict): WIM record, as stored in the database + wim_account (dict): WIM account record, as stored in the database + config (dict): optional persistent information related to an specific + connector. Inside this dict, a special key, + ``service_endpoint_mapping`` provides the internal endpoint + mapping. + logger (logging.Logger): optional logger object. If none is passed + ``openmano.wim.wimconn`` is used. + + The arguments of the constructor are converted to object attributes. + An extra property, ``service_endpoint_mapping`` is created from ``config``. + """ + def __init__(self, wim, wim_account, config=None, logger=None): + self.logger = logging.getLogger('openmano.wimconn.fake') + super(FakeConnector, self).__init__(wim, wim_account, config, logger) + self.logger.debug("__init: wim='{}' wim_account='{}'".format(wim, wim_account)) + self.connections = {} + self.counter = 0 + + def check_credentials(self): + """Check if the connector itself can access the WIM. + + Raises: + WimConnectorError: Issues regarding authorization, access to + external URLs, etc are detected. + """ + self.logger.debug("check_credentials") + return None + + def get_connectivity_service_status(self, service_uuid, conn_info=None): + """Monitor the status of the connectivity service established + + Arguments: + service_uuid (str): UUID of the connectivity service + conn_info (dict or None): Information returned by the connector + during the service creation/edition and subsequently stored in + the database. + + Returns: + dict: JSON/YAML-serializable dict that contains a mandatory key + ``wim_status`` associated with one of the following values:: + + Additionally ``error_msg``(**str**) and ``wim_info``(**dict**) + keys can be used to provide additional status explanation or + new information available for the connectivity service. + """ + self.logger.debug("get_connectivity_service_status: service_uuid='{}' conn_info='{}'".format(service_uuid, + conn_info)) + return {'wim_status': 'ACTIVE', 'wim_info': self.connectivity.get(service_uuid)} + + def create_connectivity_service(self, service_type, connection_points, + **kwargs): + """ + Stablish WAN connectivity between the endpoints + + """ + self.logger.debug("create_connectivity_service: service_type='{}' connection_points='{}', kwargs='{}'". + format(service_type, connection_points, kwargs)) + _id = str(uuid4()) + self.connectivity[_id] = {"nb": self.counter} + self.counter += 1 + return _id, self.connectivity[_id] + + def delete_connectivity_service(self, service_uuid, conn_info=None): + """Disconnect multi-site endpoints previously connected + + """ + self.logger.debug("delete_connectivity_service: service_uuid='{}' conn_info='{}'".format(service_uuid, + conn_info)) + self.connectivity.pop(service_uuid, None) + return None + + def edit_connectivity_service(self, service_uuid, conn_info=None, + connection_points=None, **kwargs): + """Change an existing connectivity service. + + This method's arguments and return value follow the same convention as + :meth:`~.create_connectivity_service`. + """ + self.logger.debug("edit_connectivity_service: service_uuid='{}' conn_info='{}', connection_points='{}'" + "kwargs='{}'".format(service_uuid, conn_info, connection_points, kwargs)) + return None + + def clear_all_connectivity_services(self): + """Delete all WAN Links in a WIM. + + This method is intended for debugging only, and should delete all the + connections controlled by the WIM, not only the WIM connections that + a specific RO is aware of. + + """ + self.logger.debug("clear_all_connectivity_services") + self.connectivity.clear() + return None + + def get_all_active_connectivity_services(self): + """Provide information about all active connections provisioned by a + WIM. + + Raises: + WimConnectorException: In case of error. + """ + self.logger.debug("get_all_active_connectivity_services") + return self.connectivity