History¶

0.0.3 (2021-05-24)¶

Be compatible with minos-microservice-common==0.1.7.
Fix bug related with EventConsumerService, CommandConsumerService and CommandReplyConsumerService and the start method.
Fix bug related with get_host_ip function and some DNS systems.

Unify consumer queues into a single one consumer_queue.
Replace periodic checking (active waiting) by a LISTEN/NOTIFY approach (reactive) on consumer and producer queue.
Use single reply topic based on microservice name to handle CommandReply messages of sagas paused on disk.
Refactor ReplyPool and DynamicReplyHandler as DynamicHandlerPool and DynamicHandler and integrate them into the consumer queue.
Improve Producer performance keeping kafka connection open between publishing calls.
Implement direct message transferring between Producer and Consumer for messages send to the same microservice.

Add "user" context variable to be accessible during Request handling (same as Request.user).
Add support for Request.user propagation over CommandBroker.

Add REPLY_TOPIC_CONTEXT_VAR and integrate with DynamicHandlerPool.
Add support for post_fn callbacks following the same strategy as in pre_fn callbacks.

Remove dependency to minos-microservice-aggregate (now minos.aggregate package will require minos.networks).
Add support for middleware functions.
Add support variable number of services (previously only CommandService and QueryService were allowed).
Migrate Command, CommandReply, CommandStatus and Event from minos.common to minos.networks.
Add support for minos-microservice-common=^0.3.0

Improve BrokerHandler dispatching strategy to be more concurrent (using asyncio.PriorityQueue and multiple consumers).
Add send(...) method to DynamicBroker in order to simplify the execution of request-response messages.
Merge minos.networks.brokers and minos.networks.handlers modules into minos.networks.brokers (divided into handlers and subscribers).
Merge Command, CommandReply and Event into BrokerMessage.
Rename CommandStatus as BrokerMessageStatus.
Merge CommandBroker, CommandReplyBroker and EventBroker into BrokerPublisher.
Merge CommandHandler, CommandReplyHandler and EventHandler into BrokerHandler.
Merge CommandHandlerService, CommandReplyHandlerService and EventHandlerService into BrokerHandlerService
Rename DynamicHandler and DynamicHandlerPool as DynamicBroker and DynamicBrokerPool
Rename Consumer and ConsumerService as BrokerConsumer and BrokerConsumerService respectively.
Rename Producer and ProducerService as BrokerProducer and BrokerProducerService respectively.
Rename HandlerRequest, HandlerResponse and HandlerResponseException as BrokerRequest, BrokerResponse and BrokerResponseException respectively.

Add identifier: UUID and headers: dict[str, str] attributes to BrokerMessage.
Remove saga: Optional[UUID] and service_name: str attributes from BrokerMessage.
Now BrokerPublisher.send returns the BrokerMessage identifier instead of the entry identifier on the Producer‘s queue.
Add REQUEST_HEADERS_CONTEXT_VAR.
Rename USER_CONTEXT_VAR and REPLY_TOPIC_CONTEXT_VAR as REQUEST_USER_CONTEXT_VAR and REQUEST_REPLY_TOPIC_CONTEXT_VAR respectively.

Add CheckDecorator (accessible from EnrouteDecorator.check(...): CheckDecorator attribute) allowing to set check functions with the (request: Request) -> bool prototype to the service handling functions.
Add support for more Content-Type values. Currently: application/json, application/x-www-form-encoded, avro/binary, text/plain and application/octet-stream.
Remove url params and query params injection from the RestRequest.content(..) method.
Add Request.params(...) method allowing to access to the request’s params.
Add Request.has_content: bool and Request.has_params: bool to check for the existence of content and params respectively.
Add InMemoryRequest class that allows to create requests for testing or calling service handling functions directly.