- Added EventName(to event_processor) and CommandName(to command_processor) (#548)

Co-authored-by: itbewhatitdo <itbewhatitdo.app@gmail.com>

Author: unaik

components/cqrs/command_processor.go

@@ -95,6 +95,7 @@ type CommandProcessorGenerateSubscribeTopicParams struct {
 type CommandProcessorSubscriberConstructorFn func(CommandProcessorSubscriberConstructorParams) (message.Subscriber, error)
 
 type CommandProcessorSubscriberConstructorParams struct {
+	CommandName string
 	HandlerName string
 	Handler     CommandHandler
 }
@@ -290,6 +291,7 @@ func (p CommandProcessor) addHandlerToRouter(r *message.Router, handler CommandH
 	logger.Debug("Adding CQRS command handler to router", nil)
 
 	subscriber, err := p.config.SubscriberConstructor(CommandProcessorSubscriberConstructorParams{
+		CommandName: commandName,
 		HandlerName: handlerName,
 		Handler:     handler,
 	})

components/cqrs/event_processor.go

@@ -91,6 +91,7 @@ type EventProcessorGenerateSubscribeTopicParams struct {
 type EventProcessorSubscriberConstructorFn func(EventProcessorSubscriberConstructorParams) (message.Subscriber, error)
 
 type EventProcessorSubscriberConstructorParams struct {
+	EventName    string
 	HandlerName  string
 	EventHandler EventHandler
 }
@@ -279,6 +280,7 @@ func (p EventProcessor) addHandlerToRouter(r *message.Router, handler EventHandl
 	}
 
 	subscriber, err := p.config.SubscriberConstructor(EventProcessorSubscriberConstructorParams{
+		EventName:    eventName,
 		HandlerName:  handlerName,
 		EventHandler: handler,
 	})