Skip to content

Commit 90e5a0f

Browse files
committed
fix (MapEvent) allow for param to define the event name
1 parent d7e3b8e commit 90e5a0f

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

cqrs.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ type ManyTransformer func(context moleculer.Context, params moleculer.Payload) [
1111
type EventStorer interface {
1212
Mixin() moleculer.Mixin
1313

14-
MapEvent(eventName string, extraParams ...map[string]interface{}) moleculer.Event
14+
MapEvent(originEvent, persistentEvent string, extraParams ...map[string]interface{}) moleculer.Event
1515

1616
MapAction(actionName string, eventName string, extraParams ...map[string]interface{}) moleculer.Action
1717

eventStore.service.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -277,11 +277,11 @@ func (e *eventStore) MapAction(actionName, eventName string, extraParams ...map[
277277
// that saves the payload as an event record inside the event store.
278278
// extraParams are label=value to be saved in the event record.
279279
// if it fails to save the event to the store it emits the event eventName.failed
280-
func (e *eventStore) MapEvent(eventName string, extraParams ...map[string]interface{}) moleculer.Event {
280+
func (e *eventStore) MapEvent(originEvent, persistentEvent string, extraParams ...map[string]interface{}) moleculer.Event {
281281
return moleculer.Event{
282-
Name: eventName,
282+
Name: originEvent,
283283
Handler: func(c moleculer.Context, p moleculer.Payload) {
284-
e.saveEvent(c, p, eventName, extraParams...)
284+
e.saveEvent(c, p, persistentEvent, extraParams...)
285285
},
286286
}
287287
}

0 commit comments

Comments
 (0)