Commit 5b24fcc1 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Adapted DLT Connector to common proto folder 

- Moved imports from *.proto folder to common.proto folder
- Removed DLT Connector's genproto.sh script
parent fad61098

src/dlt/connector/genproto.sh

deleted100755 → 0
+0 −49
Original line number Diff line number Diff line 
#!/bin/bash -eu

#

# Copyright 2021-2023 H2020 TeraFlow (https://www.teraflow-h2020.eu/)

#

# 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.



# Make folder containing the script the root folder for its execution

cd $(dirname $0)



rm -rf proto/*.py

rm -rf proto/__pycache__

tee proto/__init__.py << EOF > /dev/null

# Copyright 2021-2023 H2020 TeraFlow (https://www.teraflow-h2020.eu/)

#

# 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.



EOF



python -m grpc_tools.protoc -I../../../proto --python_out=proto --grpc_python_out=proto context.proto

python -m grpc_tools.protoc -I../../../proto --python_out=proto --grpc_python_out=proto kpi_sample_types.proto

python -m grpc_tools.protoc -I../../../proto --python_out=proto --grpc_python_out=proto dlt.proto



rm proto/context_pb2_grpc.py

rm proto/kpi_sample_types_pb2_grpc.py



sed -i -E 's/(import\ .*)_pb2/from . \1_pb2/g' proto/context_pb2.py

sed -i -E 's/(import\ .*)_pb2/from . \1_pb2/g' proto/dlt_pb2.py

sed -i -E 's/(import\ .*)_pb2/from . \1_pb2/g' proto/dlt_pb2_grpc.py

sed -i -E 's/(import\ .*)_pb2/from . \1_pb2/g' proto/kpi_sample_types_pb2.py

src/dlt/connector/proto/__init__.py

deleted100644 → 0
+0 −14
Original line number Diff line number Diff line 
# Copyright 2021-2023 H2020 TeraFlow (https://www.teraflow-h2020.eu/)

#

# 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.

src/dlt/connector/proto/context_pb2.py

deleted100644 → 0
+0 −3071

File deleted.

Preview size limit exceeded, changes collapsed.

src/dlt/connector/proto/dlt_pb2.py

deleted100644 → 0
+0 −638

File deleted.

Preview size limit exceeded, changes collapsed.

src/dlt/connector/proto/dlt_pb2_grpc.py

deleted100644 → 0
+0 −199
Original line number Diff line number Diff line 
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!

"""Client and server classes corresponding to protobuf-defined services."""

import grpc



from . import context_pb2 as context__pb2

from . import dlt_pb2 as dlt__pb2





class DltServiceStub(object):

    """Missing associated documentation comment in .proto file."""



    def __init__(self, channel):

        """Constructor.



        Args:

            channel: A grpc.Channel.

        """

        self.RecordToDlt = channel.unary_unary(

                '/dlt.DltService/RecordToDlt',

                request_serializer=dlt__pb2.DltRecord.SerializeToString,

                response_deserializer=dlt__pb2.DltRecordStatus.FromString,

                )

        self.GetFromDlt = channel.unary_unary(

                '/dlt.DltService/GetFromDlt',

                request_serializer=dlt__pb2.DltRecordId.SerializeToString,

                response_deserializer=dlt__pb2.DltRecord.FromString,

                )

        self.SubscribeToDlt = channel.unary_stream(

                '/dlt.DltService/SubscribeToDlt',

                request_serializer=dlt__pb2.DltRecordSubscription.SerializeToString,

                response_deserializer=dlt__pb2.DltRecordEvent.FromString,

                )

        self.GetDltStatus = channel.unary_unary(

                '/dlt.DltService/GetDltStatus',

                request_serializer=context__pb2.TeraFlowController.SerializeToString,

                response_deserializer=dlt__pb2.DltPeerStatus.FromString,

                )

        self.GetDltPeers = channel.unary_unary(

                '/dlt.DltService/GetDltPeers',

                request_serializer=context__pb2.Empty.SerializeToString,

                response_deserializer=dlt__pb2.DltPeerStatusList.FromString,

                )





class DltServiceServicer(object):

    """Missing associated documentation comment in .proto file."""



    def RecordToDlt(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)

        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')



    def GetFromDlt(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)

        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')



    def SubscribeToDlt(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)

        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')



    def GetDltStatus(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)

        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')



    def GetDltPeers(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)

        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')





def add_DltServiceServicer_to_server(servicer, server):

    rpc_method_handlers = {

            'RecordToDlt': grpc.unary_unary_rpc_method_handler(

                    servicer.RecordToDlt,

                    request_deserializer=dlt__pb2.DltRecord.FromString,

                    response_serializer=dlt__pb2.DltRecordStatus.SerializeToString,

            ),

            'GetFromDlt': grpc.unary_unary_rpc_method_handler(

                    servicer.GetFromDlt,

                    request_deserializer=dlt__pb2.DltRecordId.FromString,

                    response_serializer=dlt__pb2.DltRecord.SerializeToString,

            ),

            'SubscribeToDlt': grpc.unary_stream_rpc_method_handler(

                    servicer.SubscribeToDlt,

                    request_deserializer=dlt__pb2.DltRecordSubscription.FromString,

                    response_serializer=dlt__pb2.DltRecordEvent.SerializeToString,

            ),

            'GetDltStatus': grpc.unary_unary_rpc_method_handler(

                    servicer.GetDltStatus,

                    request_deserializer=context__pb2.TeraFlowController.FromString,

                    response_serializer=dlt__pb2.DltPeerStatus.SerializeToString,

            ),

            'GetDltPeers': grpc.unary_unary_rpc_method_handler(

                    servicer.GetDltPeers,

                    request_deserializer=context__pb2.Empty.FromString,

                    response_serializer=dlt__pb2.DltPeerStatusList.SerializeToString,

            ),

    }

    generic_handler = grpc.method_handlers_generic_handler(

            'dlt.DltService', rpc_method_handlers)

    server.add_generic_rpc_handlers((generic_handler,))





 # This class is part of an EXPERIMENTAL API.

class DltService(object):

    """Missing associated documentation comment in .proto file."""



    @staticmethod

    def RecordToDlt(request,

            target,

            options=(),

            channel_credentials=None,

            call_credentials=None,

            insecure=False,

            compression=None,

            wait_for_ready=None,

            timeout=None,

            metadata=None):

        return grpc.experimental.unary_unary(request, target, '/dlt.DltService/RecordToDlt',

            dlt__pb2.DltRecord.SerializeToString,

            dlt__pb2.DltRecordStatus.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def GetFromDlt(request,

            target,

            options=(),

            channel_credentials=None,

            call_credentials=None,

            insecure=False,

            compression=None,

            wait_for_ready=None,

            timeout=None,

            metadata=None):

        return grpc.experimental.unary_unary(request, target, '/dlt.DltService/GetFromDlt',

            dlt__pb2.DltRecordId.SerializeToString,

            dlt__pb2.DltRecord.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def SubscribeToDlt(request,

            target,

            options=(),

            channel_credentials=None,

            call_credentials=None,

            insecure=False,

            compression=None,

            wait_for_ready=None,

            timeout=None,

            metadata=None):

        return grpc.experimental.unary_stream(request, target, '/dlt.DltService/SubscribeToDlt',

            dlt__pb2.DltRecordSubscription.SerializeToString,

            dlt__pb2.DltRecordEvent.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def GetDltStatus(request,

            target,

            options=(),

            channel_credentials=None,

            call_credentials=None,

            insecure=False,

            compression=None,

            wait_for_ready=None,

            timeout=None,

            metadata=None):

        return grpc.experimental.unary_unary(request, target, '/dlt.DltService/GetDltStatus',

            context__pb2.TeraFlowController.SerializeToString,

            dlt__pb2.DltPeerStatus.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def GetDltPeers(request,

            target,

            options=(),

            channel_credentials=None,

            call_credentials=None,

            insecure=False,

            compression=None,

            wait_for_ready=None,

            timeout=None,

            metadata=None):

        return grpc.experimental.unary_unary(request, target, '/dlt.DltService/GetDltPeers',

            context__pb2.Empty.SerializeToString,

            dlt__pb2.DltPeerStatusList.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)