Add e2e test for GitlabMergeRequestValidationErrors

Signed-off-by: Shubham Bhardwaj <[email protected]>

Author: infernus01

test/gitlab_merge_request_test.go

@@ -690,6 +690,135 @@ func TestGitlabMergeRequestOnUpdateAtAndLabelChange(t *testing.T) {
 	}
 }
 
+func TestGitlabMergeRequestValidationErrorsFromFork(t *testing.T) {
+	targetNS := names.SimpleNameGenerator.RestrictLengthWithRandomSuffix("pac-e2e-ns")
+	ctx := context.Background()
+	runcnx, opts, glprovider, err := tgitlab.Setup(ctx)
+	assert.NilError(t, err)
+	ctx, err = cctx.GetControllerCtxInfo(ctx, runcnx)
+	assert.NilError(t, err)
+	runcnx.Clients.Log.Info("Testing GitLab validation error commenting from fork scenario")
+
+	// Get the original project onboarded to PaC
+	originalProject, resp, err := glprovider.Client().Projects.GetProject(opts.ProjectID, nil)
+	assert.NilError(t, err)
+	if resp != nil && resp.StatusCode == http.StatusNotFound {
+		t.Errorf("Repository %d not found", opts.ProjectID)
+	}
+
+	err = tgitlab.CreateCRD(ctx, originalProject, runcnx, opts, targetNS, nil)
+	assert.NilError(t, err)
+
+	// Create a fork of the original project
+	forkName := names.SimpleNameGenerator.RestrictLengthWithRandomSuffix("pac-fork-test")
+	forkProject, _, err := glprovider.Client().Projects.ForkProject(opts.ProjectID, &clientGitlab.ForkProjectOptions{
+		Name: &forkName,
+		Path: &forkName,
+	})
+	assert.NilError(t, err)
+	runcnx.Clients.Log.Infof("Created fork project: %s (ID: %d) from original: %s (ID: %d)",
+		forkProject.PathWithNamespace, forkProject.ID, originalProject.PathWithNamespace, originalProject.ID)
+
+	// Wait sometime for fork to be fully ready
+	time.Sleep(3 * time.Second)
+
+	// Cleanup fork when test finishes
+	defer func() {
+		runcnx.Clients.Log.Infof("Cleaning up fork project: %d", forkProject.ID)
+		_, err := glprovider.Client().Projects.DeleteProject(forkProject.ID, nil)
+		if err != nil {
+			runcnx.Clients.Log.Warnf("Failed to delete fork project: %v", err)
+		}
+	}()
+
+	// Commit invalid .tekton files to the fork
+	entries, err := payload.GetEntries(map[string]string{
+		".tekton/bad-yaml.yaml": "testdata/failures/bad-yaml.yaml",
+	}, targetNS, forkProject.DefaultBranch,
+		triggertype.PullRequest.String(), map[string]string{})
+	assert.NilError(t, err)
+
+	targetRefName := names.SimpleNameGenerator.RestrictLengthWithRandomSuffix("pac-e2e-fork-test")
+	forkCloneURL, err := scm.MakeGitCloneURL(forkProject.WebURL, opts.UserName, opts.Password)
+	assert.NilError(t, err)
+
+	commitTitle := "Add invalid .tekton file from fork - " + targetRefName
+	scmOpts := &scm.Opts{
+		GitURL:        forkCloneURL,
+		CommitTitle:   commitTitle,
+		Log:           runcnx.Clients.Log,
+		WebURL:        forkProject.WebURL,
+		TargetRefName: targetRefName,
+		BaseRefName:   originalProject.DefaultBranch,
+	}
+	_ = scm.PushFilesToRefGit(t, scmOpts, entries)
+	runcnx.Clients.Log.Infof("Pushed invalid .tekton files to fork branch: %s", targetRefName)
+
+	// Create merge request from fork to original project
+	mrTitle := "TestValidationErrorsFromFork - " + targetRefName
+	mrOptions := &clientGitlab.CreateMergeRequestOptions{
+		Title:        &mrTitle,
+		SourceBranch: &targetRefName,
+		TargetBranch: &originalProject.DefaultBranch,
+		// Create MR on the target project (original), not the source (fork)
+		TargetProjectID: &originalProject.ID,
+	}
+
+	mr, _, err := glprovider.Client().MergeRequests.CreateMergeRequest(forkProject.ID, mrOptions)
+	assert.NilError(t, err)
+	runcnx.Clients.Log.Infof("Created merge request from fork to original: %s/-/merge_requests/%d",
+		originalProject.WebURL, mr.IID)
+
+	defer func() {
+		// Close the MR and clean up branch
+		runcnx.Clients.Log.Infof("Closing MR %d", mr.IID)
+		_, _, err := glprovider.Client().MergeRequests.UpdateMergeRequest(originalProject.ID, mr.IID,
+			&clientGitlab.UpdateMergeRequestOptions{StateEvent: clientGitlab.Ptr("close")})
+		if err != nil {
+			runcnx.Clients.Log.Warnf("Failed to close MR: %v", err)
+		}
+
+		runcnx.Clients.Log.Infof("Deleting branch %s from fork", targetRefName)
+		_, err = glprovider.Client().Branches.DeleteBranch(forkProject.ID, targetRefName)
+		if err != nil {
+			runcnx.Clients.Log.Warnf("Failed to delete branch: %v", err)
+		}
+	}()
+
+	runcnx.Clients.Log.Info("Waiting for webhook validation to process MR and post validation comment...")
+
+	maxLoop := 12 // Wait up to 72 seconds for webhook processing
+	foundValidationComment := false
+
+	for i := 0; i < maxLoop; i++ {
+		notes, _, err := glprovider.Client().Notes.ListMergeRequestNotes(originalProject.ID, mr.IID, nil)
+		assert.NilError(t, err)
+
+		for _, note := range notes {
+			// Look for the validation error comment that PaC should post via webhook
+			if regexp.MustCompile(`.*There are some errors in your PipelineRun template.*`).MatchString(note.Body) &&
+				regexp.MustCompile(`.*bad-yaml\.yaml.*yaml validation error.*`).MatchString(note.Body) {
+				runcnx.Clients.Log.Info("SUCCESS: Found validation error comment on original project's MR!")
+				runcnx.Clients.Log.Info("This proves the TargetProjectID fix works in the full webhook validation flow!")
+				foundValidationComment = true
+
+				// Verify the comment format matches PaC's validation error format
+				assert.Assert(t, regexp.MustCompile(`\[!CAUTION\]`).MatchString(note.Body), "Comment should contain caution header")
+				break
+			}
+		}
+
+		if foundValidationComment {
+			break
+		}
+
+		runcnx.Clients.Log.Infof("Loop %d/%d: Waiting for webhook validation to post comment (testing TargetProjectID fix)", i+1, maxLoop)
+		time.Sleep(6 * time.Second)
+	}
+
+	assert.Assert(t, foundValidationComment, "Validation error comment should appear on original project's MR. ")
+}
+
 // Local Variables:
 // compile-command: "go test -tags=e2e -v -run ^TestGitlabMergeRequest$"
 // End: