Skip to content
Snippets Groups Projects
Commit 0b1baae7 authored by Michal Hažlinský's avatar Michal Hažlinský :family:
Browse files

updated CSD backend

parent c0e7c7cc
Branches
No related tags found
No related merge requests found
...@@ -165,11 +165,6 @@ def _extractErrorMessage(failure): ...@@ -165,11 +165,6 @@ def _extractErrorMessage(failure):
return failure.getErrorMessage() return failure.getErrorMessage()
class WebClientContextFactory(opennsaTlsContext):
def getContext(self):
return opennsaTlsContext.getContext(self)
class CSDConnectionManager: class CSDConnectionManager:
def __init__(self, port_map, space_user, space_password, space_api_url, space_routers, csd_service_def, csd_customer_id, network_name, csd_descriptions): def __init__(self, port_map, space_user, space_password, space_api_url, space_routers, csd_service_def, csd_customer_id, network_name, csd_descriptions):
...@@ -224,11 +219,12 @@ class CSDConnectionManager: ...@@ -224,11 +219,12 @@ class CSDConnectionManager:
headers["Content-Type"] = "application/vnd.net.juniper.space.service-management.service-order+xml;version=2;charset=UTF-8" headers["Content-Type"] = "application/vnd.net.juniper.space.service-management.service-order+xml;version=2;charset=UTF-8"
headers["Authorization"] = self._createAuthzHeader() headers["Authorization"] = self._createAuthzHeader()
return headers return headers
def setupLink(self, connection_id, source_target, dest_target, bandwidth): def setupLink(self, connection_id, source_target, dest_target, bandwidth):
payload = createCSDPayload(connection_id, source_target, dest_target, self.csd_service_def, self.csd_customer_id, self.space_routers, self.csd_descriptions) payload = createCSDPayload(connection_id, source_target, dest_target, self.csd_service_def, self.csd_customer_id, self.space_routers, self.csd_descriptions)
headers = self._createHeaders() headers = self._createHeaders()
contextFactory = WebClientContextFactory(config.DEFAULT_CERTIFICATE_DIR, None) contextFactory = opennsaTlsContext(config.DEFAULT_CERTIFICATE_DIR, False)
def linkUp(data): def linkUp(data):
log.msg('Link %s -> %s up' % (source_target, dest_target), system=LOG_SYSTEM) log.msg('Link %s -> %s up' % (source_target, dest_target), system=LOG_SYSTEM)
...@@ -250,7 +246,7 @@ class CSDConnectionManager: ...@@ -250,7 +246,7 @@ class CSDConnectionManager:
headers["Accept"] = "*/*" headers["Accept"] = "*/*"
headers["Authorization"] = self._createAuthzHeader() headers["Authorization"] = self._createAuthzHeader()
serviceID = None serviceID = None
contextFactory = WebClientContextFactory(config.DEFAULT_CERTIFICATE_DIR, None) contextFactory = opennsaTlsContext(config.DEFAULT_CERTIFICATE_DIR, False)
def linkDown(data): def linkDown(data):
log.msg('Link %s -> %s down' % (source_target, dest_target), system=LOG_SYSTEM) log.msg('Link %s -> %s down' % (source_target, dest_target), system=LOG_SYSTEM)
...@@ -265,7 +261,7 @@ class CSDConnectionManager: ...@@ -265,7 +261,7 @@ class CSDConnectionManager:
headers = {} headers = {}
#headers["Content-Type"] = "application/vnd.net.juniper.space.service-management.service-order+xml;version=2;charset=UTF-8" #headers["Content-Type"] = "application/vnd.net.juniper.space.service-management.service-order+xml;version=2;charset=UTF-8"
headers["Authorization"] = self._createAuthzHeader() headers["Authorization"] = self._createAuthzHeader()
contextFactory = WebClientContextFactory(config.DEFAULT_CERTIFICATE_DIR, None) contextFactory = opennsaTlsContext(config.DEFAULT_CERTIFICATE_DIR, False)
serviceID = 0 serviceID = 0
nsmap={'a': 'services.schema.networkapi.jmp.juniper.net'} nsmap={'a': 'services.schema.networkapi.jmp.juniper.net'}
services = etree.fromstring(data).xpath("/a:Data/a:ServiceResource/a:Service", namespaces=nsmap) services = etree.fromstring(data).xpath("/a:Data/a:ServiceResource/a:Service", namespaces=nsmap)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment