Function TestExportJson

worker/export_test.go:329–383

(t *testing.T)

}

func TestExportJson(t *testing.T) {
	// Index the name predicate. We ensure it doesn't show up on export.
	initTestExport(t, `name: string @index(exact) .
				 [0x2] name: string @index(exact) .`)

	bdir := t.TempDir()
	time.Sleep(1 * time.Second)

	// We have 4 friend type edges. FP("friends")%10 = 2.
	x.WorkerConfig.ExportPath = bdir
	readTs := timestamp()
	// Do the following so export won't block forever for readTs.
	posting.Oracle().ProcessDelta(&pb.OracleDelta{MaxAssigned: readTs})
	req := pb.ExportRequest{ReadTs: readTs, GroupId: 1, Format: "json", Namespace: math.MaxUint64}
	files, err := export(context.Background(), &req)
	require.NoError(t, err)

	fileList, schemaFileList, gqlSchema := getExportFileList(t, bdir)
	require.Equal(t, len(files), len(fileList)+len(schemaFileList)+len(gqlSchema))

	file := fileList[0]
	f, err := os.Open(file)
	require.NoError(t, err)

	r, err := gzip.NewReader(f)
	require.NoError(t, err)

	wantJson := `
	[
		{"uid":"0x1","namespace":"0x0","name":"pho\ton"},
		{"uid":"0x2","namespace":"0x0","name@en":"pho\ton"},
		{"uid":"0x3","namespace":"0x0","name":"First Line\nSecondLine"},
		{"uid":"0x5","namespace":"0x0","name":""},
		{"uid":"0x6","namespace":"0x0","name":"Ding!\u0007Ding!\u0007Ding!\u0007"},
		{"uid":"0x1","namespace":"0x0","friend":[{"uid":"0x5"}]},
		{"uid":"0x2","namespace":"0x0","friend":[{"uid":"0x5"}]},
		{"uid":"0x3","namespace":"0x0","friend":[{"uid":"0x5"}]},
		{"uid":"0x4","namespace":"0x0","friend":[{"uid":"0x5","friend|age":33,
			"friend|close":"true","friend|game":"football",
			"friend|poem":"roses are red\nviolets are blue","friend|since":"2005-05-02T15:04:05Z"}]},
		{"uid":"0x9","namespace":"0x2","name":"ns2"}
	]
	`
	gotJson, err := io.ReadAll(r)
	require.NoError(t, err)
	var expected interface{}
	require.NoError(t, json.Unmarshal([]byte(wantJson), &expected))

	var actual interface{}
	require.NoError(t, json.Unmarshal(gotJson, &actual))
	require.ElementsMatch(t, expected, actual)

	checkExportSchema(t, schemaFileList)
	checkExportGqlSchema(t, gqlSchema)
}

const exportRequest = `mutation export($format: String!) {
	export(input: {format: $format}) {