| 183 | } |
| 184 | |
| 185 | func checkExportSchema(t *testing.T, schemaFileList []string) { |
| 186 | require.Equal(t, 1, len(schemaFileList)) |
| 187 | file := schemaFileList[0] |
| 188 | f, err := os.Open(file) |
| 189 | require.NoError(t, err) |
| 190 | |
| 191 | r, err := gzip.NewReader(f) |
| 192 | require.NoError(t, err) |
| 193 | var buf bytes.Buffer |
| 194 | _, err = buf.ReadFrom(r) |
| 195 | require.NoError(t, err) |
| 196 | |
| 197 | result, err := schema.Parse(buf.String()) |
| 198 | require.NoError(t, err) |
| 199 | |
| 200 | require.Equal(t, 2, len(result.Preds)) |
| 201 | require.Equal(t, "uid", types.TypeID(result.Preds[0].ValueType).Name()) |
| 202 | require.Equal(t, x.AttrInRootNamespace("http://www.w3.org/2000/01/rdf-schema#range"), |
| 203 | result.Preds[1].Predicate) |
| 204 | require.Equal(t, "uid", types.TypeID(result.Preds[1].ValueType).Name()) |
| 205 | |
| 206 | require.Equal(t, 1, len(result.Types)) |
| 207 | require.True(t, proto.Equal(result.Types[0], personType)) |
| 208 | } |
| 209 | |
| 210 | func checkExportGqlSchema(t *testing.T, gqlSchemaFiles []string) { |
| 211 | require.Equal(t, 1, len(gqlSchemaFiles)) |