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

Fixed aggregate versions ordering
hellofresh · Feb 25, 2019 · 7ccfaf2 · 7ccfaf2
2 parents 78c03a3 + b912bac
commit 7ccfaf2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
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),
 		},