Function TestReadSnapshotFile

internal/applicationsnapshot/input_test.go:190–327

(t *testing.T)

}

func TestReadSnapshotFile(t *testing.T) {
	t.Run("Successful file read and unmarshal", func(t *testing.T) {
		snapshotSpec := app.SnapshotSpec{
			Components: []app.SnapshotComponent{
				{
					Name:           "Named",
					ContainerImage: "",
				},
				{
					Name:           "Set name",
					ContainerImage: "registry.io/repository/image:another",
				},
			},
		}
		fs := afero.NewMemMapFs()
		spec := `{"components":[{"name": "Named", "containerImage":""},{"name": "Set name", "containerImage":"registry.io/repository/image:another"}]}`

		err := afero.WriteFile(fs, "/correct.json", []byte(spec), 0o644)
		if err != nil {
			t.Fatalf("Setup failure: could not write file: %v", err)
		}

		content, err := afero.ReadFile(fs, "/correct.json")
		assert.NoError(t, err)
		got, err := readSnapshotSource(content)
		assert.Equal(t, snapshotSpec, got)
		assert.NoError(t, err)
	})

	t.Run("Invalid Spec", func(t *testing.T) {
		fs := afero.NewMemMapFs()
		spec := `bad spec`
		specFile := "/badSpec.json"

		err := afero.WriteFile(fs, specFile, []byte(spec), 0o644)
		if err != nil {
			t.Fatalf("Setup failure: could not write file: %v", err)
		}

		content, err := afero.ReadFile(fs, specFile)
		assert.NoError(t, err)
		_, err = readSnapshotSource(content)
		wrapped := errors.New("error unmarshaling JSON: while decoding JSON: json: cannot unmarshal string into Go value of type v1alpha1.SnapshotSpec")
		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