fix(api): use right ref (#7495)

Author: sguiheux

engine/api/purge/purge_v2_test.go

@@ -91,14 +91,16 @@ func TestApplyRunRetentionOnProject_WorkflowWithRetention(t *testing.T) {
 		Initiator: &sdk.V2Initiator{
 			UserID: lambdauser.ID,
 		},
-		RunNumber:   0,
-		WorkflowRef: "",
+		RunNumber: 0,
+		Contexts: sdk.WorkflowRunContext{
+			Git: sdk.GitContext{Ref: ""},
+		},
 	}
 	// Create run on master - We must keep only run_number 19 and 20
 	for i := 0; i < 20; i++ {
 		wr.RunNumber = int64(runNumber)
 		runNumber++
-		wr.WorkflowRef = "refs/heads/master"
+		wr.Contexts.Git.Ref = "refs/heads/master"
 
 		require.NoError(t, workflow_v2.InsertRun(ctx, db, &wr))
 
@@ -113,15 +115,15 @@ func TestApplyRunRetentionOnProject_WorkflowWithRetention(t *testing.T) {
 	for i := 0; i < 20; i++ {
 		wr.RunNumber = int64(runNumber)
 		runNumber++
-		wr.WorkflowRef = "refs/heads/dev/my/feat"
+		wr.Contexts.Git.Ref = "refs/heads/dev/my/feat"
 		require.NoError(t, workflow_v2.InsertRun(ctx, db, &wr))
 	}
 
 	// Create run on fix branch. We must keep ony run_number 60
 	for i := 0; i < 20; i++ {
 		wr.RunNumber = int64(runNumber)
 		runNumber++
-		wr.WorkflowRef = "refs/heads/fix"
+		wr.Contexts.Git.Ref = "refs/heads/fix"
 		require.NoError(t, workflow_v2.InsertRun(ctx, db, &wr))
 	}
 
@@ -201,14 +203,18 @@ func TestApplyRunRetentionOnProject_FallbackProjectDefaultRule(t *testing.T) {
 		Initiator: &sdk.V2Initiator{
 			UserID: lambdauser.ID,
 		},
-		RunNumber:   0,
-		WorkflowRef: "",
+		RunNumber: 0,
+		Contexts: sdk.WorkflowRunContext{
+			Git: sdk.GitContext{
+				Ref: "",
+			},
+		},
 	}
 	// Create run on master - We must keep only run_number 19 and 20
 	for i := 0; i < 20; i++ {
 		wr.RunNumber = int64(runNumber)
 		runNumber++
-		wr.WorkflowRef = "refs/heads/master"
+		wr.Contexts.Git.Ref = "refs/heads/master"
 		require.NoError(t, workflow_v2.InsertRun(ctx, db, &wr))
 
 	}

engine/api/workflow_v2/dao_run.go

@@ -254,7 +254,7 @@ func LoadRunsWorkflowRefsByWorkflow(ctx context.Context, db gorp.SqlExecutor, pr
 	_, next := telemetry.Span(ctx, "LoadRunsWorkflowRefsByWorkflow")
 	defer next()
 	if _, err := db.Select(&refs, `
-		SELECT DISTINCT workflow_ref
+		SELECT DISTINCT contexts -> 'git' ->> 'ref'::TEXT
 		FROM v2_workflow_run
 		WHERE project_key = $1 AND vcs_server = $2 AND repository = $3 AND workflow_name = $4
 	`, projKey, vcs, repository, workflow); err != nil {
@@ -655,7 +655,7 @@ func LoadRunsDescAtOffset(ctx context.Context, db gorp.SqlExecutor, projKey, vcs
 	vcs_server = $2 AND
 	repository = $3 AND
 	workflow_name = $4 AND
-	workflow_ref = $5
+	contexts -> 'git' ->> 'ref'::TEXT = $5
 	ORDER BY run_number DESC
 	OFFSET $6`
 
@@ -673,7 +673,7 @@ func LoadOlderRuns(ctx context.Context, db gorp.SqlExecutor, projKey, vcs, repo,
 	vcs_server = $2 AND
 	repository = $3 AND
 	workflow_name = $4 AND
-	workflow_ref = $5 AND
+	contexts -> 'git' ->> 'ref'::TEXT = $5 AND
 	now() - started > $6 * INTERVAL '1' DAY`
 
 	var ids []string