Loading hackfest/tapi/server/tapi_server/controllers/tapi_connectivity_controller.py +36 −2 Original line number Diff line number Diff line Loading @@ -2559,8 +2559,42 @@ def data_tapi_commoncontext_tapi_connectivityconnectivity_context_post(body=None :rtype: None """ if connexion.request.is_json: body = TapiConnectivityConnectivityContextWrapper.from_dict(connexion.request.get_json()) # noqa: E501 return 'do some magic!' #body = TapiConnectivityConnectivityContextWrapper.from_dict(connexion.request.get_json()) # noqa: E501 raw_body = connexion.request.get_json() if "tapi-connectivity:connectivity-service" in raw_body: raw_body["connectivity-service"] = raw_body.pop("tapi-connectivity:connectivity-service") if isinstance(raw_body["connectivity-service"], list) and len(raw_body["connectivity-service"]) > 0: raw_body["connectivity-service"] = raw_body["connectivity-service"][0] connectivity_service = raw_body["connectivity-service"] if "connectivity-constraint" in connectivity_service: connectivity_constraint = connectivity_service.pop("connectivity-constraint") if "requested-capacity" in connectivity_constraint: connectivity_service["requested-capacity"] = connectivity_constraint.pop("requested-capacity") if "connectivity-direction" in connectivity_constraint: connectivity_service["connectivity-direction"] = connectivity_constraint.pop("connectivity-direction") body = TapiConnectivityConnectivityServiceWrapper.from_dict(raw_body) # noqa: E501 connection = TapiConnectivityConnection( uuid=body.connectivity_service.uuid, connection_end_point=[ TapiConnectivityConnectionEndPointRef( node_edge_point_uuid="node-1-port-3", connection_end_point_uuid="cep13"), TapiConnectivityConnectionEndPointRef( node_edge_point_uuid="node-3-port-2", connection_end_point_uuid="cep32"), ] ) connection_ref = TapiConnectivityConnectionRef(connection.uuid) body.connectivity_service.connection = [ connection_ref ] if database.context.connectivity_context is None: database.context.connectivity_context = TapiConnectivityConnectivityContext( connectivity_service=[], connection=[] ) database.context.connectivity_context.connection.append(connection) database.context.connectivity_context.connectivity_service.append(body.connectivity_service) def data_tapi_commoncontext_tapi_connectivityconnectivity_context_put(body=None): # noqa: E501 Loading Loading
hackfest/tapi/server/tapi_server/controllers/tapi_connectivity_controller.py +36 −2 Original line number Diff line number Diff line Loading @@ -2559,8 +2559,42 @@ def data_tapi_commoncontext_tapi_connectivityconnectivity_context_post(body=None :rtype: None """ if connexion.request.is_json: body = TapiConnectivityConnectivityContextWrapper.from_dict(connexion.request.get_json()) # noqa: E501 return 'do some magic!' #body = TapiConnectivityConnectivityContextWrapper.from_dict(connexion.request.get_json()) # noqa: E501 raw_body = connexion.request.get_json() if "tapi-connectivity:connectivity-service" in raw_body: raw_body["connectivity-service"] = raw_body.pop("tapi-connectivity:connectivity-service") if isinstance(raw_body["connectivity-service"], list) and len(raw_body["connectivity-service"]) > 0: raw_body["connectivity-service"] = raw_body["connectivity-service"][0] connectivity_service = raw_body["connectivity-service"] if "connectivity-constraint" in connectivity_service: connectivity_constraint = connectivity_service.pop("connectivity-constraint") if "requested-capacity" in connectivity_constraint: connectivity_service["requested-capacity"] = connectivity_constraint.pop("requested-capacity") if "connectivity-direction" in connectivity_constraint: connectivity_service["connectivity-direction"] = connectivity_constraint.pop("connectivity-direction") body = TapiConnectivityConnectivityServiceWrapper.from_dict(raw_body) # noqa: E501 connection = TapiConnectivityConnection( uuid=body.connectivity_service.uuid, connection_end_point=[ TapiConnectivityConnectionEndPointRef( node_edge_point_uuid="node-1-port-3", connection_end_point_uuid="cep13"), TapiConnectivityConnectionEndPointRef( node_edge_point_uuid="node-3-port-2", connection_end_point_uuid="cep32"), ] ) connection_ref = TapiConnectivityConnectionRef(connection.uuid) body.connectivity_service.connection = [ connection_ref ] if database.context.connectivity_context is None: database.context.connectivity_context = TapiConnectivityConnectivityContext( connectivity_service=[], connection=[] ) database.context.connectivity_context.connection.append(connection) database.context.connectivity_context.connectivity_service.append(body.connectivity_service) def data_tapi_commoncontext_tapi_connectivityconnectivity_context_put(body=None): # noqa: E501 Loading