Use EventMeta.Sspawn()

emacsway · May 26, 2024 · 3aa6996 · 3aa6996
1 parent df48cab
commit 3aa6996
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/grade/internal/domain/seedwork/aggregate/event_meta.go b/grade/internal/domain/seedwork/aggregate/event_meta.go
@@ -64,6 +64,7 @@ func (m EventMeta) Reason() string {
 
 func (m EventMeta) Spawn(eventId uuid.Uuid) EventMeta {
 	n := m
+	n.causationId = n.eventId
 	n.eventId = eventId
 	return n
 }

diff --git a/grade/internal/infrastructure/seedwork/repository/event_store.go b/grade/internal/infrastructure/seedwork/repository/event_store.go
@@ -2,6 +2,7 @@ package repository
 
 import (
 	"github.com/emacsway/grade/grade/internal/domain/seedwork/aggregate"
+	"github.com/emacsway/grade/grade/internal/domain/seedwork/uuid"
 	"github.com/emacsway/grade/grade/internal/infrastructure/seedwork/session"
 )
 
@@ -33,7 +34,10 @@ func (r *EventStore) Save(
 	eventMeta aggregate.EventMeta,
 ) error {
 	pendingEvents := agg.PendingDomainEvents()
+	agg.ClearPendingDomainEvents()
+
 	for _, iEvent := range pendingEvents {
+		eventMeta = eventMeta.Spawn(uuid.NewUuid())
 		iEvent.SetEventMeta(eventMeta)
 		q := r.eventQuery(iEvent)
 		q.SetStreamType(r.streamType)
@@ -42,6 +46,5 @@ func (r *EventStore) Save(
 			return err
 		}
 	}
-	agg.ClearPendingDomainEvents()
 	return nil
 }