OSD-19188: Get backplane URL via ocm environment

Fetch Backplane URL via OCM environment
openshift · Dec 11, 2023 · da7e96c · da7e96c
1 parent 4f63014
commit da7e96c
Show file tree

Hide file tree

Showing 17 changed files with 210 additions and 128 deletions.
diff --git a/cmd/ocm-backplane/console/console_test.go b/cmd/ocm-backplane/console/console_test.go
@@ -39,6 +39,7 @@ var _ = Describe("console command", func() {
  proxyURL string
  clusterInfo *cmv1.Cluster
  testKubeCfg api.Config
+ ocmEnv *cmv1.Environment
  )
 
  BeforeEach(func() {
@@ -125,6 +126,7 @@ var _ = Describe("console command", func() {
  dirName, _ := os.MkdirTemp("", ".kube")
 
  pullSecretConfigDirectory = dirName
+ ocmEnv, _ = cmv1.NewEnvironment().BackplaneURL("https://dummy.api").Build()
  })
 
  AfterEach(func() {
@@ -178,6 +180,7 @@ var _ = Describe("console command", func() {
  It("should start console server", func() {
  setupConfig()
 
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetPullSecret().Return(pullSecret, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetClusterInfoByID(clusterID).Return(clusterInfo, nil).AnyTimes()
@@ -196,6 +199,7 @@ var _ = Describe("console command", func() {
  testKubeCfg.CurrentContext = "custom-context"
  setupConfig()
 
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetPullSecret().Return(pullSecret, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetClusterInfoByID(clusterID).Return(clusterInfo, nil).AnyTimes()
@@ -213,6 +217,7 @@ var _ = Describe("console command", func() {
  testKubeCfg.CurrentContext = "undefined-context"
  setupConfig()
 
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetPullSecret().Return(pullSecret, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetClusterInfoByID(clusterID).Return(clusterInfo, nil).AnyTimes()

diff --git a/cmd/ocm-backplane/login/login_test.go b/cmd/ocm-backplane/login/login_test.go
@@ -14,6 +14,7 @@ import (
  "k8s.io/client-go/tools/clientcmd"
  "k8s.io/client-go/tools/clientcmd/api"
 
+ cmv1 "github.com/openshift-online/ocm-sdk-go/clustersmgmt/v1"
  "github.com/openshift/backplane-cli/pkg/backplaneapi"
  backplaneapiMock "github.com/openshift/backplane-cli/pkg/backplaneapi/mocks"
  "github.com/openshift/backplane-cli/pkg/client/mocks"
@@ -45,6 +46,7 @@ var _ = Describe("Login command", func() {
  serviceClusterID string
  serviceClusterName string
  fakeResp *http.Response
+ ocmEnv *cmv1.Environment
  )
 
  BeforeEach(func() {
@@ -80,6 +82,8 @@ var _ = Describe("Login command", func() {
  clientcmd.UseModifyConfigLock = false
 
  globalOpts.BackplaneURL = backplaneAPIURI
+
+ ocmEnv, _ = cmv1.NewEnvironment().BackplaneURL("https://dummy.api").Build()
  })
 
  AfterEach(func() {
@@ -95,6 +99,7 @@ var _ = Describe("Login command", func() {
  Context("check ocm token", func() {
 
  It("Should fail when failed to get OCM token", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(nil, errors.New("err")).AnyTimes()
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
@@ -108,6 +113,7 @@ var _ = Describe("Login command", func() {
  err := utils.CreateTempKubeConfig(nil)
  Expect(err).To(BeNil())
  globalOpts.ProxyURL = "https://squid.myproxy.com"
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockClientUtil.EXPECT().SetClientProxyURL(globalOpts.ProxyURL).Return(nil)
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
@@ -132,6 +138,7 @@ var _ = Describe("Login command", func() {
  err := utils.CreateTempKubeConfig(nil)
  Expect(err).To(BeNil())
  globalOpts.BackplaneURL = "https://sadge.app"
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil)
@@ -154,6 +161,7 @@ var _ = Describe("Login command", func() {
  err := utils.CreateTempKubeConfig(nil)
  Expect(err).To(BeNil())
  globalOpts.ProxyURL = "https://squid.myproxy.com"
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockClientUtil.EXPECT().SetClientProxyURL(globalOpts.ProxyURL).Return(nil)
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
@@ -176,6 +184,7 @@ var _ = Describe("Login command", func() {
  })
 
  It("should fail if unable to create api client", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil)
@@ -186,6 +195,15 @@ var _ = Describe("Login command", func() {
  Expect(err).ToNot(BeNil())
  })
 
+ It("should fail if ocm env backplane url is empty", func() {
+ ocmEnv, _ = cmv1.NewEnvironment().Build()
+
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
+ err := runLogin(nil, []string{testClusterID})
+
+ Expect(err).ToNot(BeNil())
+ })
+
  })
 
  Context("check cluster login", func() {
@@ -196,6 +214,7 @@ var _ = Describe("Login command", func() {
  It("when running with a simple case should work as expected", func() {
  err := utils.CreateTempKubeConfig(nil)
  Expect(err).To(BeNil())
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil)
@@ -215,6 +234,7 @@ var _ = Describe("Login command", func() {
  })
 
  It("Should fail when trying to find a non existent cluster", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
 
@@ -227,6 +247,7 @@ var _ = Describe("Login command", func() {
 
  It("should return the managing cluster if one is requested", func() {
  globalOpts.Manager = true
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().GetManagingCluster(trueClusterID).Return(managingClusterID, managingClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(managingClusterID)).Return(false, nil).AnyTimes()
@@ -241,6 +262,7 @@ var _ = Describe("Login command", func() {
 
  It("should failed if managing cluster not exist in same env", func() {
  globalOpts.Manager = true
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().GetManagingCluster(trueClusterID).Return(
  managingClusterID,
@@ -261,6 +283,7 @@ var _ = Describe("Login command", func() {
 
  It("should return the service cluster if hosted cluster is given", func() {
  globalOpts.Service = true
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().GetServiceCluster(trueClusterID).Return(serviceClusterID, serviceClusterName, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(serviceClusterID)).Return(false, nil).AnyTimes()
@@ -277,6 +300,7 @@ var _ = Describe("Login command", func() {
  err := utils.CreateTempKubeConfig(nil)
  Expect(err).To(BeNil())
  globalOpts.ProxyURL = "https://squid.myproxy.com"
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockClientUtil.EXPECT().SetClientProxyURL(globalOpts.ProxyURL).Return(nil)
  mockOcmInterface.EXPECT().GetTargetCluster("configcluster").Return(testClusterID, "dummy_cluster", nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(testClusterID)).Return(false, nil).AnyTimes()
@@ -299,6 +323,7 @@ var _ = Describe("Login command", func() {
 
  err := utils.CreateTempKubeConfig(nil)
  Expect(err).To(BeNil())
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil)
@@ -326,6 +351,7 @@ var _ = Describe("Login command", func() {
  _, err = login.CreateClusterKubeConfig(trueClusterID, utils.GetDefaultKubeConfig())
  Expect(err).To(BeNil())
 
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil)

diff --git a/cmd/ocm-backplane/logout/logout_test.go b/cmd/ocm-backplane/logout/logout_test.go
@@ -13,6 +13,7 @@ import (
  "k8s.io/client-go/tools/clientcmd"
  "k8s.io/client-go/tools/clientcmd/api"
 
+ cmv1 "github.com/openshift-online/ocm-sdk-go/clustersmgmt/v1"
  "github.com/openshift/backplane-cli/cmd/ocm-backplane/login"
  "github.com/openshift/backplane-cli/pkg/backplaneapi"
  backplaneapiMock "github.com/openshift/backplane-cli/pkg/backplaneapi/mocks"
@@ -48,6 +49,7 @@ var _ = Describe("Logout command", func() {
 
  kubeConfig api.Config
  loggedInNotBackplaneConfig api.Config
+ ocmEnv *cmv1.Environment
  )
 
  BeforeEach(func() {
@@ -114,6 +116,7 @@ var _ = Describe("Logout command", func() {
  }
 
  os.Setenv(info.BackplaneURLEnvName, backplaneAPIURI)
+ ocmEnv, _ = cmv1.NewEnvironment().BackplaneURL("https://dummy.api").Build()
  })
 
  AfterEach(func() {
@@ -128,6 +131,7 @@ var _ = Describe("Logout command", func() {
 
  err := utils.CreateTempKubeConfig(&kubeConfig)
  Expect(err).To(BeNil())
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil).AnyTimes()
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()

diff --git a/cmd/ocm-backplane/managedJob/createManagedJob_test.go b/cmd/ocm-backplane/managedJob/createManagedJob_test.go
@@ -15,6 +15,7 @@ import (
  "k8s.io/client-go/tools/clientcmd"
  "k8s.io/client-go/tools/clientcmd/api"
 
+ cmv1 "github.com/openshift-online/ocm-sdk-go/clustersmgmt/v1"
  "github.com/openshift/backplane-cli/pkg/backplaneapi"
  backplaneapiMock "github.com/openshift/backplane-cli/pkg/backplaneapi/mocks"
  "github.com/openshift/backplane-cli/pkg/client/mocks"
@@ -40,7 +41,8 @@ var _ = Describe("managedJob create command", func() {
  fakeJobResp *http.Response
  jobResponseBody string
 
- sut *cobra.Command
+ sut *cobra.Command
+ ocmEnv *cmv1.Environment
  )
 
  BeforeEach(func() {
@@ -95,6 +97,7 @@ var _ = Describe("managedJob create command", func() {
  _ = clientcmd.ModifyConfig(clientcmd.NewDefaultPathOptions(), api.Config{}, true)
 
  os.Setenv(info.BackplaneURLEnvName, proxyURI)
+ ocmEnv, _ = cmv1.NewEnvironment().BackplaneURL("https://dummy.api").Build()
  })
 
  AfterEach(func() {
@@ -104,6 +107,7 @@ var _ = Describe("managedJob create command", func() {
 
  Context("create managed job", func() {
  It("when running with a simple case should work as expected", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  // It should query for the internal cluster id first
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  // Then it will look for the backplane shard
@@ -119,6 +123,7 @@ var _ = Describe("managedJob create command", func() {
  })
 
  It("should respect url flag", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  // It should query for the internal cluster id first
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  // Then it will look for the backplane shard
@@ -134,6 +139,7 @@ var _ = Describe("managedJob create command", func() {
  })
 
  It("should fail when backplane did not return a 200", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
@@ -147,6 +153,7 @@ var _ = Describe("managedJob create command", func() {
  })
 
  It("should fail when backplane returns a non parsable response", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
@@ -161,6 +168,7 @@ var _ = Describe("managedJob create command", func() {
  })
 
  It("should wait for job to be finished", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
@@ -188,6 +196,7 @@ var _ = Describe("managedJob create command", func() {
  }
  fakeJobResp.Header.Add("Content-Type", "json")
 
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
@@ -209,6 +218,7 @@ var _ = Describe("managedJob create command", func() {
  }
  fakeJobResp.Header.Add("Content-Type", "json")
 
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
@@ -229,6 +239,7 @@ var _ = Describe("managedJob create command", func() {
  })
 
  It("should stream the log of the job if it is in running status", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
@@ -256,6 +267,7 @@ var _ = Describe("managedJob create command", func() {
  StatusCode: http.StatusOK,
  }
  fakeJobResp.Header.Add("Content-Type", "json")
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()

diff --git a/cmd/ocm-backplane/managedJob/deleteManagedJob_test.go b/cmd/ocm-backplane/managedJob/deleteManagedJob_test.go
@@ -12,6 +12,7 @@ import (
  "k8s.io/client-go/tools/clientcmd"
  "k8s.io/client-go/tools/clientcmd/api"
 
+ cmv1 "github.com/openshift-online/ocm-sdk-go/clustersmgmt/v1"
  "github.com/openshift/backplane-cli/pkg/backplaneapi"
  backplaneapiMock "github.com/openshift/backplane-cli/pkg/backplaneapi/mocks"
  "github.com/openshift/backplane-cli/pkg/client/mocks"
@@ -36,7 +37,8 @@ var _ = Describe("managedJob delete command", func() {
 
  fakeResp *http.Response
 
- sut *cobra.Command
+ sut *cobra.Command
+ ocmEnv *cmv1.Environment
  )
 
  BeforeEach(func() {
@@ -67,6 +69,7 @@ var _ = Describe("managedJob delete command", func() {
  _ = clientcmd.ModifyConfig(clientcmd.NewDefaultPathOptions(), api.Config{}, true)
 
  os.Setenv(info.BackplaneURLEnvName, proxyURI)
+ ocmEnv, _ = cmv1.NewEnvironment().BackplaneURL("https://dummy.api").Build()
  })
 
  AfterEach(func() {
@@ -76,6 +79,7 @@ var _ = Describe("managedJob delete command", func() {
 
  Context("delete managed job", func() {
  It("when running with a simple case should work as expected", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  // It should query for the internal cluster id first
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  // Then it will look for the backplane shard
@@ -92,6 +96,7 @@ var _ = Describe("managedJob delete command", func() {
  })
 
  It("should respect url flag", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  // Then it will look for the backplane shard
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
@@ -106,6 +111,7 @@ var _ = Describe("managedJob delete command", func() {
  })
 
  It("should fail when backplane did not return a 200", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()
@@ -119,6 +125,7 @@ var _ = Describe("managedJob delete command", func() {
  })
 
  It("should not work when backplane returns a non parsable response with 200 return", func() {
+ mockOcmInterface.EXPECT().GetOCMEnvironment().Return(ocmEnv, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetTargetCluster(testClusterID).Return(trueClusterID, testClusterID, nil)
  mockOcmInterface.EXPECT().IsClusterHibernating(gomock.Eq(trueClusterID)).Return(false, nil).AnyTimes()
  mockOcmInterface.EXPECT().GetOCMAccessToken().Return(&testToken, nil).AnyTimes()