fix(export): don't return an error if there was no GraphQL schema

graphql/e2e/schema/schema_test.go

@@ -654,11 +654,47 @@ func TestIntrospection(t *testing.T) {
 	// introspection response or the JSON comparison. Needs deeper looking.
 }
 
+func TestDeleteSchemaAndExport(t *testing.T) {
+	// first apply a schema
+	schema := `
+	type Person {
+		name: String
+	}`
+	schemaResp := updateGQLSchemaReturnSchema(t, schema, groupOneAdminServer)
+
+	// now delete it with S * * delete mutation
+	dg, err := testutil.DgraphClient(groupOnegRPC)
+	require.NoError(t, err)
+	txn := dg.NewTxn()
+	_, err = txn.Mutate(context.Background(), &api.Mutation{
+		DelNquads: []byte(fmt.Sprintf("<%s> * * .", schemaResp.Id)),
+	})
+	require.NoError(t, err)
+	require.NoError(t, txn.Commit(context.Background()))
+
+	// running an export shouldn't give any errors
+	exportReq := &common.GraphQLParams{
+		Query: `mutation {
+		  export(input: {format: "rdf"}) {
+			exportedFiles
+		  }
+		}`,
+	}
+	exportGqlResp := exportReq.ExecuteAsPost(t, groupOneAdminServer)
+	common.RequireNoGQLErrors(t, exportGqlResp)
+
+	// applying a new schema should still work
+	newSchemaResp := updateGQLSchemaReturnSchema(t, schema, groupOneAdminServer)
+	// we can assert that the uid allocated to new schema isn't same as the uid for old schema
+	require.NotEqual(t, schemaResp.Id, newSchemaResp.Id)
+}
+
 func updateGQLSchema(t *testing.T, schema, url string) *common.GraphQLResponse {
 	req := &common.GraphQLParams{
 		Query: `mutation updateGQLSchema($sch: String!) {
 			updateGQLSchema(input: { set: { schema: $sch }}) {
 				gqlSchema {
+					id
 					schema
 				}
 			}
@@ -674,6 +710,19 @@ func updateGQLSchemaRequireNoErrors(t *testing.T, schema, url string) {
 	require.Nil(t, updateGQLSchema(t, schema, url).Errors)
 }
 
+func updateGQLSchemaReturnSchema(t *testing.T, schema, url string) gqlSchema {
+	resp := updateGQLSchema(t, schema, url)
+	require.Nil(t, resp.Errors)
+
+	var updateResp struct {
+		UpdateGQLSchema struct {
+			GqlSchema gqlSchema
+		}
+	}
+	require.NoError(t, json.Unmarshal(resp.Data, &updateResp))
+	return updateResp.UpdateGQLSchema.GqlSchema
+}
+
 func updateGQLSchemaConcurrent(t *testing.T, schema, url string) bool {
 	res := updateGQLSchema(t, schema, url)
 	err := res.Errors.Error()

worker/export.go

@@ -677,7 +677,14 @@ func exportInternal(ctx context.Context, in *pb.ExportRequest, db *badger.DB,
 			if err != nil {
 				return nil, errors.Wrapf(err, "cannot read value of GraphQL schema")
 			}
-			if len(vals) != 1 {
+			// if the GraphQL schema node was deleted with S * * delete mutation,
+			// then the data key will be overwritten with nil value.
+			// So, just skip exporting it as there will be no value for this data key.
+			if len(vals) == 0 {
+				return nil, nil
+			}
+			// Give an error only if we find more than one value for the schema.
+			if len(vals) > 1 {
 				return nil, errors.Errorf("found multiple values for the GraphQL schema")
 			}
 			val, ok := vals[0].Value.([]byte)