1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822
|
// Copyright (C) MongoDB, Inc. 2017-present.
//
// Licensed under the Apache License, Version 2.0 (the "License"); you may
// not use this file except in compliance with the License. You may obtain
// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
package mtest
import (
"context"
"fmt"
"strings"
"sync"
"sync/atomic"
"testing"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/event"
"go.mongodb.org/mongo-driver/internal/testutil/assert"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
"go.mongodb.org/mongo-driver/mongo/readconcern"
"go.mongodb.org/mongo-driver/mongo/readpref"
"go.mongodb.org/mongo-driver/mongo/writeconcern"
"go.mongodb.org/mongo-driver/x/mongo/driver"
)
var (
// Background is a no-op context.
Background = context.Background()
// MajorityWc is the majority write concern.
MajorityWc = writeconcern.New(writeconcern.WMajority())
// PrimaryRp is the primary read preference.
PrimaryRp = readpref.Primary()
// SecondaryRp is the secondary read preference.
SecondaryRp = readpref.Secondary()
// LocalRc is the local read concern
LocalRc = readconcern.Local()
// MajorityRc is the majority read concern
MajorityRc = readconcern.Majority()
)
const (
namespaceExistsErrCode int32 = 48
)
// FailPoint is a representation of a server fail point.
// See https://github.com/mongodb/specifications/tree/HEAD/source/transactions/tests#server-fail-point
// for more information regarding fail points.
type FailPoint struct {
ConfigureFailPoint string `bson:"configureFailPoint"`
// Mode should be a string, FailPointMode, or map[string]interface{}
Mode interface{} `bson:"mode"`
Data FailPointData `bson:"data"`
}
// FailPointMode is a representation of the Failpoint.Mode field.
type FailPointMode struct {
Times int32 `bson:"times"`
Skip int32 `bson:"skip"`
}
// FailPointData is a representation of the FailPoint.Data field.
type FailPointData struct {
FailCommands []string `bson:"failCommands,omitempty"`
CloseConnection bool `bson:"closeConnection,omitempty"`
ErrorCode int32 `bson:"errorCode,omitempty"`
FailBeforeCommitExceptionCode int32 `bson:"failBeforeCommitExceptionCode,omitempty"`
ErrorLabels *[]string `bson:"errorLabels,omitempty"`
WriteConcernError *WriteConcernErrorData `bson:"writeConcernError,omitempty"`
BlockConnection bool `bson:"blockConnection,omitempty"`
BlockTimeMS int32 `bson:"blockTimeMS,omitempty"`
AppName string `bson:"appName,omitempty"`
}
// WriteConcernErrorData is a representation of the FailPoint.Data.WriteConcern field.
type WriteConcernErrorData struct {
Code int32 `bson:"code"`
Name string `bson:"codeName"`
Errmsg string `bson:"errmsg"`
ErrorLabels *[]string `bson:"errorLabels,omitempty"`
ErrInfo bson.Raw `bson:"errInfo,omitempty"`
}
// T is a wrapper around testing.T.
type T struct {
// connsCheckedOut is the net number of connections checked out during test execution.
// It must be accessed using the atomic package and should be at the beginning of the struct.
// - atomic bug: https://pkg.go.dev/sync/atomic#pkg-note-BUG
// - suggested layout: https://go101.org/article/memory-layout.html
connsCheckedOut int64
*testing.T
// members for only this T instance
createClient *bool
createCollection *bool
runOn []RunOnBlock
mockDeployment *mockDeployment // nil if the test is not being run against a mock
mockResponses []bson.D
createdColls []*Collection // collections created in this test
proxyDialer *proxyDialer
dbName, collName string
failPointNames []string
minServerVersion string
maxServerVersion string
validTopologies []TopologyKind
auth *bool
enterprise *bool
dataLake *bool
ssl *bool
collCreateOpts bson.D
requireAPIVersion *bool
// options copied to sub-tests
clientType ClientType
clientOpts *options.ClientOptions
collOpts *options.CollectionOptions
shareClient *bool
baseOpts *Options // used to create subtests
// command monitoring channels
monitorLock sync.Mutex
started []*event.CommandStartedEvent
succeeded []*event.CommandSucceededEvent
failed []*event.CommandFailedEvent
Client *mongo.Client
DB *mongo.Database
Coll *mongo.Collection
}
func newT(wrapped *testing.T, opts ...*Options) *T {
t := &T{
T: wrapped,
}
for _, opt := range opts {
for _, optFn := range opt.optFuncs {
optFn(t)
}
}
if err := t.verifyConstraints(); err != nil {
t.Skipf("skipping due to environmental constraints: %v", err)
}
if t.collName == "" {
t.collName = t.Name()
}
if t.dbName == "" {
t.dbName = TestDb
}
t.collName = sanitizeCollectionName(t.dbName, t.collName)
// create a set of base options for sub-tests
t.baseOpts = NewOptions().ClientOptions(t.clientOpts).CollectionOptions(t.collOpts).ClientType(t.clientType)
if t.shareClient != nil {
t.baseOpts.ShareClient(*t.shareClient)
}
return t
}
// New creates a new T instance with the given options. If the current environment does not satisfy constraints
// specified in the options, the test will be skipped automatically.
func New(wrapped *testing.T, opts ...*Options) *T {
t := newT(wrapped, opts...)
// only create a client if it needs to be shared in sub-tests
// otherwise, a new client will be created for each subtest
if t.shareClient != nil && *t.shareClient {
t.createTestClient()
}
return t
}
// Close cleans up any resources associated with a T. There should be one Close corresponding to every New.
func (t *T) Close() {
if t.Client == nil {
return
}
// only clear collections and fail points if the test is not running against a mock
if t.clientType != Mock {
t.ClearCollections()
t.ClearFailPoints()
}
// always disconnect the client regardless of clientType because Client.Disconnect will work against
// all deployments
_ = t.Client.Disconnect(Background)
}
// Run creates a new T instance for a sub-test and runs the given callback. It also creates a new collection using the
// given name which is available to the callback through the T.Coll variable and is dropped after the callback
// returns.
func (t *T) Run(name string, callback func(*T)) {
t.RunOpts(name, NewOptions(), callback)
}
// RunOpts creates a new T instance for a sub-test with the given options. If the current environment does not satisfy
// constraints specified in the options, the new sub-test will be skipped automatically. If the test is not skipped,
// the callback will be run with the new T instance. RunOpts creates a new collection with the given name which is
// available to the callback through the T.Coll variable and is dropped after the callback returns.
func (t *T) RunOpts(name string, opts *Options, callback func(*T)) {
t.T.Run(name, func(wrapped *testing.T) {
sub := newT(wrapped, t.baseOpts, opts)
// add any mock responses for this test
if sub.clientType == Mock && len(sub.mockResponses) > 0 {
sub.AddMockResponses(sub.mockResponses...)
}
// for shareClient, inherit the client from the parent
if sub.shareClient != nil && *sub.shareClient && sub.clientType == t.clientType {
sub.Client = t.Client
}
// only create a client if not already set
if sub.Client == nil {
if sub.createClient == nil || *sub.createClient {
sub.createTestClient()
}
}
// create a collection for this test
if sub.Client != nil {
sub.createTestCollection()
}
// defer dropping all collections if the test is using a client
defer func() {
if sub.Client == nil {
return
}
// store number of sessions and connections checked out here but assert that they're equal to 0 after
// cleaning up test resources to make sure resources are always cleared
sessions := sub.Client.NumberSessionsInProgress()
conns := sub.NumberConnectionsCheckedOut()
if sub.clientType != Mock {
sub.ClearFailPoints()
sub.ClearCollections()
}
// only disconnect client if it's not being shared
if sub.shareClient == nil || !*sub.shareClient {
_ = sub.Client.Disconnect(Background)
}
assert.Equal(sub, 0, sessions, "%v sessions checked out", sessions)
assert.Equal(sub, 0, conns, "%v connections checked out", conns)
}()
// clear any events that may have happened during setup and run the test
sub.ClearEvents()
callback(sub)
})
}
// AddMockResponses adds responses to be returned by the mock deployment. This should only be used if T is being run
// against a mock deployment.
func (t *T) AddMockResponses(responses ...bson.D) {
t.mockDeployment.addResponses(responses...)
}
// ClearMockResponses clears all responses in the mock deployment.
func (t *T) ClearMockResponses() {
t.mockDeployment.clearResponses()
}
// GetStartedEvent returns the most recent CommandStartedEvent, or nil if one is not present.
// This can only be called once per event.
// TODO(GODRIVER-2075): GetStartedEvent documents that it returns the most recent event, but
// actually returns the first event. Update either the documentation or implementation.
func (t *T) GetStartedEvent() *event.CommandStartedEvent {
if len(t.started) == 0 {
return nil
}
e := t.started[0]
t.started = t.started[1:]
return e
}
// GetSucceededEvent returns the most recent CommandSucceededEvent, or nil if one is not present.
// This can only be called once per event.
// TODO(GODRIVER-2075): GetSucceededEvent documents that it returns the most recent event, but
// actually returns the first event. Update either the documentation or implementation.
func (t *T) GetSucceededEvent() *event.CommandSucceededEvent {
if len(t.succeeded) == 0 {
return nil
}
e := t.succeeded[0]
t.succeeded = t.succeeded[1:]
return e
}
// GetFailedEvent returns the most recent CommandFailedEvent, or nil if one is not present.
// This can only be called once per event.
// TODO(GODRIVER-2075): GetFailedEvent documents that it returns the most recent event, but actually
// returns the first event. Update either the documentation or implementation.
func (t *T) GetFailedEvent() *event.CommandFailedEvent {
if len(t.failed) == 0 {
return nil
}
e := t.failed[0]
t.failed = t.failed[1:]
return e
}
// GetAllStartedEvents returns a slice of all CommandStartedEvent instances for this test. This can be called multiple
// times.
func (t *T) GetAllStartedEvents() []*event.CommandStartedEvent {
return t.started
}
// GetAllSucceededEvents returns a slice of all CommandSucceededEvent instances for this test. This can be called multiple
// times.
func (t *T) GetAllSucceededEvents() []*event.CommandSucceededEvent {
return t.succeeded
}
// GetAllFailedEvents returns a slice of all CommandFailedEvent instances for this test. This can be called multiple
// times.
func (t *T) GetAllFailedEvents() []*event.CommandFailedEvent {
return t.failed
}
// FilterStartedEvents filters the existing CommandStartedEvent instances for this test using the provided filter
// callback. An event will be retained if the filter returns true. The list of filtered events will be used to overwrite
// the list of events for this test and will therefore change the output of t.GetAllStartedEvents().
func (t *T) FilterStartedEvents(filter func(*event.CommandStartedEvent) bool) {
var newEvents []*event.CommandStartedEvent
for _, evt := range t.started {
if filter(evt) {
newEvents = append(newEvents, evt)
}
}
t.started = newEvents
}
// FilterSucceededEvents filters the existing CommandSucceededEvent instances for this test using the provided filter
// callback. An event will be retained if the filter returns true. The list of filtered events will be used to overwrite
// the list of events for this test and will therefore change the output of t.GetAllSucceededEvents().
func (t *T) FilterSucceededEvents(filter func(*event.CommandSucceededEvent) bool) {
var newEvents []*event.CommandSucceededEvent
for _, evt := range t.succeeded {
if filter(evt) {
newEvents = append(newEvents, evt)
}
}
t.succeeded = newEvents
}
// FilterFailedEvents filters the existing CommandFailedEVent instances for this test using the provided filter
// callback. An event will be retained if the filter returns true. The list of filtered events will be used to overwrite
// the list of events for this test and will therefore change the output of t.GetAllFailedEvents().
func (t *T) FilterFailedEvents(filter func(*event.CommandFailedEvent) bool) {
var newEvents []*event.CommandFailedEvent
for _, evt := range t.failed {
if filter(evt) {
newEvents = append(newEvents, evt)
}
}
t.failed = newEvents
}
// GetProxiedMessages returns the messages proxied to the server by the test. If the client type is not Proxy, this
// returns nil.
func (t *T) GetProxiedMessages() []*ProxyMessage {
if t.proxyDialer == nil {
return nil
}
return t.proxyDialer.Messages()
}
// NumberConnectionsCheckedOut returns the number of connections checked out from the test Client.
func (t *T) NumberConnectionsCheckedOut() int {
return int(atomic.LoadInt64(&t.connsCheckedOut))
}
// ClearEvents clears the existing command monitoring events.
func (t *T) ClearEvents() {
t.started = t.started[:0]
t.succeeded = t.succeeded[:0]
t.failed = t.failed[:0]
}
// ResetClient resets the existing client with the given options. If opts is nil, the existing options will be used.
// If t.Coll is not-nil, it will be reset to use the new client. Should only be called if the existing client is
// not nil. This will Disconnect the existing client but will not drop existing collections. To do so, ClearCollections
// must be called before calling ResetClient.
func (t *T) ResetClient(opts *options.ClientOptions) {
if opts != nil {
t.clientOpts = opts
}
_ = t.Client.Disconnect(Background)
t.createTestClient()
t.DB = t.Client.Database(t.dbName)
t.Coll = t.DB.Collection(t.collName, t.collOpts)
for _, coll := range t.createdColls {
// If the collection was created using a different Client, it doesn't need to be reset.
if coll.hasDifferentClient {
continue
}
// If the namespace is the same as t.Coll, we can use t.Coll.
if coll.created.Name() == t.collName && coll.created.Database().Name() == t.dbName {
coll.created = t.Coll
continue
}
// Otherwise, reset the collection to use the new Client.
coll.created = t.Client.Database(coll.DB).Collection(coll.Name, coll.Opts)
}
}
// Collection is used to configure a new collection created during a test.
type Collection struct {
Name string
DB string // defaults to mt.DB.Name() if not specified
Client *mongo.Client // defaults to mt.Client if not specified
Opts *options.CollectionOptions
CreateOpts bson.D
hasDifferentClient bool
created *mongo.Collection // the actual collection that was created
}
// CreateCollection creates a new collection with the given configuration. The collection will be dropped after the test
// finishes running. If createOnServer is true, the function ensures that the collection has been created server-side
// by running the create command. The create command will appear in command monitoring channels.
func (t *T) CreateCollection(coll Collection, createOnServer bool) *mongo.Collection {
if coll.DB == "" {
coll.DB = t.DB.Name()
}
if coll.Client == nil {
coll.Client = t.Client
}
coll.hasDifferentClient = coll.Client != t.Client
db := coll.Client.Database(coll.DB)
if createOnServer && t.clientType != Mock {
cmd := bson.D{{"create", coll.Name}}
cmd = append(cmd, coll.CreateOpts...)
if err := db.RunCommand(Background, cmd).Err(); err != nil {
// ignore NamespaceExists errors for idempotency
cmdErr, ok := err.(mongo.CommandError)
if !ok || cmdErr.Code != namespaceExistsErrCode {
t.Fatalf("error creating collection %v on server: %v", coll.Name, err)
}
}
}
coll.created = db.Collection(coll.Name, coll.Opts)
t.createdColls = append(t.createdColls, &coll)
return coll.created
}
// ClearCollections drops all collections previously created by this test.
func (t *T) ClearCollections() {
// Collections should not be dropped when testing against Atlas Data Lake because the data is pre-inserted.
if !testContext.dataLake {
for _, coll := range t.createdColls {
_ = coll.created.Drop(Background)
}
}
t.createdColls = t.createdColls[:0]
}
// SetFailPoint sets a fail point for the client associated with T. Commands to create the failpoint will appear
// in command monitoring channels. The fail point will automatically be disabled after this test has run.
func (t *T) SetFailPoint(fp FailPoint) {
// ensure mode fields are int32
if modeMap, ok := fp.Mode.(map[string]interface{}); ok {
var key string
var err error
if times, ok := modeMap["times"]; ok {
key = "times"
modeMap["times"], err = t.interfaceToInt32(times)
}
if skip, ok := modeMap["skip"]; ok {
key = "skip"
modeMap["skip"], err = t.interfaceToInt32(skip)
}
if err != nil {
t.Fatalf("error converting %s to int32: %v", key, err)
}
}
if err := SetFailPoint(fp, t.Client); err != nil {
t.Fatal(err)
}
t.failPointNames = append(t.failPointNames, fp.ConfigureFailPoint)
}
// SetFailPointFromDocument sets the fail point represented by the given document for the client associated with T. This
// method assumes that the given document is in the form {configureFailPoint: <failPointName>, ...}. Commands to create
// the failpoint will appear in command monitoring channels. The fail point will be automatically disabled after this
// test has run.
func (t *T) SetFailPointFromDocument(fp bson.Raw) {
if err := SetRawFailPoint(fp, t.Client); err != nil {
t.Fatal(err)
}
name := fp.Index(0).Value().StringValue()
t.failPointNames = append(t.failPointNames, name)
}
// TrackFailPoint adds the given fail point to the list of fail points to be disabled when the current test finishes.
// This function does not create a fail point on the server.
func (t *T) TrackFailPoint(fpName string) {
t.failPointNames = append(t.failPointNames, fpName)
}
// ClearFailPoints disables all previously set failpoints for this test.
func (t *T) ClearFailPoints() {
db := t.Client.Database("admin")
for _, fp := range t.failPointNames {
cmd := bson.D{
{"configureFailPoint", fp},
{"mode", "off"},
}
err := db.RunCommand(Background, cmd).Err()
if err != nil {
t.Fatalf("error clearing fail point %s: %v", fp, err)
}
}
t.failPointNames = t.failPointNames[:0]
}
// CloneDatabase modifies the default database for this test to match the given options.
func (t *T) CloneDatabase(opts *options.DatabaseOptions) {
t.DB = t.Client.Database(t.dbName, opts)
}
// CloneCollection modifies the default collection for this test to match the given options.
func (t *T) CloneCollection(opts *options.CollectionOptions) {
var err error
t.Coll, err = t.Coll.Clone(opts)
assert.Nil(t, err, "error cloning collection: %v", err)
}
func sanitizeCollectionName(db string, coll string) string {
// Collections can't have "$" in their names, so we substitute it with "%".
coll = strings.Replace(coll, "$", "%", -1)
// Namespaces can only have 120 bytes max.
if len(db+"."+coll) >= 120 {
// coll len must be <= remaining
remaining := 120 - (len(db) + 1) // +1 for "."
coll = coll[len(coll)-remaining:]
}
return coll
}
func (t *T) createTestClient() {
clientOpts := t.clientOpts
if clientOpts == nil {
// default opts
clientOpts = options.Client().SetWriteConcern(MajorityWc).SetReadPreference(PrimaryRp)
}
// set ServerAPIOptions to latest version if required
if clientOpts.Deployment == nil && t.clientType != Mock && clientOpts.ServerAPIOptions == nil && testContext.requireAPIVersion {
clientOpts.SetServerAPIOptions(options.ServerAPI(driver.TestServerAPIVersion))
}
// command monitor
clientOpts.SetMonitor(&event.CommandMonitor{
Started: func(_ context.Context, cse *event.CommandStartedEvent) {
t.monitorLock.Lock()
defer t.monitorLock.Unlock()
t.started = append(t.started, cse)
},
Succeeded: func(_ context.Context, cse *event.CommandSucceededEvent) {
t.monitorLock.Lock()
defer t.monitorLock.Unlock()
t.succeeded = append(t.succeeded, cse)
},
Failed: func(_ context.Context, cfe *event.CommandFailedEvent) {
t.monitorLock.Lock()
defer t.monitorLock.Unlock()
t.failed = append(t.failed, cfe)
},
})
// only specify connection pool monitor if no deployment is given
if clientOpts.Deployment == nil {
previousPoolMonitor := clientOpts.PoolMonitor
clientOpts.SetPoolMonitor(&event.PoolMonitor{
Event: func(evt *event.PoolEvent) {
if previousPoolMonitor != nil {
previousPoolMonitor.Event(evt)
}
switch evt.Type {
case event.GetSucceeded:
atomic.AddInt64(&t.connsCheckedOut, 1)
case event.ConnectionReturned:
atomic.AddInt64(&t.connsCheckedOut, -1)
}
},
})
}
var err error
switch t.clientType {
case Pinned:
// pin to first mongos
pinnedHostList := []string{testContext.connString.Hosts[0]}
uriOpts := options.Client().ApplyURI(testContext.connString.Original).SetHosts(pinnedHostList)
t.Client, err = mongo.NewClient(uriOpts, clientOpts)
case Mock:
// clear pool monitor to avoid configuration error
clientOpts.PoolMonitor = nil
t.mockDeployment = newMockDeployment()
clientOpts.Deployment = t.mockDeployment
t.Client, err = mongo.NewClient(clientOpts)
case Proxy:
t.proxyDialer = newProxyDialer()
clientOpts.SetDialer(t.proxyDialer)
// After setting the Dialer, fall-through to the Default case to apply the correct URI
fallthrough
case Default:
// Use a different set of options to specify the URI because clientOpts may already have a URI or host seedlist
// specified.
var uriOpts *options.ClientOptions
if clientOpts.Deployment == nil {
// Only specify URI if the deployment is not set to avoid setting topology/server options along with the
// deployment.
uriOpts = options.Client().ApplyURI(testContext.connString.Original)
}
// Pass in uriOpts first so clientOpts wins if there are any conflicting settings.
t.Client, err = mongo.NewClient(uriOpts, clientOpts)
}
if err != nil {
t.Fatalf("error creating client: %v", err)
}
if err := t.Client.Connect(Background); err != nil {
t.Fatalf("error connecting client: %v", err)
}
}
func (t *T) createTestCollection() {
t.DB = t.Client.Database(t.dbName)
t.createdColls = t.createdColls[:0]
// Collections should not be explicitly created when testing against Atlas Data Lake because they already exist in
// the server with pre-seeded data.
createOnServer := (t.createCollection == nil || *t.createCollection) && !testContext.dataLake
t.Coll = t.CreateCollection(Collection{
Name: t.collName,
CreateOpts: t.collCreateOpts,
Opts: t.collOpts,
}, createOnServer)
}
// verifyVersionConstraints returns an error if the cluster's server version is not in the range [min, max]. Server
// versions will only be checked if they are non-empty.
func verifyVersionConstraints(min, max string) error {
if min != "" && CompareServerVersions(testContext.serverVersion, min) < 0 {
return fmt.Errorf("server version %q is lower than min required version %q", testContext.serverVersion, min)
}
if max != "" && CompareServerVersions(testContext.serverVersion, max) > 0 {
return fmt.Errorf("server version %q is higher than max version %q", testContext.serverVersion, max)
}
return nil
}
// verifyTopologyConstraints returns an error if the cluster's topology kind does not match one of the provided
// kinds. If the topologies slice is empty, nil is returned without any additional checks.
func verifyTopologyConstraints(topologies []TopologyKind) error {
if len(topologies) == 0 {
return nil
}
for _, topo := range topologies {
// For ShardedReplicaSet, we won't get an exact match because testContext.topoKind will be Sharded so we do an
// additional comparison with the testContext.shardedReplicaSet field.
if topo == testContext.topoKind || (topo == ShardedReplicaSet && testContext.shardedReplicaSet) {
return nil
}
}
return fmt.Errorf("topology kind %q does not match any of the required kinds %q", testContext.topoKind, topologies)
}
func verifyServerParametersConstraints(serverParameters map[string]bson.RawValue) error {
for param, expected := range serverParameters {
actual, err := testContext.serverParameters.LookupErr(param)
if err != nil {
return fmt.Errorf("server does not support parameter %q", param)
}
if !expected.Equal(actual) {
return fmt.Errorf("mismatched values for server parameter %q; expected %s, got %s", param, expected, actual)
}
}
return nil
}
func verifyAuthConstraint(expected *bool) error {
if expected != nil && *expected != testContext.authEnabled {
return fmt.Errorf("test requires auth value: %v, cluster auth value: %v", *expected, testContext.authEnabled)
}
return nil
}
func verifyServerlessConstraint(expected string) error {
switch expected {
case "require":
if !testContext.serverless {
return fmt.Errorf("test requires serverless")
}
case "forbid":
if testContext.serverless {
return fmt.Errorf("test forbids serverless")
}
case "allow", "":
default:
return fmt.Errorf("invalid value for serverless: %s", expected)
}
return nil
}
// verifyRunOnBlockConstraint returns an error if the current environment does not match the provided RunOnBlock.
func verifyRunOnBlockConstraint(rob RunOnBlock) error {
if err := verifyVersionConstraints(rob.MinServerVersion, rob.MaxServerVersion); err != nil {
return err
}
if err := verifyTopologyConstraints(rob.Topology); err != nil {
return err
}
// Tests in the unified test format have runOn.auth to indicate whether the
// test should be run against an auth-enabled configuration. SDAM integration
// spec tests have runOn.authEnabled to indicate the same thing. Use whichever
// is set for verifyAuthConstraint().
auth := rob.Auth
if rob.AuthEnabled != nil {
if auth != nil {
return fmt.Errorf("runOnBlock cannot specify both auth and authEnabled")
}
auth = rob.AuthEnabled
}
if err := verifyAuthConstraint(auth); err != nil {
return err
}
if err := verifyServerlessConstraint(rob.Serverless); err != nil {
return err
}
return verifyServerParametersConstraints(rob.ServerParameters)
}
// verifyConstraints returns an error if the current environment does not match the constraints specified for the test.
func (t *T) verifyConstraints() error {
// Check constraints not specified as runOn blocks
if err := verifyVersionConstraints(t.minServerVersion, t.maxServerVersion); err != nil {
return err
}
if err := verifyTopologyConstraints(t.validTopologies); err != nil {
return err
}
if err := verifyAuthConstraint(t.auth); err != nil {
return err
}
if t.ssl != nil && *t.ssl != testContext.sslEnabled {
return fmt.Errorf("test requires ssl value: %v, cluster ssl value: %v", *t.ssl, testContext.sslEnabled)
}
if t.enterprise != nil && *t.enterprise != testContext.enterpriseServer {
return fmt.Errorf("test requires enterprise value: %v, cluster enterprise value: %v", *t.enterprise,
testContext.enterpriseServer)
}
if t.dataLake != nil && *t.dataLake != testContext.dataLake {
return fmt.Errorf("test requires cluster to be data lake: %v, cluster is data lake: %v", *t.dataLake,
testContext.dataLake)
}
if t.requireAPIVersion != nil && *t.requireAPIVersion != testContext.requireAPIVersion {
return fmt.Errorf("test requires RequireAPIVersion value: %v, local RequireAPIVersion value: %v", *t.requireAPIVersion,
testContext.requireAPIVersion)
}
// Check runOn blocks. The test can be executed if there are no blocks or at least block matches the current test
// setup.
if len(t.runOn) == 0 {
return nil
}
// Stop once we find a RunOnBlock that matches the current environment. Record all errors as we go because if we
// don't find any matching blocks, we want to report the comparison errors for each block.
var runOnErrors []error
for _, runOn := range t.runOn {
err := verifyRunOnBlockConstraint(runOn)
if err == nil {
return nil
}
runOnErrors = append(runOnErrors, err)
}
return fmt.Errorf("no matching RunOnBlock; comparison errors: %v", runOnErrors)
}
func (t *T) interfaceToInt32(i interface{}) (int32, error) {
switch conv := i.(type) {
case int:
return int32(conv), nil
case int32:
return conv, nil
case int64:
return int32(conv), nil
case float64:
return int32(conv), nil
}
return 0, fmt.Errorf("type %T cannot be converted to int32", i)
}
|