Refactor shout/unshout mutations

- Remove unrecommended auto-commit transactions from code base
- Favor transaction functions
This commit is contained in:
mattwr18 2019-12-11 19:01:29 +01:00
parent 18ab7186f5
commit 1e85cbb6a2

View File

@ -1,3 +1,5 @@
import log from './helpers/databaseLogger'
export default { export default {
Mutation: { Mutation: {
shout: async (_object, params, context, _resolveInfo) => { shout: async (_object, params, context, _resolveInfo) => {
@ -5,22 +7,24 @@ export default {
const session = context.driver.session() const session = context.driver.session()
try { try {
const transactionRes = await session.run( const shoutWriteTxResultPromise = session.writeTransaction(async transaction => {
`MATCH (node {id: $id})<-[:WROTE]-(userWritten:User), (user:User {id: $userId}) const shoutTransactionResponse = await transaction.run(
`
MATCH (node {id: $id})<-[:WROTE]-(userWritten:User), (user:User {id: $userId})
WHERE $type IN labels(node) AND NOT userWritten.id = $userId WHERE $type IN labels(node) AND NOT userWritten.id = $userId
MERGE (user)-[relation:SHOUTED{createdAt:toString(datetime())}]->(node) MERGE (user)-[relation:SHOUTED{createdAt:toString(datetime())}]->(node)
RETURN COUNT(relation) > 0 as isShouted`, RETURN COUNT(relation) > 0 as isShouted
`,
{ {
id, id,
type, type,
userId: context.user.id, userId: context.user.id,
}, },
) )
log(shoutTransactionResponse)
const [isShouted] = transactionRes.records.map(record => { return shoutTransactionResponse.records.map(record => record.get('isShouted'))
return record.get('isShouted')
}) })
const [isShouted] = await shoutWriteTxResultPromise
return isShouted return isShouted
} finally { } finally {
session.close() session.close()
@ -31,20 +35,24 @@ export default {
const { id, type } = params const { id, type } = params
const session = context.driver.session() const session = context.driver.session()
try { try {
const transactionRes = await session.run( const unshoutWriteTxResultPromise = session.writeTransaction(async transaction => {
`MATCH (user:User {id: $userId})-[relation:SHOUTED]->(node {id: $id}) const unshoutTransactionResponse = await transaction.run(
`
MATCH (user:User {id: $userId})-[relation:SHOUTED]->(node {id: $id})
WHERE $type IN labels(node) WHERE $type IN labels(node)
DELETE relation DELETE relation
RETURN COUNT(relation) > 0 as isShouted`, RETURN COUNT(relation) > 0 as isShouted
`,
{ {
id, id,
type, type,
userId: context.user.id, userId: context.user.id,
}, },
) )
const [isShouted] = transactionRes.records.map(record => { log(unshoutTransactionResponse)
return record.get('isShouted') return unshoutTransactionResponse.records.map(record => record.get('isShouted'))
}) })
const [isShouted] = await unshoutWriteTxResultPromise
return isShouted return isShouted
} finally { } finally {
session.close() session.close()