perf/go/ingest/format/format_test.go

package format

import (
	"bytes"
	"strings"
	"testing"

	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
	"go.skia.org/infra/go/deepequal/assertdeep"
)

func TestParse_InvalidJSON(t *testing.T) {
	_, err := Parse(bytes.NewReader([]byte("{")))
	assert.Error(t, err)
}

func TestParse_GoodVersion(t *testing.T) {
	_, err := Parse(bytes.NewReader([]byte("{\"version\":1}")))
	assert.NoError(t, err)
}

func TestParse_BadVersion(t *testing.T) {
	_, err := Parse(bytes.NewReader([]byte("{\"version\":2}")))
	assert.Error(t, err)
}

func TestParse_BadVersionNotNumber(t *testing.T) {
	_, err := Parse(bytes.NewReader([]byte("{\"version\":\"1\"}")))
	assert.Error(t, err)
}

func TestValidate_EmptyObject_ReturnsError(t *testing.T) {
	r := strings.NewReader("{}")
	_, err := Validate(r)
	require.Error(t, err)
}

func TestValidate_VersionOnlyIsCorrect_ReturnsError(t *testing.T) {
	r := strings.NewReader(`{"version" : 1}`)
	schemaViolations, err := Validate(r)
	require.Error(t, err)
	require.NotEmpty(t, schemaViolations)
}

func TestValidate_MinimumValidVersion_Success(t *testing.T) {
	r := strings.NewReader(`{
		"version" : 1,
		"git_hash": "1234567890",
		"results" : []
		}`)
	schemaViolations, err := Validate(r)
	require.NoError(t, err)
	require.Empty(t, schemaViolations)
}

func TestValidate_ExampleWithData_Success(t *testing.T) {
	r := strings.NewReader(`{
		"version": 1,
		"git_hash": "cd5...663",
		"key": {
			"config": "8888",
			"arch": "x86"
		},
		"results": [
			{
				"key": {
					"test": "some_test_name"
				},
				"measurements": {
					"ms": [
						{
							"value": "min",
							"measurement": 1.2
						},
						{
							"value": "max",
							"measurement": 2.4
						},
						{
							"value": "median",
							"measurement": 1.5
						}
					]
				}
			}
		]
	}`)
	schemaViolations, err := Validate(r)
	require.NoError(t, err)
	require.Empty(t, schemaViolations)
}

func TestLinks_ExampleWithDataMeasurementLinks_Success(t *testing.T) {
	r := strings.NewReader(`{
		"version": 1,
		"git_hash": "cd5...663",
		"key": {
			"config": "8888",
			"arch": "x86"
		},
		"results": [
			{
				"key": {
					"test": "some=test$name"
				},
				"measurements": {
					"ms": [
						{
							"value": "min",
							"measurement": 1.2,
							"links": {
								"l1": "http://myfirstlink"
							}
						},
						{
							"value": "max",
							"measurement": 2.4
						},
						{
							"value": "median",
							"measurement": 1.5
						}
					]
				}
			}
		],
		"links": {
			"l2": "http://mygloballink"
		}
	}`)
	f, err := Parse(r)
	require.NoError(t, err)
	links := f.GetLinksForMeasurement(",config=8888,arch=x86,test=some_test_name,ms=min,")
	require.NotNil(t, links)
	expectedLinks := map[string]string{
		"l1": "http://myfirstlink",
		"l2": "http://mygloballink",
	}
	assertdeep.Equal(t, expectedLinks, links)

	links = f.GetLinksForMeasurement(",config=8888,arch=x86,test=some_test_name,ms=max,")
	require.NotNil(t, links)
	expectedLinks = map[string]string{
		"l2": "http://mygloballink",
	}
	assertdeep.Equal(t, expectedLinks, links)
}