Update aggregate_repository.go

Tomaž Žinko · web-flow · commit 7a6acf301e11 · 2017-03-23T12:20:37.000+01:00
diff --git a/aggregate_repository.go b/aggregate_repository.go
@@ -58,6 +58,10 @@ func (r *PublisherRepository) Reconstitute(id string, source AggregateRoot, stre
 	}
 	events := stream.Events
 
+	if len(events) == 0 {
+		return errors.New("No events found for this id")
+	}
+
 	for _, event := range events {
 		source.Apply(event.Payload)
 	}

Original file line number	Diff line number	Diff line change
`@@ -58,6 +58,10 @@ func (r *PublisherRepository) Reconstitute(id string, source AggregateRoot, stre`
`58`	`58`	`}`
`59`	`59`	`events := stream.Events`
`60`	`60`
	`61`	`+ if len(events) == 0 {`
	`62`	`+ return errors.New("No events found for this id")`
	`63`	`+ }`
	`64`	`+`
`61`	`65`	`for _, event := range events {`
`62`	`66`	`source.Apply(event.Payload)`
`63`	`67`	`}`