Skip to content

Commit 74ea23b

Browse files
committed
test(resources): update generic resources tests to use testify and improve readability
Signed-off-by: Marc Nuri <[email protected]>
1 parent 44053f1 commit 74ea23b

File tree

2 files changed

+383
-563
lines changed

2 files changed

+383
-563
lines changed

pkg/mcp/common_test.go

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -449,3 +449,21 @@ func (s *BaseMcpSuite) InitMcpClient() {
449449
s.Require().NoError(err, "Expected no error creating MCP server")
450450
s.McpClient = test.NewMcpClient(s.T(), s.mcpServer.ServeHTTP(nil))
451451
}
452+
453+
// CrdWaitUntilReady waits for a CRD to be established
454+
func (s *BaseMcpSuite) CrdWaitUntilReady(name string) {
455+
apiExtensionClient := apiextensionsv1.NewForConfigOrDie(envTestRestConfig)
456+
watcher, err := apiExtensionClient.CustomResourceDefinitions().Watch(s.T().Context(), metav1.ListOptions{
457+
FieldSelector: "metadata.name=" + name,
458+
})
459+
s.Require().NoError(err, "failed to watch CRD")
460+
_, err = toolswatch.UntilWithoutRetry(s.T().Context(), watcher, func(event watch.Event) (bool, error) {
461+
for _, c := range event.Object.(*apiextensionsv1spec.CustomResourceDefinition).Status.Conditions {
462+
if c.Type == apiextensionsv1spec.Established && c.Status == apiextensionsv1spec.ConditionTrue {
463+
return true, nil
464+
}
465+
}
466+
return false, nil
467+
})
468+
s.Require().NoError(err, "failed to wait for CRD")
469+
}

0 commit comments

Comments
 (0)