From 1d2f7c895198f14fc3237c6c5adde4dfab8dc4c7 Mon Sep 17 00:00:00 2001 From: Behzad Rabiei <53224485+Behzad-rabiei@users.noreply.github.com> Date: Fri, 9 Aug 2024 22:29:43 +0400 Subject: [PATCH] fix: working on the neo4j queries --- src/services/memberActivity.service.ts | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/src/services/memberActivity.service.ts b/src/services/memberActivity.service.ts index 8935390..8bd519a 100644 --- a/src/services/memberActivity.service.ts +++ b/src/services/memberActivity.service.ts @@ -944,9 +944,9 @@ async function getMembersInteractionsNetworkGraph( const usersInNetworkGraph: string[] = []; // userInteraction const usersInteractionsQuery = ` - MATCH () -[r:INTERACTED_WITH {platformId: ${platformId}}]-() + MATCH () -[r:INTERACTED_WITH {platformId: "${platformId}"}]-() WITH max(r.date) as latest_date - MATCH (a:DiscordMember)-[r:INTERACTED_WITH {platformId: ${platformId}, date: latest_date}]->(b:DiscordMember) + MATCH (a:DiscordMember)-[r:INTERACTED_WITH {platformId: "${platformId}", date: latest_date}]->(b:DiscordMember) RETURN a, r, b`; const neo4jUsersInteractionsData = await Neo4j.read(usersInteractionsQuery); const { records: neo4jUsersInteractions } = neo4jUsersInteractionsData; @@ -974,9 +974,9 @@ async function getMembersInteractionsNetworkGraph( // userRadius const userRadiusQuery = ` - MATCH () -[r:INTERACTED_WITH {platformId: ${platformId}}]-() + MATCH () -[r:INTERACTED_WITH {platformId: "${platformId}"}]-() WITH max(r.date) as latest_date - MATCH (a:DiscordMember) -[r:INTERACTED_WITH {date: latest_date, platformId :${platformId}}]-(:DiscordMember) + MATCH (a:DiscordMember) -[r:INTERACTED_WITH {date: latest_date, platformId :"${platformId}"}]-(:DiscordMember) WITH a, r RETURN a.id as userId, SUM(r.weight) as radius`; const neo4jUserRadiusData = await Neo4j.read(userRadiusQuery); @@ -992,9 +992,9 @@ async function getMembersInteractionsNetworkGraph( // userStatus const userStatusQuery = ` - MATCH () -[r:INTERACTED_IN]-(g:DiscordPlatform {id: ${platformId}}) + MATCH () -[r:INTERACTED_IN]-(g:DiscordPlatform {id: "${platformId}"}) WITH max(r.date) as latest_date - MATCH (a:DiscordMember)-[r:INTERACTED_IN {date: latest_date}]->(g:DiscordPlatform {id: ${platformId}}) + MATCH (a:DiscordMember)-[r:INTERACTED_IN {date: latest_date}]->(g:DiscordPlatform {id: "${platformId}"}) RETURN a.id as userId, r.status as status`; const neo4jUserStatusData = await Neo4j.read(userStatusQuery); const { records: neo4jUserStatus } = neo4jUserStatusData; @@ -1058,9 +1058,9 @@ async function getFragmentationScore(platformId: string): Promise(g) + MATCH (g:DiscordPlatform {id: "${platformId}"})-[r:HAVE_METRICS {date: latest_date}]->(g) RETURN ((r.louvainModularityScore - (-1)) / 2) * 200 as fragmentation_score; `;