Merge pull request #3 from hellofresh/fix/panic-empty-events

Tomaž Žinko · web-flow · commit 63167c869917 · 2017-03-23T12:39:55.000+01:00
Returns an error if events are empty
diff --git a/aggregate_repository.go b/aggregate_repository.go
@@ -1,6 +1,7 @@
 package goengine
 
 import (
+	"fmt"
 	log "github.com/Sirupsen/logrus"
 )
 
@@ -58,6 +59,10 @@ func (r *PublisherRepository) Reconstitute(id string, source AggregateRoot, stre
 	}
 	events := stream.Events
 
+	if len(events) == 0 {
+		return fmt.Errorf("No events found for id: %s", id)
+	}
+
 	for _, event := range events {
 		source.Apply(event.Payload)
 	}

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,7 @@`
`1`	`1`	`package goengine`
`2`	`2`
`3`	`3`	`import (`
	`4`	`+ "fmt"`
`4`	`5`	`log "github.com/Sirupsen/logrus"`
`5`	`6`	`)`
`6`	`7`
`@@ -58,6 +59,10 @@ func (r *PublisherRepository) Reconstitute(id string, source AggregateRoot, stre`
`58`	`59`	`}`
`59`	`60`	`events := stream.Events`
`60`	`61`
	`62`	`+ if len(events) == 0 {`
	`63`	`+ return fmt.Errorf("No events found for id: %s", id)`
	`64`	`+ }`
	`65`	`+`
`61`	`66`	`for _, event := range events {`
`62`	`67`	`source.Apply(event.Payload)`
`63`	`68`	`}`