From 9fe65e16c641c1a53ce714bb6ef9d8e706f96e15 Mon Sep 17 00:00:00 2001 From: Gustavo Bazan Date: Mon, 11 Mar 2024 18:20:07 +0000 Subject: [PATCH] task: remove all references to go.mongodb.org/atlas-sdk/v20231115007 (#2753) --- build/ci/library_owners.json | 1 - go.mod | 1 - go.sum | 2 -- internal/watchers/watcher.go | 28 ++++------------------------ 4 files changed, 4 insertions(+), 28 deletions(-) diff --git a/build/ci/library_owners.json b/build/ci/library_owners.json index 969ff75341..32718c2574 100644 --- a/build/ci/library_owners.json +++ b/build/ci/library_owners.json @@ -26,7 +26,6 @@ "github.com/stretchr/testify": "mongocli", "github.com/tangzero/inflector": "mongocli", "go.mongodb.org/atlas": "mongocli", - "go.mongodb.org/atlas-sdk/v20231115007": "mongocli", "go.mongodb.org/mongo-driver": "mongocli", "go.mongodb.org/ops-manager": "mongocli", "golang.org/x/crypto": "mongocli", diff --git a/go.mod b/go.mod index d7bb725e48..6a3da1088d 100644 --- a/go.mod +++ b/go.mod @@ -28,7 +28,6 @@ require ( github.com/stretchr/testify v1.9.0 github.com/tangzero/inflector v1.0.0 go.mongodb.org/atlas v0.36.0 - go.mongodb.org/atlas-sdk/v20231115007 v20231115007.0.0 go.mongodb.org/mongo-driver v1.14.0 go.mongodb.org/ops-manager v0.55.3 golang.org/x/crypto v0.21.0 diff --git a/go.sum b/go.sum index 3e70830a75..ad417e6498 100644 --- a/go.sum +++ b/go.sum @@ -210,8 +210,6 @@ github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1 github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= go.mongodb.org/atlas v0.36.0 h1:m05S3AO7zkl+bcG1qaNsEKBnAqnKx2FDwLooHpIG3j4= go.mongodb.org/atlas v0.36.0/go.mod h1:nfPldE9dSama6G2IbIzmEza02Ly7yFZjMMVscaM0uEc= -go.mongodb.org/atlas-sdk/v20231115007 v20231115007.0.0 h1:gvUBkSoeNtM9FSBQy8rh6cm6qXn4yXbQGzK09X0eAdk= -go.mongodb.org/atlas-sdk/v20231115007 v20231115007.0.0/go.mod h1:JU7JOUGcv7pfDzbRTwIr8hGy2R1lehdrdfGj9fDjSVY= go.mongodb.org/mongo-driver v1.14.0 h1:P98w8egYRjYe3XDjxhYJagTokP/H6HzlsnojRgZRd80= go.mongodb.org/mongo-driver v1.14.0/go.mod h1:Vzb0Mk/pa7e6cWw85R4F/endUC3u0U9jGcNU603k65c= go.mongodb.org/ops-manager v0.55.3 h1:ZckNLra9XfvUxWgRfdCVOr7QkeCPi7S4VNbcK5di/2A= diff --git a/internal/watchers/watcher.go b/internal/watchers/watcher.go index 6ac64ca0f5..3c0a5a9680 100644 --- a/internal/watchers/watcher.go +++ b/internal/watchers/watcher.go @@ -19,8 +19,7 @@ import ( "fmt" "time" - atlasv2 "go.mongodb.org/atlas-sdk/v20231115007/admin" - atlas "go.mongodb.org/atlas/mongodbatlas" + "go.mongodb.org/ops-manager/opsmngr" ) type InvalidStateError struct { @@ -69,20 +68,6 @@ type Watcher struct { defaultWait time.Duration } -const defaultWait = 4 * time.Second - -func NewWatcher(stateTransition StateTransition, describer StateDescriber) *Watcher { - return NewWatcherWithDefaultWait(stateTransition, describer, defaultWait) -} - -func NewWatcherWithDefaultWait(stateTransition StateTransition, describer StateDescriber, defaultWait time.Duration) *Watcher { - return &Watcher{ - stateTransition: stateTransition, - describer: describer, - defaultWait: defaultWait, - } -} - func (watcher *Watcher) Watch() error { watcher.hasStarted = false if watcher.NonConstantBackoff { @@ -184,8 +169,8 @@ func (st *StateTransition) IsEndError(err error) bool { return false } - var atlasErr *atlas.ErrorResponse - var atlasv2Err *atlasv2.GenericOpenAPIError + var atlasErr *opsmngr.ErrorResponse + var errCode string if st.EndErrorCode == nil { @@ -195,8 +180,6 @@ func (st *StateTransition) IsEndError(err error) bool { switch { case errors.As(err, &atlasErr): errCode = atlasErr.ErrorCode - case errors.As(err, &atlasv2Err): - errCode = *atlasv2Err.Model().ErrorCode default: return false } @@ -209,15 +192,12 @@ func (st *StateTransition) HasEndError() bool { } func (st *StateTransition) IsRetryableError(err error) bool { - var atlasErr *atlas.ErrorResponse - var atlasv2Err *atlasv2.GenericOpenAPIError + var atlasErr *opsmngr.ErrorResponse var errCode string switch { case errors.As(err, &atlasErr): errCode = atlasErr.ErrorCode - case errors.As(err, &atlasv2Err): - errCode = *atlasv2Err.Model().ErrorCode default: return false }