Fixed Count command

vgarvardt · vgarvardt · commit 9e8734d7cf4d · 2019-02-25T12:43:34.000+01:00
diff --git a/mongodb/eventstore.go b/mongodb/eventstore.go
@@ -163,7 +163,7 @@ func (s *EventStore) CountEventsFor(streamName goengine.StreamName, id string) (
 	ctx, cancel := s.cs.CountEventsFor()
 	defer cancel()
 
-	return s.mongoDB.Collection(string(streamName)).Count(ctx, bson.M{"aggregate_id": string(streamName)})
+	return s.mongoDB.Collection(string(streamName)).CountDocuments(ctx, bson.M{"aggregate_id": string(streamName)})
 }
 
 func (s *EventStore) createIndices(c *mongo.Collection) error {

Original file line number	Diff line number	Diff line change
`@@ -163,7 +163,7 @@ func (s *EventStore) CountEventsFor(streamName goengine.StreamName, id string) (`
`163`	`163`	`ctx, cancel := s.cs.CountEventsFor()`
`164`	`164`	`defer cancel()`
`165`	`165`
`166`		`- return s.mongoDB.Collection(string(streamName)).Count(ctx, bson.M{"aggregate_id": string(streamName)})`
	`166`	`+ return s.mongoDB.Collection(string(streamName)).CountDocuments(ctx, bson.M{"aggregate_id": string(streamName)})`
`167`	`167`	`}`
`168`	`168`
`169`	`169`	`func (s EventStore) createIndices(c mongo.Collection) error {`