Skip to content

Commit adf4f79

Browse files
committed
updates
1 parent 99b6d54 commit adf4f79

File tree

1 file changed

+14
-17
lines changed

1 file changed

+14
-17
lines changed

mongo/integration/cmd_monitoring_helpers_test.go

+14-17
Original file line numberDiff line numberDiff line change
@@ -270,14 +270,20 @@ func checkExpectations(mt *mtest.T, expectations *[]*expectation, id0, id1 bson.
270270
return
271271
}
272272

273-
startedEvents := make([]*cmdStartedEvt, len(*expectations))
274-
succeededEvents := make([]*cmdSucceededEvt, len(*expectations))
275-
failedEvents := make([]*cmdFailedEvt, len(*expectations))
276-
277-
for idx, expectation := range *expectations {
278-
startedEvents[idx] = expectation.CommandStartedEvent
279-
succeededEvents[idx] = expectation.CommandSucceededEvent
280-
failedEvents[idx] = expectation.CommandFailedEvent
273+
startedEvents := make([]*cmdStartedEvt, 0, len(*expectations))
274+
succeededEvents := make([]*cmdSucceededEvt, 0, len(*expectations))
275+
failedEvents := make([]*cmdFailedEvt, 0, len(*expectations))
276+
277+
for _, expectation := range *expectations {
278+
if expectation.CommandStartedEvent != nil {
279+
startedEvents = append(startedEvents, expectation.CommandStartedEvent)
280+
}
281+
if expectation.CommandSucceededEvent != nil {
282+
succeededEvents = append(succeededEvents, expectation.CommandSucceededEvent)
283+
}
284+
if expectation.CommandFailedEvent != nil {
285+
failedEvents = append(failedEvents, expectation.CommandFailedEvent)
286+
}
281287
}
282288

283289
var err error
@@ -310,9 +316,6 @@ func compareStartedEvents(mt *mtest.T, expectations []*cmdStartedEvt, id0, id1 b
310316
}
311317

312318
compare := func(expected *cmdStartedEvt) error {
313-
if expected == nil {
314-
return nil
315-
}
316319
if len(expected.Extra) > 0 {
317320
return fmt.Errorf("unrecognized fields for CommandStartedEvent: %v", expected.Extra)
318321
}
@@ -450,9 +453,6 @@ func compareSucceededEvents(mt *mtest.T, expectations []*cmdSucceededEvt) error
450453
}
451454

452455
compare := func(expected *cmdSucceededEvt) error {
453-
if expected == nil {
454-
return nil
455-
}
456456
if len(expected.Extra) > 0 {
457457
return fmt.Errorf("unrecognized fields for CommandSucceededEvent: %v", expected.Extra)
458458
}
@@ -514,9 +514,6 @@ func compareFailedEvents(mt *mtest.T, expectations []*cmdFailedEvt) error {
514514
}
515515

516516
compare := func(expected *cmdFailedEvt) error {
517-
if expected == nil {
518-
return nil
519-
}
520517
if len(expected.Extra) > 0 {
521518
return fmt.Errorf("unrecognized fields for CommandFailedEvent: %v", expected.Extra)
522519
}

0 commit comments

Comments
 (0)