Extract .spec from cluster record format for snapshot input

* Modify readSnapshotSource to automatically extract the .spec field
when the input is a Kubernetes cluster record, matching the behavior
for policy.yaml files. This allows direct use of kubectl output
without manual jq extraction.

* The change maintains backward compatibility with direct SnapshotSpec
input and works with both JSON and YAML formats.

resolves: EC-1534

Author: dheerajodha

internal/applicationsnapshot/input.go

@@ -183,6 +183,28 @@ func DetermineInputSpec(ctx context.Context, input Input) (*app.SnapshotSpec, *E
 }
 
 func readSnapshotSource(input []byte) (app.SnapshotSpec, error) {
+	var v map[string]interface{}
+
+	// Since JSON is a subset of YAML, yaml.Unmarshal can be used directly.
+	if err := yaml.Unmarshal(input, &v); err != nil {
+		log.Debugf("Problem parsing application snapshot from file %s", input)
+		return app.SnapshotSpec{}, fmt.Errorf("unable to parse Snapshot specification from %s: %w", input, err)
+	}
+
+	// Extract the "spec" key from YAML, if present, to use as the snapshot.
+	if spec, ok := v["spec"]; ok {
+		v, ok = spec.(map[string]interface{})
+		if !ok {
+			return app.SnapshotSpec{}, fmt.Errorf("spec is not a valid map structure")
+		}
+		// Marshal the spec back to bytes for unmarshaling into SnapshotSpec
+		specBytes, err := yaml.Marshal(v)
+		if err != nil {
+			return app.SnapshotSpec{}, fmt.Errorf("unable to marshal spec: %w", err)
+		}
+		input = specBytes
+	}
+
 	var file app.SnapshotSpec
 	err := yaml.Unmarshal(input, &file)
 	if err != nil {

internal/applicationsnapshot/input_test.go

@@ -233,6 +233,98 @@ func TestReadSnapshotFile(t *testing.T) {
 		expected := fmt.Errorf("unable to parse Snapshot specification from %s: %w", spec, wrapped)
 		assert.Error(t, err, expected)
 	})
+
+	t.Run("Snapshot with .spec wrapper (cluster record format)", func(t *testing.T) {
+		snapshotSpec := app.SnapshotSpec{
+			Components: []app.SnapshotComponent{
+				{
+					Name:           "Named",
+					ContainerImage: "registry.io/repository/image:tag",
+				},
+			},
+		}
+		fs := afero.NewMemMapFs()
+		// Simulate a cluster record format with .spec wrapper
+		clusterRecord := `{
+			"apiVersion": "appstudio.redhat.com/v1alpha1",
+			"kind": "Snapshot",
+			"metadata": {
+				"name": "vsa-demo-app-x9xln",
+				"namespace": "user-ns2"
+			},
+			"spec": {
+				"components": [
+					{
+						"name": "Named",
+						"containerImage": "registry.io/repository/image:tag"
+					}
+				]
+			}
+		}`
+
+		err := afero.WriteFile(fs, "/cluster-record.json", []byte(clusterRecord), 0644)
+		if err != nil {
+			t.Fatalf("Setup failure: could not write file: %v", err)
+		}
+
+		content, err := afero.ReadFile(fs, "/cluster-record.json")
+		assert.NoError(t, err)
+		got, err := readSnapshotSource(content)
+		assert.NoError(t, err)
+		assert.Equal(t, snapshotSpec, got)
+	})
+
+	t.Run("Snapshot with .spec wrapper in YAML format", func(t *testing.T) {
+		snapshotSpec := app.SnapshotSpec{
+			Components: []app.SnapshotComponent{
+				{
+					Name:           "Named",
+					ContainerImage: "registry.io/repository/image:tag",
+				},
+			},
+		}
+		// Simulate a cluster record format with .spec wrapper in YAML
+		clusterRecord := `apiVersion: appstudio.redhat.com/v1alpha1
+kind: Snapshot
+metadata:
+  name: vsa-demo-app-x9xln
+  namespace: user-ns2
+spec:
+  components:
+    - name: Named
+      containerImage: registry.io/repository/image:tag
+`
+
+		content := []byte(clusterRecord)
+		got, err := readSnapshotSource(content)
+		assert.NoError(t, err)
+		assert.Equal(t, snapshotSpec, got)
+	})
+
+	t.Run("Snapshot without .spec wrapper (backward compatibility)", func(t *testing.T) {
+		snapshotSpec := app.SnapshotSpec{
+			Components: []app.SnapshotComponent{
+				{
+					Name:           "Named",
+					ContainerImage: "registry.io/repository/image:tag",
+				},
+			},
+		}
+		// Direct SnapshotSpec without wrapper (existing behavior)
+		directSpec := `{
+			"components": [
+				{
+					"name": "Named",
+					"containerImage": "registry.io/repository/image:tag"
+				}
+			]
+		}`
+
+		content := []byte(directSpec)
+		got, err := readSnapshotSource(content)
+		assert.NoError(t, err)
+		assert.Equal(t, snapshotSpec, got)
+	})
 }
 
 func TestExpandImageIndex(t *testing.T) {