IT4Change/Ocelot-Social
3
0
Fork 0
mirror of https://github.com/IT4Change/Ocelot-Social.git synced 2025-12-13 07:45:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

One notifyMentions function for Posts and Comments

Browse Source
This commit is contained in:
Wolfgang Huß 2019-07-18 17:33:34 +02:00
parent ccae251ad9
commit f47724da6a
1 changed files with 7 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
backend/src/middleware/handleHtmlContent/handleContentData.js
View File

@ -1,42 +1,23 @@
import extractMentionedUsers from './notifications/extractMentionedUsers'
import extractHashtags from './hashtags/extractHashtags'
const notifyMentionOfPost = async (postId, idsOfMentionedUsers, context) => {
if (!idsOfMentionedUsers.length) return
const session = context.driver.session()
const createdAt = new Date().toISOString()
const cypher = `
MATCH (u: User) WHERE u.id IN $idsOfMentionedUsers
MATCH (p: Post) WHERE p.id = $postId
CREATE (n: Notification { id: apoc.create.uuid(), read: false, createdAt: $createdAt })
MERGE (n)-[:NOTIFIED]->(u)
MERGE (p)-[:NOTIFIED]->(n)
`
await session.run(cypher, {
idsOfMentionedUsers,
createdAt,
postId,
})
session.close()
}
const notifyMentionOfComment = async (commentId, idsOfMentionedUsers, context) => {
const notifyMentions = async (label, id, idsOfMentionedUsers, context) => {
if (!idsOfMentionedUsers.length) return
const session = context.driver.session()
const createdAt = new Date().toISOString()
const cypher = `
MATCH (u: User) WHERE u.id in $idsOfMentionedUsers
MATCH (c: Comment) WHERE c.id = $commentId
MATCH (source) WHERE source.id = $id AND $label IN LABELS(source)
CREATE (n: Notification { id: apoc.create.uuid(), read: false, createdAt: $createdAt })
MERGE (n)-[:NOTIFIED]->(u)
MERGE (c)-[:NOTIFIED]->(n)
MERGE (source)-[:NOTIFIED]->(n)
`
await session.run(cypher, {
idsOfMentionedUsers,
label,
createdAt,
commentId,
id,
})
session.close()
}
@ -79,7 +60,7 @@ const handleContentDataOfPost = async (resolve, root, args, context, resolveInfo
// removes classes from the content
const post = await resolve(root, args, context, resolveInfo)
await notifyMentionOfPost(post.id, idsOfMentionedUsers, context)
await notifyMentions('Post', post.id, idsOfMentionedUsers, context)
await updateHashtagsOfPost(post.id, hashtags, context)
return post
@ -92,7 +73,7 @@ const handleContentDataOfComment = async (resolve, root, args, context, resolveI
// removes classes from the content
const comment = await resolve(root, args, context, resolveInfo)
await notifyMentionOfComment(comment.id, idsOfMentionedUsers, context)
await notifyMentions('Comment', comment.id, idsOfMentionedUsers, context)
return comment
}