fix: fix the issue with identity id of the user

src/controllers/platform.controller.ts

@@ -386,7 +386,7 @@ const requestAccess = catchAsync(async function (req: ISessionRequest, res: Resp
 });
 
 const getReputationScore = catchAsync(async function (req: IAuthAndPlatform, res: Response) {
-  const reputationScore = await platformService.getReputationScore(req.platform, req.user.id);
+  const reputationScore = await platformService.getReputationScore(req.platform, req.user);
   res.send(reputationScore);
 });
 

src/index.ts

@@ -1,19 +1,21 @@
 import mongoose from 'mongoose';
+
+import { announcementEmitter } from '@togethercrew.dev/db';
+import RabbitMQ, { MBConnection } from '@togethercrew.dev/tc-messagebroker';
+
 import app from './app';
 import config from './config';
-import RabbitMQ, { MBConnection, Queue, Event } from '@togethercrew.dev/tc-messagebroker';
 import logger from './config/logger';
-import { announcementEmitter } from '@togethercrew.dev/db';
-import { announcementService } from './services';
 import rabbitMQClient from './rabbitmq/';
-import initializeHandlers from './rabbitmq/handlers';
+import { announcementService } from './services';
+
 mongoose.set('strictQuery', false);
 // Connect to RabbitMQ
 const setupRabbitMq = async () => {
   // Establish connection
   await rabbitMQClient.connect();
   // Initialize all event handlers
-  initializeHandlers();
+  // initializeHandlers();
 };
 
 // Connect to Message Broker DB

src/services/platform.service.ts

@@ -2,7 +2,7 @@ import { Snowflake } from 'discord.js';
 import httpStatus from 'http-status';
 import { FilterQuery, HydratedDocument, ObjectId, Types } from 'mongoose';
 
-import { IPlatform, Platform, PlatformNames } from '@togethercrew.dev/db';
+import { IPlatform, IUser, Platform, PlatformNames } from '@togethercrew.dev/db';
 
 import { analyzerAction, analyzerWindow } from '../config/analyzer.statics';
 import parentLogger from '../config/logger';
@@ -309,9 +309,13 @@ const validatePlatformUpdate = (platform: IAuthAndPlatform['platform'], body: IA
  * @param {IPlatform} platform
  * @param {IUser} user
  */
-const getReputationScore = async (platform: HydratedDocument<IPlatform>, userId: ObjectId) => {
+const getReputationScore = async (platform: HydratedDocument<IPlatform>, user: HydratedDocument<IUser>) => {
+  const identity = user.identities.find((id) => id.provider === platform.name);
+  if (!identity) {
+    throw new ApiError(httpStatus.BAD_REQUEST, `User need to login with the ${platform.name} account`);
+  }
   return {
-    reputationScore: (await reputationScoreService.calculateReputationScoreForUser(platform, userId)) * 100,
+    reputationScore: (await reputationScoreService.calculateReputationScoreForUser(platform, identity.id)) * 100,
   };
 };
 export default {

src/services/reputationScore.service.ts

@@ -1,4 +1,4 @@
-import { HydratedDocument, ObjectId } from 'mongoose';
+import { HydratedDocument } from 'mongoose';
 
 import { IPlatform } from '@togethercrew.dev/db';
 
@@ -11,21 +11,20 @@ const logger = parentLogger.child({ module: 'ReputationScoreService' });
 
 async function calculateReputationScoreForUser(
   platform: HydratedDocument<IPlatform>,
-  userId: ObjectId,
+  identity: string,
 ): Promise<number> {
   const platformName = platform.name as SupportedNeo4jPlatforms;
   const memberLabel = NEO4J_PLATFORM_INFO[platformName].member;
   const platformId = platform.id;
 
-  const reputationScoreQuery = buildReputationScoreQuery(userId, platformId, memberLabel);
+  const reputationScoreQuery = buildReputationScoreQuery(identity, platformId, memberLabel);
   const neo4jData = await Neo4j.read(reputationScoreQuery);
-
   return extractReputationScoreFromNeo4jData(neo4jData);
 }
 
-function buildReputationScoreQuery(userId: ObjectId, platformId: string, memberLabel: string): string {
+function buildReputationScoreQuery(identity: string, platformId: string, memberLabel: string): string {
   return `
-    MATCH (:${memberLabel} {id: "${userId}"})-[r:HAVE_METRICS {platformId: "${platformId}"}]->(a)
+    MATCH (:${memberLabel} {id: "${identity}"})-[r:HAVE_METRICS {platformId: "${platformId}"}]->(a)
     WITH r.date as metrics_date, r.closenessCentrality as memberScore
     ORDER BY metrics_date DESC
     LIMIT 1
@@ -34,18 +33,13 @@ function buildReputationScoreQuery(userId: ObjectId, platformId: string, memberL
     RETURN memberScore / maxScore AS reputation_score
   `;
 }
-
 function extractReputationScoreFromNeo4jData(neo4jData: any): number {
   const { records } = neo4jData;
-  logger.debug(`Neo4j Records: ${JSON.stringify(records)}`);
-
   if (records.length === 0) {
     return 0;
   }
-
   const reputationScoreResponse = records[0];
   const reputationScore = reputationScoreResponse.get('reputation_score');
-
   return reputationScore || 0;
 }