fix(eventstore/mongodb): pass context with transaction to inTx handler

looplab · Mar 11, 2022 · 441b029 · 441b029
1 parent d9133a0
commit 441b029
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/eventstore/mongodb_v2/eventstore.go b/eventstore/mongodb_v2/eventstore.go
@@ -354,7 +354,7 @@ func (s *EventStore) Save(ctx context.Context, events []eh.Event, originalVersio
 
 		if s.eventHandlerInTX != nil {
 			for _, e := range events {
-				if err := s.eventHandlerInTX.HandleEvent(ctx, e); err != nil {
+				if err := s.eventHandlerInTX.HandleEvent(txCtx, e); err != nil {
 					return nil, fmt.Errorf("could not handle event in transaction: %w", err)
 				}
 			}