Feature: add Response class

[Lancetnik]

We should create a special class to make users able to setup outgoing message metainformation in @publihser decorator case

@broker.publisher("out")
@broker.subscriber("in")
async def handler(msg) -> Reponse:
    return Reponse(data=b"", headers={})

Also, the basic case with just a data should be supported as well

@broker.publisher("out")
@broker.subscriber("in")
async def handler(msg):
    return b""   # should works

More than we should create specific KafkaResponse/RabbitResponse/... classes to allow user to specify broker-specific information like in the following example

@kafka_broker.publisher("out")
@kafka_broker.subscriber("in")
async def handler(msg) -> Reponse:
    return KafkaResponse(data=b"", headers={}, key=b"")

P.S. RMQ ReplyConfig option should be deprecated

[AmanSal1]

@Lancetnik Can I give this a shot? Could you just brief me a little bit about this?

[Lancetnik]

@AmanSal1 sorry, I was a little hasty. It's not so easy to implement as I thought. It requires coordinated changes in all publishers, so I'll implement it by myself.

If you want to help, you create create a basic Response class in broker/response.py with __new__ method, that could consume raw data or Response class instance and return Response itself if it was passed or create a new one from data (you can take a look here for reference)

[AmanSal1]

@Lancetnik

class Response:
    def __new__(cls, *args, **kwargs):
        if len(args) == 1 and isinstance(args[0], cls):
            # If an instance of Response is passed, return it directly
            return args[0]
        else:
            # Otherwise, create a new instance with the provided data
            return super().__new__(cls)

    def __init__(self, data=None, headers=None, key=None):
        self.data = data
        self.headers = headers or {}
        self.key = key

Could you please check if this is what you meant? For the next part, I suppose we would need to create separate classes for each and inherit the response class for them. Then, we would have to modify the decorator class for each response class

[Lancetnik]

Yeah, something like this