Skip to content
Snippets Groups Projects
Commit 970d7456 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

NBI component - TFS API:

- Corrected parsing of POST service requests
- Corrected return types of POST methods
parent 64ba4d8e
No related branches found
No related tags found
3 merge requests!359Release TeraFlowSDN 5.0,!328Resolve "(CTTC) Update recommendations to use SocketIO on NBI and E2E Orch components",!286Resolve "(CTTC) Implement integration test between E2E-IP-Optical SDN Controllers"
...@@ -55,10 +55,10 @@ class Contexts(_Resource): ...@@ -55,10 +55,10 @@ class Contexts(_Resource):
json_requests = request.get_json() json_requests = request.get_json()
if 'contexts' in json_requests: if 'contexts' in json_requests:
json_requests = json_requests['contexts'] json_requests = json_requests['contexts']
return [ return jsonify([
format_grpc_to_json(self.context_client.SetContext(grpc_context(context))) grpc_message_to_json(self.context_client.SetContext(grpc_context(context)))
for context in json_requests for context in json_requests
] ])
class Context(_Resource): class Context(_Resource):
def get(self, context_uuid : str): def get(self, context_uuid : str):
...@@ -157,10 +157,10 @@ class Topologies(_Resource): ...@@ -157,10 +157,10 @@ class Topologies(_Resource):
for topology in json_requests: for topology in json_requests:
if context_uuid != topology['topology_id']['context_id']['context_uuid']['uuid']: if context_uuid != topology['topology_id']['context_id']['context_uuid']['uuid']:
raise BadRequest('Mismatching context_uuid') raise BadRequest('Mismatching context_uuid')
return [ return jsonify([
format_grpc_to_json(self.context_client.SetTopology(grpc_topology(**topology))) grpc_message_to_json(self.context_client.SetTopology(grpc_topology(topology)))
for topology in json_requests for topology in json_requests
] ])
class Topology(_Resource): class Topology(_Resource):
def get(self, context_uuid : str, topology_uuid : str): def get(self, context_uuid : str, topology_uuid : str):
...@@ -194,13 +194,15 @@ class Services(_Resource): ...@@ -194,13 +194,15 @@ class Services(_Resource):
json_requests = request.get_json() json_requests = request.get_json()
if 'services' in json_requests: if 'services' in json_requests:
json_requests = json_requests['services'] json_requests = json_requests['services']
if isinstance(json_requests, dict):
json_requests = [json_requests]
for service in json_requests: for service in json_requests:
if context_uuid != service['service_id']['context_id']['context_uuid']['uuid']: if context_uuid != service['service_id']['context_id']['context_uuid']['uuid']:
raise BadRequest('Mismatching context_uuid') raise BadRequest('Mismatching context_uuid')
return [ return jsonify([
format_grpc_to_json(self.service_client.CreateService(grpc_service(**service))) grpc_message_to_json(self.service_client.CreateService(grpc_service(service)))
for service in json_requests for service in json_requests
] ])
class Service(_Resource): class Service(_Resource):
def get(self, context_uuid : str, service_uuid : str): def get(self, context_uuid : str, service_uuid : str):
...@@ -232,10 +234,10 @@ class Slices(_Resource): ...@@ -232,10 +234,10 @@ class Slices(_Resource):
for slice_ in json_requests: for slice_ in json_requests:
if context_uuid != slice_['slice_id']['context_id']['context_uuid']['uuid']: if context_uuid != slice_['slice_id']['context_id']['context_uuid']['uuid']:
raise BadRequest('Mismatching context_uuid') raise BadRequest('Mismatching context_uuid')
return [ return jsonify([
format_grpc_to_json(self.slice_client.CreateSlice(grpc_slice(**slice_))) grpc_message_to_json(self.slice_client.CreateSlice(grpc_slice(slice_)))
for slice_ in json_requests for slice_ in json_requests
] ])
class Slice(_Resource): class Slice(_Resource):
def get(self, context_uuid : str, slice_uuid : str): def get(self, context_uuid : str, slice_uuid : str):
...@@ -264,10 +266,10 @@ class Devices(_Resource): ...@@ -264,10 +266,10 @@ class Devices(_Resource):
json_requests = request.get_json() json_requests = request.get_json()
if 'devices' in json_requests: if 'devices' in json_requests:
json_requests = json_requests['devices'] json_requests = json_requests['devices']
return [ return jsonify([
format_grpc_to_json(self.device_client.AddDevice(grpc_device(device))) grpc_message_to_json(self.device_client.AddDevice(grpc_device(device)))
for device in json_requests for device in json_requests
] ])
class Device(_Resource): class Device(_Resource):
def get(self, device_uuid : str): def get(self, device_uuid : str):
...@@ -294,10 +296,10 @@ class Links(_Resource): ...@@ -294,10 +296,10 @@ class Links(_Resource):
json_requests = request.get_json() json_requests = request.get_json()
if 'links' in json_requests: if 'links' in json_requests:
json_requests = json_requests['links'] json_requests = json_requests['links']
return [ return jsonify([
format_grpc_to_json(self.context_client.SetLink(grpc_link(link))) grpc_message_to_json(self.context_client.SetLink(grpc_link(link)))
for link in json_requests for link in json_requests
] ])
class Link(_Resource): class Link(_Resource):
def get(self, link_uuid : str): def get(self, link_uuid : str):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment