[K8s Plugin] Implement duplicateManifests (pipe-cd#5863)

* Add DeepCopyWithName to Manifest

Signed-off-by: Shinnosuke Sawada-Dazai <shin@warashi.dev>

* Add duplicateManifests to deployment package

Signed-off-by: Shinnosuke Sawada-Dazai <shin@warashi.dev>

---------

Signed-off-by: Shinnosuke Sawada-Dazai <shin@warashi.dev>

Author: Warashi

pkg/app/pipedv1/plugin/kubernetes/deployment/misc.go

@@ -118,3 +118,12 @@ func addVariantLabelsAndAnnotations(m []provider.Manifest, variantLabel, variant
 		})
 	}
 }
+
+// duplicateManifests duplicates the given manifests and appends a name suffix to each manifest.
+func duplicateManifests(manifests []provider.Manifest, nameSuffix string) []provider.Manifest {
+	copied := make([]provider.Manifest, len(manifests))
+	for i, m := range manifests {
+		copied[i] = m.DeepCopyWithName(makeSuffixedName(m.Name(), nameSuffix))
+	}
+	return copied
+}

pkg/app/pipedv1/plugin/kubernetes/deployment/misc_test.go

@@ -351,3 +351,45 @@ metadata:
 		})
 	}
 }
+
+func TestDuplicateManifests(t *testing.T) {
+	yaml := `
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: test-config
+  labels:
+    foo: bar
+---
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: another-config
+  labels:
+    bar: baz
+`
+	manifests := mustParseManifests(t, yaml)
+	require.Len(t, manifests, 2)
+
+	nameSuffix := "canary"
+	copied := duplicateManifests(manifests, nameSuffix)
+	require.Len(t, copied, 2)
+
+	// Check that names are suffixed and originals are unchanged
+	assert.Equal(t, "test-config", manifests[0].Name())
+	assert.Equal(t, "another-config", manifests[1].Name())
+	assert.Equal(t, "test-config-canary", copied[0].Name())
+	assert.Equal(t, "another-config-canary", copied[1].Name())
+
+	// Mutate copied and ensure original is not affected
+	copied[0].AddLabels(map[string]string{"foo": "changed"})
+
+	var origCfg, copiedCfg corev1.ConfigMap
+	err := manifests[0].ConvertToStructuredObject(&origCfg)
+	require.NoError(t, err)
+	err = copied[0].ConvertToStructuredObject(&copiedCfg)
+	require.NoError(t, err)
+
+	assert.Equal(t, "bar", origCfg.Labels["foo"], "original label should remain unchanged")
+	assert.Equal(t, "changed", copiedCfg.Labels["foo"], "copied label should be updated")
+}

pkg/app/pipedv1/plugin/kubernetes/provider/manifest.go

@@ -80,6 +80,13 @@ func (m Manifest) DeepCopy() Manifest {
 	return Manifest{body: m.body.DeepCopy()}
 }
 
+// DeepCopyWithName returns a deep copy of the manifest with the given name.
+func (m Manifest) DeepCopyWithName(name string) Manifest {
+	copied := m.DeepCopy()
+	copied.body.SetName(name)
+	return copied
+}
+
 func (m Manifest) Key() ResourceKey {
 	return makeResourceKey(m.body)
 }

pkg/app/pipedv1/plugin/kubernetes/provider/manifest_test.go

@@ -1026,6 +1026,99 @@ metadata:
 	}
 }
 
+func TestManifest_DeepCopyWithName(t *testing.T) {
+	t.Parallel()
+
+	tests := []struct {
+		name      string
+		yaml      string
+		newName   string
+		mutate    func(orig, copy *Manifest)
+		checkOrig func(orig Manifest)
+		checkCopy func(copy Manifest)
+	}{
+		{
+			name: "deep copy with new name does not affect original",
+			yaml: `
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: original-name
+  labels:
+    foo: bar
+`,
+			newName: "copied-name",
+			mutate:  nil,
+			checkOrig: func(orig Manifest) {
+				assert.Equal(t, "original-name", orig.Name())
+			},
+			checkCopy: func(copy Manifest) {
+				assert.Equal(t, "copied-name", copy.Name())
+			},
+		},
+		{
+			name: "mutate copy does not affect original",
+			yaml: `
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: original-name
+  labels:
+    foo: bar
+`,
+			newName: "copied-name",
+			mutate: func(orig, copy *Manifest) {
+				copy.AddLabels(map[string]string{"foo": "baz"})
+			},
+			checkOrig: func(orig Manifest) {
+				assert.Equal(t, "bar", orig.body.GetLabels()["foo"], "original label should remain unchanged")
+			},
+			checkCopy: func(copy Manifest) {
+				assert.Equal(t, "baz", copy.body.GetLabels()["foo"], "copy label should be updated")
+			},
+		},
+		{
+			name: "mutate original does not affect copy",
+			yaml: `
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: original-name
+  labels:
+    foo: bar
+`,
+			newName: "copied-name",
+			mutate: func(orig, copy *Manifest) {
+				orig.AddLabels(map[string]string{"foo": "baz"})
+			},
+			checkOrig: func(orig Manifest) {
+				assert.Equal(t, "baz", orig.body.GetLabels()["foo"], "original label should be updated")
+			},
+			checkCopy: func(copy Manifest) {
+				assert.Equal(t, "bar", copy.body.GetLabels()["foo"], "copy label should remain unchanged")
+			},
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
+
+			manifests := mustParseManifests(t, tt.yaml)
+			require.Len(t, manifests, 1)
+			orig := manifests[0]
+			copy := orig.DeepCopyWithName(tt.newName)
+
+			if tt.mutate != nil {
+				tt.mutate(&orig, &copy)
+			}
+
+			tt.checkOrig(orig)
+			tt.checkCopy(copy)
+		})
+	}
+}
+
 func TestFromStructuredObject(t *testing.T) {
 	t.Parallel()