Merging kb packages

elevate-mentoring/controllers/customHandler.js

@@ -0,0 +1,16 @@
+const routesConfig = require('../constants/routes')
+const mentorController = require('./mentoring')
+
+const customHandler = async (req, res) => {
+	const selectedRouteConfig = routesConfig.routes.find((obj) => obj.sourceRoute === req.sourceRoute)
+
+    if(selectedRouteConfig && selectedRouteConfig.service){
+		req['baseUrl'] = process.env[`${selectedRouteConfig.service.toUpperCase()}_SERVICE_BASE_URL`]
+	}
+	return await mentorController[selectedRouteConfig.targetRoute.functionName](req, res, selectedRouteConfig)
+}
+
+const customHandlerController = {
+	customHandler,
+}
+module.exports = customHandlerController

elevate-mentoring/controllers/mentoring.js

@@ -1,38 +1,211 @@
 const requesters = require('../utils/requester')
 const routeConfigs = require('../constants/routes')
 const requestParser = require('../utils/requestParser')
+const {convertIdsToString} = require('../utils/integerToStringConverter')
+
 
 const createProfile = async (req, res, responses) => {
-	const selectedConfig = routeConfigs.routes.find((obj) => obj.sourceRoute === req.sourceRoute)
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
 	req.body.skipValidation = true
+
+	console.log("--------- createProfile -------",req.headers);
 	return await requesters.post(req.baseUrl, selectedConfig.targetRoute.path, req.body, {
-		'X-auth-token': `bearer ${responses.user.result.access_token}`,
+		'origin': req.headers['origin'],
+		'X-auth-token': `${responses.user.result.access_token}`, // override or add this header
 	})
 }
 const updateUser = async (req, res, responses) => {
-	const selectedConfig = routeConfigs.routes.find((obj) => obj.sourceRoute === req.sourceRoute)
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
 
 	//const filteredRequestBody = requestParser.transformUpdateUserBody(req.body)
 	console.log(req.baseUrl, selectedConfig.targetRoute.path, req.headers, req.body, 'mentoring request')
 	return await requesters.patch(req.baseUrl, selectedConfig.targetRoute.path, req.body, req.headers)
 }
 
 const entityTypeRead = async (req, res, responses) => {
-	const selectedConfig = routeConfigs.routes.find((obj) => obj.sourceRoute === req.sourceRoute)
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
 	return await requesters.post(req.baseUrl, selectedConfig.targetRoute.path, req.body, {
 		'X-auth-token': req.headers['x-auth-token'],
 	})
 }
 
+const userAddEvent = async (req, res, responses) => {
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
+	const allowedEventTypes = ['bulk-create']
+	if(allowedEventTypes.includes(req.body.eventType)){
+
+		req.body.organization_id = req.body.organizations[0].id
+		req.body.roles = req.body.organizations[0].roles.map((role) => {
+			return {
+				title : role.title
+			}
+		})
+
+		return await requesters.post(req.baseUrl, selectedConfig.targetRoute.path, req.body, {
+			'internal_access_token': req.headers['internal_access_token'],
+		})
+	} else {
+		// Return a resolved Promise with a success response
+		return Promise.resolve({
+			success: true,
+			message: 'No Action taken.',
+			data: {},
+		  });
+	}
+
+} 
+
 const rolePermissions = async (req, res, responses) => {
-	const selectedConfig = routeConfigs.routes.find((obj) => obj.sourceRoute === req.sourceRoute)
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
+
+	console.log("selected config",selectedConfig);
+
+	console.log("selected req.baseUrl",req.baseUrl);
+
+	console.log("selected req.responses",JSON.stringify(responses));
+
 	return await requesters.post(req.baseUrl, selectedConfig.targetRoute.path,req.body,{
-		'X-auth-token': `bearer ${responses.user.result.access_token}`,
+		'X-auth-token': `${responses.user.result.access_token}`,
 	})
 }
 
+const createUser = async (req, res, responses) => {
+	const selectedConfig = routeConfigs.routes.find((obj) =>  req.service === obj.service && obj.sourceRoute === req.sourceRoute)
+
+	console.log("--------- createUser -------",req.headers);
+	return await requesters.post(req.baseUrl, selectedConfig.targetRoute.path, req.body,{
+		'origin': req.headers['origin'],
+		'device-info': req.headers['device-info'],
+	})
+}
+
+
+const loginUser = async (req, res, responses) => {
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
+
+
+	let data = await requesters.post(req.baseUrl, selectedConfig.targetRoute.path, req.body,{
+		'captcha-token': req.headers['captcha-token'],
+		'device-info': req.headers['device-info'],
+	})
+	return data
+}
+
+const readOrganization = async (req, res, selectedConfig) => {
+	try {
+		const parameterisedRoute = req.query.organisation_code ? selectedConfig.targetRoute.path + `?organisation_code=${req.query.organisation_code}` : selectedConfig.targetRoute.path + `?organisation_id=${req.query.organisation_id}`
+		let response = await requesters.get(req.baseUrl, parameterisedRoute , {
+			'internal_access_token': req.headers['internal_access_token'],
+			'Content-Type':'application/json'
+		})
+	    response.result = convertIdsToString(response.result)
+		return res.json(response)
+	} catch (error) {
+		console.error('Error fetching organization details:', error)
+		return res.status(500).json({ error: 'Internal Server Error' })
+	}
+}
+
+const readUser = async (req, res, selectedConfig) => {
+	try {
+	  const parameterisedRoute = req.params.id ? selectedConfig.targetRoute.path.replace('/:id', `/${req.params.id}`) : selectedConfig.targetRoute.path;
+	  let headers
+
+	  if (req.params.id) {
+
+		if(req.headers['x-auth-token']){
+			headers = {
+				'Content-Type': 'application/json',
+				'X-auth-token': req.headers['x-auth-token'],
+			  }	
+		} else {
+			headers = {
+				'internal_access_token': req.headers['internal_access_token'],
+				'Content-Type': 'application/json',
+			}
+		}
+
+	  } else {
+		headers = {
+		  'X-auth-token': req.headers['x-auth-token'],
+		  'Content-Type': 'application/json',
+		}
+	  }
+
+	  let response = await requesters.get(req.baseUrl, parameterisedRoute, headers)
+
+
+	  if(response && response.result){
+			response.result = convertIdsToString(response.result)
+			return res.json(response)
+	   } else {
+
+		let data ={
+			error: 'Internal Server Error'
+		}
+
+		return res.status(response.status? response.status: 500).json(response.data ? response.data : data)
+		//  return res.json(response);
+	   }
+
+	  // Extract only the relevant data
+
+	//   return res.json(return)
+	} catch (error) {
+	  console.error('Error fetching user details:', error);
+	  return res.status(500).json({ error: 'Internal Server Error' })
+	}
+  };
+
+
+  const accountsList = async (req, res, selectedConfig) => {
+	try {
+		const userIds = req.body.userIds // Extract userIds from the request body
+		const excludeDeletedRecords = req.query.exclude_deleted_records === 'true'
+
+		const parameterisedRoute = excludeDeletedRecords 
+			? `${selectedConfig.targetRoute.path}?exclude_deleted_records=true` 
+			: selectedConfig.targetRoute.path
+
+		const headers = {
+			'internal_access_token': req.headers['internal_access_token'],
+			'Content-Type': 'application/json',
+		}
+
+		const requestBody = { userIds } // Pass the request body
+		const accountsListResponse = await requesters.get(req.baseUrl, parameterisedRoute, headers, requestBody)
+
+		accountsListResponse.result = await convertIdsToString(accountsListResponse.result)
+
+		return res.json(accountsListResponse)
+	} catch (error) {
+		console.error('Error fetching list of user details:', error);
+		return res.status(500).json({ error: 'Internal Server Error' });
+	}
+}
+
+
+const validateEmails = async (req, res , selectedConfig) => {
+	try{
+		const emailIds = req.body.emailIds 
+
+		const headers = {
+			'internal_access_token': req.headers['internal_access_token'],
+			'Content-Type': 'application/json',
+		}
+
+		const requestBody = { emailIds } // Pass the request body
+
+		const userListResponse = await requesters.post(req.baseUrl, selectedConfig.targetRoute.path, requestBody, headers)    
+		userListResponse.result = await convertIdsToString(userListResponse.result)
+		return res.json(userListResponse)
+	} catch (error) {
+		console.error('Error fetching user details by email :', error)
+		return res.status(500).json({ error: 'Internal Server Error' })
+	}
+}
 const mentorDetails = async (req, res, responses) => {
-	const selectedConfig = routeConfigs.routes.find((obj) => obj.sourceRoute === req.sourceRoute)
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
 
 	const parameterisedRoute = req.params.id ? selectedConfig.targetRoute.path.replace('/:id', `/${req.params.id}`) : selectedConfig.targetRoute.path;
 	  let headers
@@ -52,7 +225,7 @@ const mentorDetails = async (req, res, responses) => {
 }
 
 const mentoringProfile = async (req, res, responses) => {
-	const selectedConfig = routeConfigs.routes.find((obj) => obj.sourceRoute === req.sourceRoute)
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
 
 	const parameterisedRoute = selectedConfig.targetRoute.path;
 	  let headers
@@ -61,8 +234,59 @@ const mentoringProfile = async (req, res, responses) => {
 		  'Content-Type': 'application/json',
 		  'X-auth-token': req.headers['x-auth-token'],
 		}
+
+		console.error("------------------mentoringProfile  ----------")
 
 	 let response = await requesters.get(req.baseUrl, parameterisedRoute,headers,{})
+	 console.error("------------------response in mentoring profile  ----------",response)
+	  return response
+
+}
+const getUserDetailsFromExternal = async (req, res, responses) => {
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
+
+	let parameterisedRoute = selectedConfig.targetRoute.path;
+
+	if(req.params.id){
+		parameterisedRoute = parameterisedRoute+'/'+req.params.id;
+	}
+	let	headers = {
+		  'Content-Type': 'application/json',
+		  'X-auth-token': req.headers['x-auth-token'],
+		}
+
+		console.log("parameterisedRoute ---------------",parameterisedRoute);
+
+
+	 let response = await requesters.get(req.baseUrl, parameterisedRoute,headers,{})
+	  return response
+
+}
+
+const userDetails = async (req, res, responses) => {
+	const selectedConfig = routeConfigs.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
+
+	const parameterisedRoute = selectedConfig.targetRoute.path;
+
+	console.error("============== cllaing user details")
+	let headers
+	if (req.params.id) {
+		headers = {
+		  'internal_access_token': req.headers['internal_access_token'],
+		  'Content-Type': 'application/json',
+		}
+	  } else {
+	    headers = {
+		  'Content-Type': 'application/json',
+		  'X-auth-token': req.headers['x-auth-token'],
+		}
+	}
+	console.log("parameterisedRoute API  =========",parameterisedRoute);
+	console.error(" ----------- parameterisedRoute API  =========",parameterisedRoute);
+
+
+	 let response = await requesters.get(req.baseUrl, parameterisedRoute,headers,{})
+	 console.log(req.baseUrl,"parameterisedRoute API  =========",response);
 	  return response
 
 }
@@ -72,8 +296,19 @@ mentoringController = {
 	updateUser,
 	entityTypeRead,
 	rolePermissions,
+	createUser,
+	updateUser,
+	entityTypeRead,
+	loginUser,
+	readOrganization,
+	readUser,
+	accountsList,
+	validateEmails,
 	mentorDetails,
-	mentoringProfile
+	mentoringProfile,
+	userDetails,
+	getUserDetailsFromExternal,
+	userAddEvent
 }
 
 module.exports = mentoringController

elevate-mentoring/controllers/orchestrationController.js

@@ -1,9 +1,18 @@
 const routesConfig = require('../constants/routes')
 const mentoringController = require('../controllers/mentoring')
 const orchestrationHandler = async (req, res, responses) => {
-	console.log(req.targetPackages, req.inSequence, req.orchestrated, req.sourceRoute, responses)
+
+	console.log(req.service,req.targetPackages, req.inSequence, req.orchestrated, req.sourceRoute, responses)
 	console.log(req.body)
-	const selectedRouteConfig = routesConfig.routes.find((obj) => obj.sourceRoute === req.sourceRoute)
+
+	const selectedRouteConfig = routesConfig.routes.find((obj) => req.service === obj.service && obj.sourceRoute === req.sourceRoute)
+
+
+	console.log(" selectedRouteConfig ---------- ",selectedRouteConfig);
+
+	if(selectedRouteConfig && selectedRouteConfig.service){
+		req['baseUrl'] = process.env[`${selectedRouteConfig.service.toUpperCase()}_SERVICE_BASE_URL`]
+	}
 	return await mentoringController[selectedRouteConfig.targetRoute.functionName](req, res, responses)
 }
 

elevate-mentoring/helpers/dependencyManager.js

@@ -0,0 +1,13 @@
+const kafkaManager = require('./kafkaManager')
+
+const dependencyManager = (dependencyMap, environmentVariables) =>{
+    try{
+        console.log("--------------- dependencyManager elevate-kafka--   ");
+        kafkaManager(dependencyMap.get('kafka'),environmentVariables)
+    }catch(error){
+        console.log(error)
+        throw error
+    }
+}
+
+module.exports = dependencyManager