Function TestExecHook_WaitOptionsPassedDownstream

pkg/action/hooks_test.go:448–494

(t *testing.T)

}

func TestExecHook_WaitOptionsPassedDownstream(t *testing.T) {
	is := assert.New(t)

	failer := &kubefake.FailingKubeClient{
		PrintingKubeClient: kubefake.PrintingKubeClient{Out: io.Discard},
	}

	configuration := &Configuration{
		Releases:     storage.Init(driver.NewMemory()),
		KubeClient:   failer,
		Capabilities: common.DefaultCapabilities,
	}

	rel := &release.Release{
		Name:      "test-release",
		Namespace: "test",
		Hooks: []*release.Hook{
			{
				Name: "test-hook",
				Kind: "ConfigMap",
				Path: "templates/hook.yaml",
				Manifest: `apiVersion: v1
kind: ConfigMap
metadata:
  name: test-hook
  namespace: test
data:
  foo: bar
`,
				Weight: 0,
				Events: []release.HookEvent{
					release.HookPreInstall,
				},
			},
		},
	}

	// Use WithWaitContext as a marker WaitOption that we can track
	ctx := context.Background()
	waitOptions := []kube.WaitOption{kube.WithWaitContext(ctx)}

	err := configuration.execHook(rel, release.HookPreInstall, kube.StatusWatcherStrategy, waitOptions, 600, false)
	is.NoError(err)

	// Verify that WaitOptions were passed to GetWaiter
	is.NotEmpty(failer.RecordedWaitOptions, "WaitOptions should be passed to GetWaiter")
}