Ocelot-Social/backend/src/middleware/userInteractions.ts

/* eslint-disable @typescript-eslint/no-unsafe-return */
/* eslint-disable @typescript-eslint/no-unsafe-call */
/* eslint-disable @typescript-eslint/no-unsafe-member-access */
/* eslint-disable @typescript-eslint/no-unsafe-assignment */
/* eslint-disable @typescript-eslint/restrict-template-expressions */
const createRelatedCypher = (relation) => `
MATCH (user:User { id: $currentUser})
MATCH (post:Post { id: $postId})
OPTIONAL MATCH (post)<-[r:${relation}]-(u:User)
WHERE NOT u.disabled AND NOT u.deleted
WITH user, post, count(DISTINCT u) AS count
MERGE (user)-[relation:${relation} { }]->(post)
ON CREATE
SET relation.count = 1,
relation.createdAt = toString(datetime()),
post.clickedCount =  count + 1
ON MATCH
SET relation.count = relation.count + 1,
relation.updatedAt = toString(datetime()),
post.clickedCount = count
RETURN user, post, relation
`

const setPostCounter = async (postId, relation, context) => {
  const {
    user: { id: currentUser },
  } = context
  const session = context.driver.session()
  try {
    await session.writeTransaction((txc) => {
      return txc.run(createRelatedCypher(relation), { currentUser, postId })
    })
  } finally {
    session.close()
  }
}

const userClickedPost = async (resolve, root, args, context, info) => {
  if (args.id && context.user) {
    await setPostCounter(args.id, 'CLICKED', context)
  }
  return resolve(root, args, context, info)
}

export default {
  Query: {
    Post: userClickedPost,
  },
}