Commit 0d7efda5 authored by Mohammad Ismaeel's avatar Mohammad Ismaeel
Browse files

HTTP Tapi component

parent eabcbf21

proto/tapi.proto

+20 −0
Changes for proto/tapi.proto: 20 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -41,3 +41,23 @@ message CheckStat { 
  int32 res = 1 ;

}



message ChildEndpoint {

  context.EndPointId endpoint_id =1 ; 

  context.DeviceId device_id = 2 ; 

  string endpoint_name = 3; 

  string device_name =4 ;

  

}

 

message ChildTopology {



  context.TopologyId topology_id = 2 ;

  string host = 3; 

  int32 port = 4 ;

  repeated ChildEndpoint endpoints =5;



}



message ListChildTopology {

  repeated ChildTopology topology_list = 1 ;

}

src/common/tools/context_queries/OpticalConfig.py

+1 −1
Changes for src/common/tools/context_queries/OpticalConfig.py: 1 added line, 1 removed line.
Original line number Diff line number Diff line
@@ -76,7 +76,7 @@ def opticalconfig_uuid_get_duuid( 
    if allow_random: return get_uuid_random()



    raise InvalidArgumentsException([

        ('DeviceId ', device_id),

        ('DeviceId ', device_uuid),

    ], extra_details=['device_id is required to produce a OpticalConfig UUID'])

src/common/tools/uuids/opticalconfig.py

0 → 100644
+0 −0

Empty file added.

src/common/tools/uuids/topology.py

0 → 100644
+0 −0

Empty file added.

src/context/client/ContextClient.py

+21 −0
Changes for src/context/client/ContextClient.py: 21 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -33,6 +33,7 @@ from common.proto.context_pb2 import ( 
from common.proto.context_pb2_grpc import ContextServiceStub

from common.proto.context_policy_pb2_grpc import ContextPolicyServiceStub

from common.proto.policy_pb2 import PolicyRuleIdList, PolicyRuleId, PolicyRuleList, PolicyRule

from common.proto.tapi_pb2 import ChildTopology , ChildEndpoint ,ListChildTopology



LOGGER = logging.getLogger(__name__)

MAX_RETRIES = 15
@@ -535,7 +536,26 @@ class ContextClient: 
        LOGGER.debug('RemoveOpticalLink result: {:s}'.format(grpc_message_to_json_string(response)))

        return response

    

    @RETRY_DECORATOR

    def SetChildTopology(self, request: ChildTopology) -> TopologyId:

        LOGGER.debug('SetChildTopology request: {:s}'.format(grpc_message_to_json_string(request)))

        response = self.stub.SetChildTopology(request)

        LOGGER.debug('SetChildTopology result: {:s}'.format(grpc_message_to_json_string(response)))

        return response

    

    @RETRY_DECORATOR

    def GetChildTopology(self, request: TopologyId) -> ChildTopology:

        LOGGER.debug('GetChildTopology request: {:s}'.format(grpc_message_to_json_string(request)))

        response = self.stub.GetChildTopology(request)

        LOGGER.debug('GetChildTopology result: {:s}'.format(grpc_message_to_json_string(response)))

        return response

    

    @RETRY_DECORATOR

    def ListChildTopology(self, request: Empty) -> ListChildTopology:

        LOGGER.debug('GetChildTopology request: {:s}'.format(grpc_message_to_json_string(request)))

        response = self.stub.GetChildTopology(request)

        LOGGER.debug('GetChildTopology result: {:s}'.format(grpc_message_to_json_string(response)))

        return response

    # --------------------------------- Service ConfigRule Deletion ------------------

    

    @RETRY_DECORATOR
@@ -544,3 +564,4 @@ class ContextClient: 
        response = self.stub.DeleteServiceConfigRule(request)

        LOGGER.debug('ServiceConfigRule Delete result: {:s}'.format(grpc_message_to_json_string(response)))

        return response

  
 No newline at end of file