Merge pull request #15 from hellofresh/hotfix/version-ordering

vgarvardt · web-flow · commit 7ccfaf24efea · 2019-02-25T10:55:11.000+01:00
Fixed aggregate versions ordering
diff --git a/aggregate_repository.go b/aggregate_repository.go
@@ -73,6 +73,6 @@ func (r *PublisherRepository) Reconstitute(id string, source AggregateRoot, stre
 	}
 
 	source.SetVersion(events[len(events)-1].Version)
-	Log("Aggregate reconstituted", map[string]interface{}{"id": id}, nil)
+	Log("Aggregate reconstituted", map[string]interface{}{"id": id, "stream": streamName}, nil)
 	return nil
 }
diff --git a/mongodb/eventstore.go b/mongodb/eventstore.go
@@ -175,7 +175,7 @@ func (s *EventStore) createIndices(c *mongo.Collection) error {
 		mongo.IndexModel{
 			Keys: bsonx.Doc{
 				{Key: "aggregate_id", Value: bsonx.Int32(1)},
-				{Key: "version", Value: bsonx.Int32(-1)},
+				{Key: "version", Value: bsonx.Int32(1)},
 			},
 			Options: options.Index().SetUnique(true).SetBackground(true),
 		},

Original file line number	Diff line number	Diff line change
`@@ -73,6 +73,6 @@ func (r *PublisherRepository) Reconstitute(id string, source AggregateRoot, stre`
`73`	`73`	`}`
`74`	`74`
`75`	`75`	`source.SetVersion(events[len(events)-1].Version)`
`76`		`- Log("Aggregate reconstituted", map[string]interface{}{"id": id}, nil)`
	`76`	`+ Log("Aggregate reconstituted", map[string]interface{}{"id": id, "stream": streamName}, nil)`
`77`	`77`	`return nil`
`78`	`78`	`}`