}
			output, _ = istioCtl.InvokeOrFail(t, args)
			jsonOutput := jsonUnmarshallOrFail(t, strings.Join(args, " "), output)
			g.Expect(jsonOutput).To(HaveKey("bootstrap"))

			args = []string{
				"--namespace=dummy",
				"pc", "cluster", fmt.Sprintf("%s.%s", podID, apps.Namespace.Name()), "-o", "json",
			}
			output, _ = istioCtl.InvokeOrFail(t, args)

	// Invoke invokes an istioctl command and returns the output and exception.
	// stdout and stderr will be returned as different strings
	Invoke(args []string) (string, string, error)

	// InvokeOrFail calls Invoke and fails tests if it returns en err
	InvokeOrFail(t test.Failer, args []string) (string, string)
}

// Config is structured config for the istioctl component
type Config struct {
	// Cluster to be used in a multicluster environment

				"--set", "tag=" + s.Image.Tag,
				"--set", "values.global.variant=" + s.Image.Variant,
				"--manifests=" + ManifestPath,
				"-y",
			}
			istioCtl.InvokeOrFail(t, installCmd)

			verifyCmd := []string{
				"verify-install",
			}
			out, _ := istioCtl.InvokeOrFail(t, verifyCmd)
			if !strings.Contains(out, "verified successfully") {
				t.Fatalf("verify-install failed: %v", out)
			}
		})

				},
			})

			istioctl.NewOrFail(t, t, istioctl.Config{}).InvokeOrFail(t, []string{
				"waypoint",
				"apply",
				"--namespace",
				nsConfig.Name(),
				"--wait",
			})

			nameSet := []string{"", "w1", "w2"}
			for _, name := range nameSet {
				istioctl.NewOrFail(t, t, istioctl.Config{}).InvokeOrFail(t, []string{
					"waypoint",
					"apply",
					"--namespace",
					nsConfig.Name(),

			// Uninstall with a different file (should have no effect)
			istioCtl.InvokeOrFail(t, []string{"uninstall", "-f", randomFileName, "-r" + canaryRevision, "--skip-confirmation"})

			// Check the webhook still exists
			validateWebhookExistence()

			// Uninstall with the correct file
			istioCtl.InvokeOrFail(t, []string{"uninstall", "-f=" + customFileName, "-r=" + canaryRevision, "--skip-confirmation"})

	if err.String() != "" {
		scopes.Framework.Infof("istioctl error: %v", strings.TrimSpace(err.String()))
	}
	return out.String(), err.String(), fErr
}

// InvokeOrFail implements Instance
func (c *kubeComponent) InvokeOrFail(t test.Failer, args []string) (string, string) {
	output, stderr, err := c.Invoke(args)
	if err != nil {
		t.Logf("Unwanted exception for 'istioctl %s': %v", strings.Join(args, " "), err)

			istioCtl.InvokeOrFail(t, initCmd)
			t.TrackResource(&operatorDumper{rev: "v2"})

			initCmd = []string{
				"operator", "init",
				"--hub=" + s.Image.Hub,
				"--tag=" + tag,
				"--manifests=" + ManifestPath,
				"--revision=" + "v3",
			}
			// install third operator deployment with different revision
			istioCtl.InvokeOrFail(t, initCmd)

			})
			assert.Error(t, err)

			// Here we should have two activated webhooks, but dry-run should not report any error, which
			// means the re-installation can be done successfully.
			output, outErr := istioCtl.InvokeOrFail(t, []string{"install", "--dry-run"})
			if !strings.Contains(output, "Made this installation the default for cluster-wide operations.") {
				t.Errorf("install expects to succeed but didn't")
			}

					"--hub=" + s.Image.Hub,
					"--tag=" + tag,
					"--manifests=" + ManifestPath,
				}
				// install istio with default config for the first time by running operator init command
				istioCtl.InvokeOrFail(t, initCmd)
				t.TrackResource(&operatorDumper{rev: ""})

				if _, err := cs.Kube().CoreV1().Namespaces().Create(context.TODO(), &corev1.Namespace{
					ObjectMeta: metav1.ObjectMeta{
						Name: IstioNamespace,

}

func verifyRevision(t framework.TestContext, i istioctl.Instance, podName, podNamespace, revision string) {
	t.Helper()
	pcArgs := []string{"pc", "bootstrap", podName, "-n", podNamespace}
	bootstrapConfig, _ := i.InvokeOrFail(t, pcArgs)
	expected := fmt.Sprintf("\"discoveryAddress\": \"istiod-%s.istio-system.svc:15012\"", revision)
	if !strings.Contains(bootstrapConfig, expected) {