feat(stoneintg-1165): resolve pipelineruns from scenario

Support referencing pipelineruns from integrationtestscenario resolver
field.  Uses  Tekton's ResolutionRequest CR to grab remote data then
creates PipelineRun in the cluster

Signed-off-by: Ryan Cole <[email protected]>

Author: 14rcole

internal/controller/snapshot/snapshot_adapter.go

@@ -762,8 +762,12 @@ func (a *Adapter) createIntegrationPipelineRun(application *applicationapiv1alph
 	a.logger.Info("Creating new pipelinerun for integrationTestscenario",
 		"integrationTestScenario.Name", integrationTestScenario.Name)
 
-	pipelineRunBuilder := tekton.NewIntegrationPipelineRun(integrationTestScenario.Name, application.Namespace, *integrationTestScenario).
-		WithSnapshot(snapshot).
+	pipelineRunBuilder, err := tekton.NewIntegrationPipelineRun(a.client, integrationTestScenario.Name, application.Namespace, *integrationTestScenario)
+	if err != nil {
+		return nil, err
+	}
+
+	pipelineRunBuilder = pipelineRunBuilder.WithSnapshot(snapshot).
 		WithIntegrationLabels(integrationTestScenario).
 		WithIntegrationAnnotations(integrationTestScenario).
 		WithApplication(a.application).

tekton/integration_pipeline.go

@@ -103,7 +103,7 @@ func (r *IntegrationPipelineRun) AsPipelineRun() *tektonv1.PipelineRun {
 
 // NewIntegrationPipelineRun creates an empty PipelineRun in the given namespace. The name will be autogenerated,
 // using the prefix passed as an argument to the function.
-func NewIntegrationPipelineRun(prefix, namespace string, integrationTestScenario v1beta2.IntegrationTestScenario) *IntegrationPipelineRun {
+func NewIntegrationPipelineRun(client client.Client, ctx context.Context, prefix, namespace string, integrationTestScenario v1beta2.IntegrationTestScenario) (*IntegrationPipelineRun, err) {
 	resolverParams := []tektonv1.Param{}
 
 	for _, scenarioParam := range integrationTestScenario.Spec.ResolverRef.Params {
@@ -117,6 +117,19 @@ func NewIntegrationPipelineRun(prefix, namespace string, integrationTestScenario
 		resolverParams = append(resolverParams, resolverParam)
 	}
 
+	resolver := tektonv1.ResolverName(integrationTestScenario.Spec.ResolverRef.Resolver)
+	if integrationTestScenario.Spec.ResolverType == "pipeline" {
+		return generateIntegrationPipelineRunFromPipelineResolver(prefix, namespace, resolver, resolverParams), nil
+	} else if integrationTestScenario.Spec.ResolverType == "pipelinerun" {
+		base64plr, err := getPipelineRunYamlFromPipelineRunResolver(clilent, ctx, prefix, namespace, resolver, resolverParams)
+		if err != nil {
+			return nil, err
+		}
+		return generateIntegrationPipelineRunFromBase64(base64plr)
+	}
+}
+
+func generateIntegrationPipelineRunFromPipelineResolver(prefix, namespace, resolver string, resolverParams []tektonv1.Param) *IntegrationPipelineRun {
 	pipelineRun := tektonv1.PipelineRun{
 		ObjectMeta: metav1.ObjectMeta{
 			GenerateName: prefix + "-",
@@ -125,15 +138,87 @@ func NewIntegrationPipelineRun(prefix, namespace string, integrationTestScenario
 		Spec: tektonv1.PipelineRunSpec{
 			PipelineRef: &tektonv1.PipelineRef{
 				ResolverRef: tektonv1.ResolverRef{
-					Resolver: tektonv1.ResolverName(integrationTestScenario.Spec.ResolverRef.Resolver),
+					Resolver: resolver,
 					Params:   resolverParams,
 				},
 			},
 		},
 	}
+
 	return &IntegrationPipelineRun{pipelineRun}
 }
 
+func getPipelineRunYamlFromPipelineRunResolver(client client.Client, ctx context.Context, prefix, namespace, resolver string, resolverParams []tektonv1.Param) (*IntegrationPipelineRun, error) {
+	request = tektonv1.ResolutionRequest{
+		ObjectMeta: metav1.ObjectMeta{
+			GenerateName: prefix + "-",
+			Namespace:    namespace,
+		},
+		Labels: map[string]string{
+			"resolution.tekton.dev/type": resolver,
+		},
+		Annotations: map[string]string{
+			"konflux-ci.dev/created-by": "integration-service", // for backup garbage collection
+		},
+		Spec: tektonv1.ResolverRequestSpec{
+			Params: resolverParams,
+		},
+	}
+
+	err := retry.OnError(retry.DefaultBackoff, client.Create(ctx, request))
+	if err != nil {
+		return "", err
+	}
+	resolutionRequestName := request.ObjectMeta.Name
+	defer func() {
+		_ = retry.OnError(retry.DefaultBackoff, client.Delete(ctx, request))
+	}()
+
+	resolverBackoff := wait.Backoff{
+		Steps:    60,
+		Duration: 1 * time.Second,
+		Factor:   1.0,
+		Jitter:   0.5,
+	}
+	var resolvedRequest tektonv1.ResolutionRequest
+	err = retry.OnError(resolverBackoff, func() {
+		namespace := "foo"
+		name := "bar"
+		err = client.Get(ctx, types.NamespacedName{Namespace: resolutionRequestName, Name: name}, &resolvedRequest)
+		if err != nil {
+			return err
+		}
+		for _, cond := range resolvedRequest.Status.Conditions {
+			if strings.EqualFold(cond.Type, "succeeded") {
+				if cond.Status == metav1.ConditionTrue {
+					// request resolved successfully, we can terminate retry block
+					return nil
+				}
+			}
+		}
+		return fmt.Errorf("Resolution for '%s' in namespace '%s' did not complete", namespace, name)
+	})
+
+	if err != nil {
+		return "", err
+	}
+	return resolvedRequest.Status.Data, nil
+}
+
+func generateIntegrationPipelineRunFromBase64(base64plr string) (*IntegrationPipelineRun, error) {
+	plrYaml, err := base64.StdEncoding.DecodeString(base64plr)
+	if err != nil {
+		return err
+	}
+	// TODO: Make sure this is sufficient to verify that kind is pipelineRun
+	var pipelineRun tektonv1.PipelineRun
+	err = yaml.Unmarshal(plrYaml, &pipelineRun)
+	if err != nil {
+		return err
+	}
+	return &IntegrationPipelineRun{pipelineRun}, nil
+}
+
 // Updates git resolver values parameters with values of params specified in the input map
 // updates only exsitings parameters, doens't create new ones
 func (iplr *IntegrationPipelineRun) WithUpdatedTestsGitResolver(params map[string]string) *IntegrationPipelineRun {