Skip to content

Commit

Permalink
Triple nested test on subscriptions
Browse files Browse the repository at this point in the history
  • Loading branch information
@angrykoala
angrykoala committed Mar 8, 2022
1 parent e9ac064 commit 95ad484
Show file tree
Hide file tree
Showing 2 changed files with 168 additions and 1 deletion.
70 changes: 69 additions & 1 deletion packages/graphql/tests/integration/subscriptions/delete/delete.int.test.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ describe("Subscriptions delete", () => {
plugin = new TestSubscriptionsPlugin();
const typeDefs = gql`
type ${typeActor.name} {
name: String!
id: ID!
movies: [${typeMovie.name}!]! @relationship(type: "ACTED_IN", direction: OUT)
}
Expand Down Expand Up @@ -173,4 +173,72 @@ describe("Subscriptions delete", () => {
])
);
});

test("triple nested delete with subscriptions enabled", async () => {
const query = `
mutation {
${typeMovie.operations.delete}(
where: { id: 1 }
delete: {
actors: {
where: { node: { id: 3 } }
delete: {
movies: {
where: { node: { id: 2 } }
delete: { actors: { where: { node: { id: 4 } } } }
}
}
}
}
) {
nodesDeleted
}
}
`;

await session.run(`
CREATE (m1:${typeMovie.name} { id: "1" })<-[:ACTED_IN]-(a:${typeActor.name} { id: "3" })
CREATE (m2:${typeMovie.name} { id: "2" })<-[:ACTED_IN]-(:${typeActor.name} { id: "4" })
CREATE (m2)<-[:ACTED_IN]-(a)
`);

const gqlResult: any = await graphql({
schema: await neoSchema.getSchema(),
source: query,
contextValue: { driver },
});

expect(gqlResult.errors).toBeUndefined();
expect(gqlResult.data[typeMovie.operations.delete].nodesDeleted).toBe(4);

expect(plugin.eventList).toHaveLength(4);
expect(plugin.eventList).toEqual(
expect.arrayContaining([
{
id: expect.any(Number),
timestamp: expect.any(Number),
event: "delete",
properties: { old: { id: "1" }, new: undefined },
},
{
id: expect.any(Number),
timestamp: expect.any(Number),
event: "delete",
properties: { old: { id: "3" }, new: undefined },
},
{
id: expect.any(Number),
timestamp: expect.any(Number),
event: "delete",
properties: { old: { id: "2" }, new: undefined },
},
{
id: expect.any(Number),
timestamp: expect.any(Number),
event: "delete",
properties: { old: { id: "4" }, new: undefined },
},
])
);
});
});
99 changes: 99 additions & 0 deletions packages/graphql/tests/tck/tck-test-files/subscriptions/delete.test.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -136,4 +136,103 @@ describe("Subscriptions metadata on delete", () => {
}"
`);
});
test("Triple Nested Delete", async () => {
const query = gql`
mutation {
deleteMovies(
where: { id: 123 }
delete: {
actors: {
where: { node: { name: "Actor to delete" } }
delete: {
movies: {
where: { node: { id: 321 } }
delete: { actors: { where: { node: { name: "Another actor to delete" } } } }
}
}
}
}
) {
nodesDeleted
}
}
`;

const req = createJwtRequest("secret", {});
const result = await translateQuery(neoSchema, query, {
req,
});

expect(formatCypher(result.cypher)).toMatchInlineSnapshot(`
"WITH [] AS meta
MATCH (this:Movie)
WHERE this.id = $this_id
WITH this, meta + { event: \\"delete\\", id: id(this), properties: { old: this { .* }, new: null }, timestamp: timestamp() } AS meta
WITH this, meta
OPTIONAL MATCH (this)<-[this_actors0_relationship:ACTED_IN]-(this_actors0:Actor)
WHERE this_actors0.name = $this_deleteMovies.args.delete.actors[0].where.node.name
WITH this, meta, this_actors0
OPTIONAL MATCH (this_actors0)-[this_actors0_movies0_relationship:ACTED_IN]->(this_actors0_movies0:Movie)
WHERE this_actors0_movies0.id = $this_deleteMovies.args.delete.actors[0].delete.movies[0].where.node.id
WITH this, meta, this_actors0, this_actors0_movies0
OPTIONAL MATCH (this_actors0_movies0)<-[this_actors0_movies0_actors0_relationship:ACTED_IN]-(this_actors0_movies0_actors0:Actor)
WHERE this_actors0_movies0_actors0.name = $this_deleteMovies.args.delete.actors[0].delete.movies[0].delete.actors[0].where.node.name
WITH this, meta, this_actors0, this_actors0_movies0, collect(DISTINCT this_actors0_movies0_actors0) as this_actors0_movies0_actors0_to_delete
WITH this,this_actors0,this_actors0_movies0,this_actors0_movies0_actors0_to_delete, REDUCE(m=meta, n IN this_actors0_movies0_actors0_to_delete | m + { event: \\"delete\\", id: id(n), properties: { old: n { .* }, new: null }, timestamp: timestamp() }) AS meta
FOREACH(x IN this_actors0_movies0_actors0_to_delete | DETACH DELETE x)
WITH this, meta, this_actors0, collect(DISTINCT this_actors0_movies0) as this_actors0_movies0_to_delete
WITH this,this_actors0,this_actors0_movies0_to_delete, REDUCE(m=meta, n IN this_actors0_movies0_to_delete | m + { event: \\"delete\\", id: id(n), properties: { old: n { .* }, new: null }, timestamp: timestamp() }) AS meta
FOREACH(x IN this_actors0_movies0_to_delete | DETACH DELETE x)
WITH this, meta, collect(DISTINCT this_actors0) as this_actors0_to_delete
WITH this,this_actors0_to_delete, REDUCE(m=meta, n IN this_actors0_to_delete | m + { event: \\"delete\\", id: id(n), properties: { old: n { .* }, new: null }, timestamp: timestamp() }) AS meta
FOREACH(x IN this_actors0_to_delete | DETACH DELETE x)
DETACH DELETE this
WITH meta
UNWIND meta AS m
RETURN collect(DISTINCT m) AS meta"
`);

expect(formatParams(result.params)).toMatchInlineSnapshot(`
"{
\\"this_id\\": \\"123\\",
\\"this_deleteMovies\\": {
\\"args\\": {
\\"delete\\": {
\\"actors\\": [
{
\\"where\\": {
\\"node\\": {
\\"name\\": \\"Actor to delete\\"
}
},
\\"delete\\": {
\\"movies\\": [
{
\\"where\\": {
\\"node\\": {
\\"id\\": \\"321\\"
}
},
\\"delete\\": {
\\"actors\\": [
{
\\"where\\": {
\\"node\\": {
\\"name\\": \\"Another actor to delete\\"
}
}
}
]
}
}
]
}
}
]
}
}
}
}"
`);
});
});

0 comments on commit 95ad484

Please sign in to comment.